Package org.apache.storm.hdfs.spout
Class SequenceFileReader.Offset
java.lang.Object
org.apache.storm.hdfs.spout.SequenceFileReader.Offset
- All Implemented Interfaces:
Cloneable
,Comparable<org.apache.storm.hdfs.spout.FileOffset>
- Enclosing class:
- SequenceFileReader<KeyT extends org.apache.hadoop.io.Writable,
ValueT extends org.apache.hadoop.io.Writable>
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionclone()
int
compareTo
(org.apache.storm.hdfs.spout.FileOffset o) boolean
int
hashCode()
boolean
isNextOffset
(org.apache.storm.hdfs.spout.FileOffset rhs) toString()
-
Field Details
-
lastSyncPoint
public long lastSyncPoint -
recordsSinceLastSync
public long recordsSinceLastSync -
currentRecord
public long currentRecord
-
-
Constructor Details
-
Offset
public Offset(long lastSyncPoint, long recordsSinceLastSync, long currentRecord) -
Offset
public Offset(long lastSyncPoint, long recordsSinceLastSync, long currentRecord, long currRecordEndOffset, long prevRecordEndOffset) -
Offset
-
-
Method Details
-
toString
-
isNextOffset
public boolean isNextOffset(org.apache.storm.hdfs.spout.FileOffset rhs) -
compareTo
public int compareTo(org.apache.storm.hdfs.spout.FileOffset o) - Specified by:
compareTo
in interfaceComparable<org.apache.storm.hdfs.spout.FileOffset>
-
equals
-
hashCode
public int hashCode() -
clone
-