TextRowCountEstimator.LimitNumberOfFiles (Apache Beam 2.67.0)

java.lang.Object

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

All Implemented Interfaces:: TextRowCountEstimator.SamplingStrategy

Enclosing class:: TextRowCountEstimator

public static class TextRowCountEstimator.LimitNumberOfFiles extends 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 Details
- LimitNumberOfFiles
  
  public LimitNumberOfFiles(int limit)
Method Details
- stopSampling
  
  public boolean stopSampling(int numberOfFiles, long totalReadBytes)
  
  Specified by:
  
  stopSampling in interface TextRowCountEstimator.SamplingStrategy