org.apache.beam.sdk.io

Class TextRowCountEstimator.LimitNumberOfTotalBytes

java.lang.Object

org.apache.beam.sdk.io.TextRowCountEstimator.LimitNumberOfTotalBytes

All Implemented Interfaces:

TextRowCountEstimator.SamplingStrategy

Enclosing class:

TextRowCountEstimator

public static class TextRowCountEstimator.LimitNumberOfTotalBytes
extends java.lang.Object
implements TextRowCountEstimator.SamplingStrategy

This strategy stops sampling when total number of sampled bytes are more than some threshold.

Constructor Summary

Constructors

Constructor and Description
LimitNumberOfTotalBytes(long limit)

Method Summary

Modifier and Type	Method and Description
boolean	stopSampling(int numberOfFiles, long totalReadBytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

LimitNumberOfTotalBytes

public LimitNumberOfTotalBytes(long limit)

Method Detail

stopSampling

public boolean stopSampling(int numberOfFiles,
                            long totalReadBytes)

Specified by:

stopSampling in interface TextRowCountEstimator.SamplingStrategy