Package org.apache.storm.hdfs.spout
Class ProgressTracker
- java.lang.Object
-
- org.apache.storm.hdfs.spout.ProgressTracker
-
public class ProgressTracker extends Object
-
-
Constructor Summary
Constructors Constructor Description ProgressTracker()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddumpState(PrintStream stream)org.apache.storm.hdfs.spout.FileOffsetgetCommitPosition()voidrecordAckedOffset(org.apache.storm.hdfs.spout.FileOffset newOffset)intsize()
-
-
-
Method Detail
-
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()
-
-