Structs§
- From
Stream State Store Iter - Fused
State Store Iter - Init
Options - NewLocal
Options - NewRead
Snapshot Options - Next
Epoch Options - Prefetch
Options - If
prefetchis true, prefetch will be enabled. Prefetching may increase the memory footprint of the CN process because the prefetched blocks cannot be evicted. Since the streaming-read of object-storage may hung in some case, we still use sync short read for both batch-query and streaming process. So this configure is unused. - Read
LogOptions - Read
Options - Seal
Current Epoch Options - TryWait
Epoch Options - Write
Options
Enums§
Statics§
Traits§
- Iter
Item - Local
State Store - A state store that is dedicated for streaming operator, which only reads the uncommitted data
written by itself. Each local state store is not
Clone, and is owned by a streaming state table. - State
Store - State
Store Iter - State
Store Iter Ext - State
Store Read - State
Store Read Log