Package org.apache.beam.sdk.io.parquet

Class ParquetIO.ReadFiles.BlockTracker

  • All Implemented Interfaces:
    org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.HasProgress
    Enclosing class:
    ParquetIO.ReadFiles
    public static class ParquetIO.ReadFiles.BlockTracker
extends org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker

        org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.HasProgress, org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.IsBounded, org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.Progress, org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.TruncateResult<RestrictionT extends java.lang.Object>

    • Field Summary

      • Fields inherited from class org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker

        lastAttemptedOffset, lastClaimedOffset, range

    • Constructor Summary

      Constructors 
      Constructor Description
      BlockTracker​(org.apache.beam.sdk.io.range.OffsetRange range, long totalByteSize, long recordCount)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.Progress getProgress()  
      void makeProgress()  

      • Methods inherited from class org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker

        checkDone, currentRestriction, isBounded, toString, tryClaim, trySplit

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • BlockTracker

        public BlockTracker​(org.apache.beam.sdk.io.range.OffsetRange range,
                    long totalByteSize,
                    long recordCount)

    • Method Detail

      • makeProgress

        public void makeProgress()
                  throws java.io.IOException
        Throws:
        java.io.IOException

      • getProgress

        public org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.Progress getProgress()
        Specified by:
        getProgress in interface org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.HasProgress
        Overrides:
        getProgress in class org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker