Package | Description |
---|---|
org.apache.flink.table.store.connector.source | |
org.apache.flink.table.store.spark | |
org.apache.flink.table.store.table.source |
Modifier and Type | Method and Description |
---|---|
Split |
FileStoreSourceSplit.split() |
Constructor and Description |
---|
FileStoreSourceSplit(String id,
Split split) |
FileStoreSourceSplit(String id,
Split split,
long recordsToSkip) |
Modifier and Type | Method and Description |
---|---|
Split |
SparkInputPartition.split() |
Modifier and Type | Method and Description |
---|---|
protected List<Split> |
SparkDataSourceReader.splits() |
protected List<Split> |
SparkScan.splits() |
Constructor and Description |
---|
SparkInputPartition(Split split) |
Modifier and Type | Class and Description |
---|---|
class |
DataSplit
Input splits.
|
Modifier and Type | Method and Description |
---|---|
List<Split> |
DataTableScan.DataFilePlan.splits() |
List<Split> |
TableScan.Plan.splits() |
Modifier and Type | Method and Description |
---|---|
RecordReader<org.apache.flink.table.data.RowData> |
TableRead.createReader(Split split) |
RecordReader<org.apache.flink.table.data.RowData> |
KeyValueTableRead.createReader(Split split) |
Modifier and Type | Method and Description |
---|---|
default RecordReader<org.apache.flink.table.data.RowData> |
TableRead.createReader(List<Split> splits) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.