public abstract class FlinkSource extends Object implements org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>
Source
for table store.Modifier and Type | Field and Description |
---|---|
protected Long |
limit |
protected Predicate |
predicate |
protected int[][] |
projectedFields |
protected Table |
table |
Constructor and Description |
---|
FlinkSource(Table table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context) |
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,FileStoreSourceSplit> |
createReader(org.apache.flink.api.connector.source.SourceReaderContext context) |
PendingSplitsCheckpointSerializer |
getEnumeratorCheckpointSerializer() |
FileStoreSourceSplitSerializer |
getSplitSerializer() |
protected final Table table
@Nullable protected final int[][] projectedFields
public org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,FileStoreSourceSplit> createReader(org.apache.flink.api.connector.source.SourceReaderContext context)
createReader
in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>
public org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context) throws Exception
createEnumerator
in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>
Exception
public FileStoreSourceSplitSerializer getSplitSerializer()
getSplitSerializer
in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>
public PendingSplitsCheckpointSerializer getEnumeratorCheckpointSerializer()
getEnumeratorCheckpointSerializer
in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.