Modifier and Type | Field and Description |
---|---|
protected ReadBuilder |
FlinkSource.readBuilder |
Constructor and Description |
---|
ContinuousFileStoreSource(ReadBuilder readBuilder,
Map<String,String> options,
Long limit) |
ContinuousFileStoreSource(ReadBuilder readBuilder,
Map<String,String> options,
Long limit,
BucketMode bucketMode) |
FlinkSource(ReadBuilder readBuilder,
Long limit) |
StaticFileStoreSource(ReadBuilder readBuilder,
Long limit,
int splitBatchSize,
FlinkConnectorOptions.SplitAssignMode splitAssignMode) |
StaticFileStoreSource(ReadBuilder readBuilder,
Long limit,
int splitBatchSize,
FlinkConnectorOptions.SplitAssignMode splitAssignMode,
DynamicPartitionFilteringInfo dynamicPartitionFilteringInfo) |
Constructor and Description |
---|
AlignedContinuousFileStoreSource(ReadBuilder readBuilder,
Map<String,String> options,
Long limit,
BucketMode bucketMode) |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> |
MonitorFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo,
ReadBuilder readBuilder,
long monitorInterval,
boolean emitSnapshotWatermark,
boolean shuffleBucketWithPartition,
BucketMode bucketMode) |
Constructor and Description |
---|
MonitorFunction(ReadBuilder readBuilder,
long monitorInterval,
boolean emitSnapshotWatermark) |
ReadOperator(ReadBuilder readBuilder) |
Constructor and Description |
---|
PaimonRecordReader(ReadBuilder readBuilder,
PaimonInputSplit split,
List<String> paimonColumns,
List<String> hiveColumns,
List<String> selectedColumns,
String tagToPartField) |
Modifier and Type | Method and Description |
---|---|
ReadBuilder |
Table.newReadBuilder()
Returns a new read builder.
|
default ReadBuilder |
FormatTable.newReadBuilder() |
default ReadBuilder |
InnerTable.newReadBuilder() |
Modifier and Type | Class and Description |
---|---|
class |
ReadBuilderImpl
Implementation for
ReadBuilder . |
Modifier and Type | Method and Description |
---|---|
ReadBuilder |
ReadBuilderImpl.withBucketFilter(Filter<Integer> bucketFilter) |
ReadBuilder |
ReadBuilder.withBucketFilter(Filter<Integer> bucketFilter)
Push bucket filter.
|
default ReadBuilder |
ReadBuilder.withFilter(List<Predicate> predicates)
Apply filters to the readers to decrease the number of produced records.
|
ReadBuilder |
ReadBuilderImpl.withFilter(Predicate filter) |
ReadBuilder |
ReadBuilder.withFilter(Predicate predicate)
Push filters, will filter the data as much as possible, but it is not guaranteed that it is a
complete filter.
|
ReadBuilder |
ReadBuilderImpl.withLimit(int limit) |
ReadBuilder |
ReadBuilder.withLimit(int limit)
the row number pushed down.
|
ReadBuilder |
ReadBuilderImpl.withPartitionFilter(Map<String,String> partitionSpec) |
ReadBuilder |
ReadBuilder.withPartitionFilter(Map<String,String> partitionSpec)
Push partition filter.
|
ReadBuilder |
ReadBuilderImpl.withProjection(int[] projection) |
ReadBuilder |
ReadBuilder.withProjection(int[] projection)
Apply projection to the reader, if you need nested row pruning, use
withReadType(RowType) instead. |
default ReadBuilder |
ReadBuilder.withProjection(int[][] projection)
Deprecated.
|
ReadBuilder |
ReadBuilderImpl.withReadType(RowType readType) |
ReadBuilder |
ReadBuilder.withReadType(RowType readType)
Push read row type to the reader, support nested row pruning.
|
ReadBuilder |
ReadBuilderImpl.withShard(int indexOfThisSubtask,
int numberOfParallelSubtasks) |
ReadBuilder |
ReadBuilder.withShard(int indexOfThisSubtask,
int numberOfParallelSubtasks)
Specify the shard to be read, and allocate sharded files to read records.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.