| Package | Description |
|---|---|
| org.apache.paimon.io | |
| org.apache.paimon.table.source | |
| org.apache.paimon.utils |
| 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 <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 | Method and Description |
|---|---|
static List<DeletionFile> |
DeletionFile.deserializeList(DataInputView in,
FunctionWithIOException<DataInputView,DeletionFile> deserialize) |
| Constructor and Description |
|---|
ObjectsCache(SegmentsCache<K> cache,
ObjectSerializer<V> projectedSerializer,
RowType formatSchema,
FunctionWithIOException<K,Long> fileSizeFunction,
BiFunctionWithIOE<K,Long,CloseableIterator<InternalRow>> reader) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.