org.apache.paimon.flink.source

Class FlinkTableSource.SplitStatistics

java.lang.Object

org.apache.paimon.flink.source.FlinkTableSource.SplitStatistics

Enclosing class:

FlinkTableSource

protected static class FlinkTableSource.SplitStatistics
extends Object

Split statistics for inferring row count and parallelism size.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SplitStatistics(int splitNumber, long totalRowCount)

Method Summary

Modifier and Type	Method and Description
int	splitNumber()
long	totalRowCount()

Methods inherited from class java.lang.Object

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

Constructor Detail

SplitStatistics

protected SplitStatistics(int splitNumber,
                          long totalRowCount)

Method Detail

splitNumber

public int splitNumber()

totalRowCount

public long totalRowCount()