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(List<Split> splits)

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(List<Split> splits)

Method Detail

splitNumber

public int splitNumber()

totalRowCount

public long totalRowCount()