public class StaticFileStoreSource extends FlinkSource
FlinkSource
for reading records. It does not monitor new snapshots.limit, predicate, projectedFields
Constructor and Description |
---|
StaticFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
StaticFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit,
StaticDataFileSnapshotEnumerator.Factory enumeratorFactory) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.connector.source.Boundedness |
getBoundedness() |
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
PendingSplitsCheckpoint checkpoint) |
createEnumerator, createReader, getEnumeratorCheckpointSerializer, getSplitSerializer
public StaticFileStoreSource(DataTable table, @Nullable int[][] projectedFields, @Nullable Predicate predicate, @Nullable Long limit)
public org.apache.flink.api.connector.source.Boundedness getBoundedness()
public org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, PendingSplitsCheckpoint checkpoint)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.