org.apache.paimon.flink.lookup

Class LookupStreamingReader

java.lang.Object

org.apache.paimon.flink.lookup.LookupStreamingReader

public class LookupStreamingReader
extends Object

A streaming reader to load data into LookupTable.

Constructor Summary

Constructors

Constructor and Description
LookupStreamingReader(LookupFileStoreTable table, int[] projection, Predicate predicate, Set<Integer> requireCachedBucketIds, Filter<InternalRow> cacheRowFilter)

Method Summary

Modifier and Type	Method and Description
RecordReader<InternalRow>	nextBatch(boolean useParallelism)
Long	nextSnapshotId()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LookupStreamingReader

public LookupStreamingReader(LookupFileStoreTable table,
                             int[] projection,
                             @Nullable
                             Predicate predicate,
                             Set<Integer> requireCachedBucketIds,
                             @Nullable
                             Filter<InternalRow> cacheRowFilter)

Method Detail

nextBatch

public RecordReader<InternalRow> nextBatch(boolean useParallelism)
                                    throws Exception

Throws:

Exception

nextSnapshotId

@Nullable
public Long nextSnapshotId()