Package org.apache.beam.sdk.io

Class TextRowCountEstimator.LimitNumberOfFiles

java.lang.Object

org.apache.beam.sdk.io.TextRowCountEstimator.LimitNumberOfFiles

All Implemented Interfaces:

TextRowCountEstimator.SamplingStrategy

Enclosing class:

TextRowCountEstimator

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

This strategy stops sampling if we sample enough number of bytes.

Constructor Summary

Constructors

Constructor	Description
LimitNumberOfFiles(int limit)

Method Summary

Modifier and Type	Method	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

LimitNumberOfFiles

public LimitNumberOfFiles(int limit)

Method Detail

stopSampling

public boolean stopSampling(int numberOfFiles,
                            long totalReadBytes)

Specified by:

stopSampling in interface TextRowCountEstimator.SamplingStrategy