Class ProgressTracker

java.lang.Object
org.apache.storm.hdfs.spout.ProgressTracker

public class ProgressTracker extends Object
  • Constructor Details

    • ProgressTracker

      public ProgressTracker()
  • Method Details

    • recordAckedOffset

      public void recordAckedOffset(org.apache.storm.hdfs.spout.FileOffset newOffset)
    • getCommitPosition

      public org.apache.storm.hdfs.spout.FileOffset getCommitPosition()
    • dumpState

      public void dumpState(PrintStream stream)
    • size

      public int size()