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>

public static class SequenceFileReader.Offset extends Object
  • 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

      public Offset(String offset)
  • Method Details

    • toString

      public String toString()
      Overrides:
      toString in class Object
    • 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 interface Comparable<org.apache.storm.hdfs.spout.FileOffset>
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • clone

      public SequenceFileReader.Offset clone()
      Overrides:
      clone in class Object