risingwave_pb::stream_plan

Type Alias PbFragmentTypeFlag

source
pub type PbFragmentTypeFlag = FragmentTypeFlag;
Expand description

Alias for FragmentTypeFlag.

Aliased Type§

enum PbFragmentTypeFlag {
Show 13 variants FragmentUnspecified = 0, Source = 1, Mview = 2, Sink = 4, Now = 8, StreamScan = 16, BarrierRecv = 32, Values = 64, Dml = 128, CdcFilter = 256, SourceScan = 1_024, SnapshotBackfillStreamScan = 2_048, FsFetch = 4_096,
}

Variants§

§

FragmentUnspecified = 0

§

Source = 1

§

Mview = 2

§

Sink = 4

§

Now = 8

TODO: Remove this and insert a BarrierRecv instead.

§

StreamScan = 16

Include StreamScan and StreamCdcScan

§

BarrierRecv = 32

§

Values = 64

§

Dml = 128

§

CdcFilter = 256

§

SourceScan = 1_024

§

SnapshotBackfillStreamScan = 2_048

§

FsFetch = 4_096

Note: this flag is not available in old fragments, so only suitable for debugging purpose.