org.apache.flink.connectors.hive

Class HiveSourceFileEnumerator.PartitionFilesSizeCalculator

java.lang.Object

org.apache.flink.connectors.hive.HiveSourceFileEnumerator.PartitionFilesSizeCalculator

All Implemented Interfaces:

Callable<Long>

Enclosing class:

HiveSourceFileEnumerator

public static class HiveSourceFileEnumerator.PartitionFilesSizeCalculator
extends Object
implements Callable<Long>

The calculator to calculate the total bytes with weight for a partition.

Constructor Summary

Constructors

Constructor and Description
PartitionFilesSizeCalculator(HiveTablePartition hiveTablePartition, Long openCost, org.apache.hadoop.mapred.JobConf jobConf)

Method Summary

Modifier and Type	Method and Description
Long	call()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionFilesSizeCalculator

public PartitionFilesSizeCalculator(HiveTablePartition hiveTablePartition,
                                    Long openCost,
                                    org.apache.hadoop.mapred.JobConf jobConf)

Method Detail

call

public Long call()
          throws Exception

Specified by:

call in interface Callable<Long>

Throws:

Exception