TextRowCountEstimator.LimitNumberOfTotalBytes (Apache Beam 2.67.0)

java.lang.Object

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

All Implemented Interfaces:: TextRowCountEstimator.SamplingStrategy

Enclosing class:: TextRowCountEstimator

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

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

Constructor Summary

Constructors

Constructor

Description

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