public abstract class FlinkSource extends Object implements org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,FileStoreSourceSplit,PendingSplitsCheckpoint>
Source
for paimon.Modifier and Type | Field and Description |
---|---|
protected Long |
limit |
protected ReadBuilder |
readBuilder |
Constructor and Description |
---|
FlinkSource(ReadBuilder readBuilder,
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 ReadBuilder readBuilder
public FlinkSource(ReadBuilder readBuilder, @Nullable Long limit)
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.SourceReaderFactory<org.apache.flink.table.data.RowData,FileStoreSourceSplit>
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 © 2023–2024 The Apache Software Foundation. All rights reserved.