Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
LookupCompactDiffRead.reader(Split split) |
Modifier and Type | Method and Description |
---|---|
Split |
FileStoreSourceSplit.split() |
Modifier and Type | Method and Description |
---|---|
List<FileStoreSourceSplit> |
FileStoreSourceSplitGenerator.createSplits(List<Split> splits) |
Constructor and Description |
---|
FileStoreSourceSplit(String id,
Split split) |
FileStoreSourceSplit(String id,
Split split,
long recordsToSkip) |
Modifier and Type | Class and Description |
---|---|
class |
PlaceholderSplit
Used as a placeholder for an empty snapshot, indicating that the current snapshot does not
contain any
Split . |
Modifier and Type | Method and Description |
---|---|
void |
ReadOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Split> record) |
void |
MultiTablesReadOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.api.java.tuple.Tuple2<Split,String>> record) |
void |
MonitorFunction.run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<Split> ctx) |
Modifier and Type | Method and Description |
---|---|
static RecordReader<InternalRow> |
SplitsParallelReadUtil.parallelExecute(RowType projectedType,
FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder,
List<Split> splits,
int pageSize,
int parallelism) |
static RecordReader<InternalRow> |
SplitsParallelReadUtil.parallelExecute(RowType projectedType,
FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder,
List<Split> splits,
int pageSize,
int parallelism) |
static <EXTRA> RecordReader<InternalRow> |
SplitsParallelReadUtil.parallelExecute(RowType projectedType,
FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder,
List<Split> splits,
int pageSize,
int parallelism,
java.util.function.Function<Split,EXTRA> extraFunction,
java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow) |
static <EXTRA> RecordReader<InternalRow> |
SplitsParallelReadUtil.parallelExecute(RowType projectedType,
FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder,
List<Split> splits,
int pageSize,
int parallelism,
java.util.function.Function<Split,EXTRA> extraFunction,
java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow) |
static <EXTRA> RecordReader<InternalRow> |
SplitsParallelReadUtil.parallelExecute(RowType projectedType,
FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder,
List<Split> splits,
int pageSize,
int parallelism,
java.util.function.Function<Split,EXTRA> extraFunction,
java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow) |
Modifier and Type | Class and Description |
---|---|
class |
DataSplit
Input splits.
|
class |
SingletonSplit
Singleton split use for system table, in which, scan always just produce one split.
|
Modifier and Type | Method and Description |
---|---|
List<Split> |
SnapshotNotExistPlan.splits() |
List<Split> |
TableScan.Plan.splits() |
List<Split> |
PlanImpl.splits() |
List<Split> |
DataFilePlan.splits() |
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
TableRead.createReader(Split split) |
RecordReader<InternalRow> |
AbstractDataTableRead.createReader(Split split) |
RecordReader<InternalRow> |
KeyValueTableRead.reader(Split split) |
abstract RecordReader<InternalRow> |
AbstractDataTableRead.reader(Split split) |
Modifier and Type | Method and Description |
---|---|
default RecordReader<InternalRow> |
TableRead.createReader(List<Split> splits) |
Constructor and Description |
---|
PlanImpl(Long watermark,
Long snapshotId,
List<Split> splits) |
Modifier and Type | Method and Description |
---|---|
List<Split> |
SnapshotReader.Plan.splits()
Result splits.
|
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
TableLineageTable.TableLineageRead.createReader(Split split) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.