public static class KeyValueFileReaderFactory.Builder extends Object
KeyValueFileReaderFactory
.Modifier and Type | Method and Description |
---|---|
KeyValueFileReaderFactory |
build(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket) |
KeyValueFileReaderFactory |
build(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
boolean projectKeys,
List<Predicate> filters) |
KeyValueFileReaderFactory.Builder |
withKeyProjection(int[][] projection) |
KeyValueFileReaderFactory.Builder |
withValueProjection(int[][] projection) |
public KeyValueFileReaderFactory.Builder withKeyProjection(int[][] projection)
public KeyValueFileReaderFactory.Builder withValueProjection(int[][] projection)
public KeyValueFileReaderFactory build(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket)
public KeyValueFileReaderFactory build(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket, boolean projectKeys, @Nullable List<Predicate> filters)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.