FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withBucketFilter(Filter<Integer> bucketFilter) |
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withFilter(Predicate predicate) |
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withLevelFilter(Filter<Integer> levelFilter) |
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withLimit(int limit) |
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withMetricRegistry(MetricRegistry metricRegistry) |
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withPartitionFilter(List<BinaryRow> partitions) |
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withPartitionFilter(Map<String,String> partitionSpec) |
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withShard(int indexOfThisSubtask,
int numberOfParallelSubtasks) |