public class SimpleSystemSource extends FlinkSource
FlinkSource
for system table.limit, predicate, projectedFields, table
Constructor and Description |
---|
SimpleSystemSource(Table table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
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 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.