Uses of Class
org.apache.paimon.flink.FlinkConnectorOptions.SplitAssignMode

Packages that use FlinkConnectorOptions.SplitAssignMode

Package	Description
org.apache.paimon.flink
org.apache.paimon.flink.source

Uses of FlinkConnectorOptions.SplitAssignMode in org.apache.paimon.flink

Fields in org.apache.paimon.flink with type parameters of type FlinkConnectorOptions.SplitAssignMode

Modifier and Type	Field and Description
static ConfigOption<FlinkConnectorOptions.SplitAssignMode>	FlinkConnectorOptions.SCAN_SPLIT_ENUMERATOR_ASSIGN_MODE

Methods in org.apache.paimon.flink that return FlinkConnectorOptions.SplitAssignMode

Modifier and Type	Method and Description
static FlinkConnectorOptions.SplitAssignMode	FlinkConnectorOptions.SplitAssignMode.valueOf(String name) Returns the enum constant of this type with the specified name.
static FlinkConnectorOptions.SplitAssignMode[]	FlinkConnectorOptions.SplitAssignMode.values() Returns an array containing the constants of this enum type, in the order they are declared.

Uses of FlinkConnectorOptions.SplitAssignMode in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source with parameters of type FlinkConnectorOptions.SplitAssignMode

Modifier and Type	Method and Description
static SplitAssigner	StaticFileStoreSource.createSplitAssigner(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, Collection<FileStoreSourceSplit> splits)

Constructors in org.apache.paimon.flink.source with parameters of type FlinkConnectorOptions.SplitAssignMode

Constructor and Description
StaticFileStoreSource(ReadBuilder readBuilder, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode)
StaticFileStoreSource(ReadBuilder readBuilder, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, DynamicPartitionFilteringInfo dynamicPartitionFilteringInfo)
SystemTableSource(Table table, boolean isStreamingMode, Predicate predicate, int[][] projectFields, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)