public class ReadBuilderImpl extends Object implements ReadBuilder
ReadBuilder
.Constructor and Description |
---|
ReadBuilderImpl(InnerTable table) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
TableRead |
newRead()
|
TableScan |
newScan()
Create a
TableScan to perform batch planning. |
StreamTableScan |
newStreamScan()
Create a
TableScan to perform streaming planning. |
RowType |
readType()
Returns read row type.
|
String |
tableName()
A name to identify the table.
|
ReadBuilder |
withBucketFilter(Filter<Integer> bucketFilter)
Push bucket filter.
|
ReadBuilder |
withFilter(Predicate filter)
Push filters, will filter the data as much as possible, but it is not guaranteed that it is a
complete filter.
|
ReadBuilder |
withLimit(int limit)
the row number pushed down.
|
ReadBuilder |
withPartitionFilter(Map<String,String> partitionSpec)
Push partition filter.
|
ReadBuilder |
withProjection(int[] projection)
Apply projection to the reader, if you need nested row pruning, use
ReadBuilder.withReadType(RowType) instead. |
ReadBuilder |
withReadType(RowType readType)
Push read row type to the reader, support nested row pruning.
|
ReadBuilder |
withShard(int indexOfThisSubtask,
int numberOfParallelSubtasks)
Specify the shard to be read, and allocate sharded files to read records.
|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
withFilter, withProjection
public ReadBuilderImpl(InnerTable table)
public String tableName()
ReadBuilder
tableName
in interface ReadBuilder
public RowType readType()
ReadBuilder
readType
in interface ReadBuilder
public ReadBuilder withFilter(Predicate filter)
ReadBuilder
withFilter
in interface ReadBuilder
public ReadBuilder withPartitionFilter(Map<String,String> partitionSpec)
ReadBuilder
withPartitionFilter
in interface ReadBuilder
public ReadBuilder withReadType(RowType readType)
ReadBuilder
withReadType
in interface ReadBuilder
readType
- read row type, can be a pruned type from Table.rowType()
public ReadBuilder withProjection(int[] projection)
ReadBuilder
ReadBuilder.withReadType(RowType)
instead.withProjection
in interface ReadBuilder
public ReadBuilder withLimit(int limit)
ReadBuilder
withLimit
in interface ReadBuilder
public ReadBuilder withShard(int indexOfThisSubtask, int numberOfParallelSubtasks)
ReadBuilder
ReadBuilder.withBucketFilter(Filter)
.
Reason: Sharding and bucket filtering are different logical mechanisms for selecting subsets of table data. Applying both methods simultaneously introduces conflicting selection criteria.
withShard
in interface ReadBuilder
public ReadBuilder withBucketFilter(Filter<Integer> bucketFilter)
ReadBuilder
ReadBuilder.withShard(int, int)
.
Reason: Bucket filtering and sharding are different logical mechanisms for selecting subsets of table data. Applying both methods simultaneously introduces conflicting selection criteria.
withBucketFilter
in interface ReadBuilder
public TableScan newScan()
ReadBuilder
TableScan
to perform batch planning.newScan
in interface ReadBuilder
public StreamTableScan newStreamScan()
ReadBuilder
TableScan
to perform streaming planning.newStreamScan
in interface ReadBuilder
public TableRead newRead()
ReadBuilder
newRead
in interface ReadBuilder
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.