Field Detail

• logFileName

  private String logFileName

• fileSize

  private long fileSize

• startTime

  private long startTime

• endTime

  private long endTime

Constructor Detail

• WALInputFormat.WALSplit

  public WALInputFormat.WALSplit()

  for serialization

• WALInputFormat.WALSplit

  public WALInputFormat.WALSplit(String logFileName,
                         long fileSize,
                         long startTime,
                         long endTime)

  Represent an WALSplit, i.e. a single WAL file. Start- and EndTime are managed by the split, so that WAL files can be filtered before WALEdits are passed to the mapper(s).

  Parameters:

  logFileName -

  fileSize -

  startTime -

  endTime -

Method Detail

• getLength

  public long getLength()
                 throws IOException,
                        InterruptedException

  Specified by:

  getLength in class org.apache.hadoop.mapreduce.InputSplit

  Throws:

  IOException

  InterruptedException

• getLocations

  public String[] getLocations()
                        throws IOException,
                               InterruptedException

  Specified by:

  getLocations in class org.apache.hadoop.mapreduce.InputSplit

  Throws:

  IOException

  InterruptedException

• getLogFileName

  public String getLogFileName()

• getStartTime

  public long getStartTime()

• getEndTime

  public long getEndTime()

• readFields

  public void readFields(DataInput in)
                  throws IOException

  Specified by:

  readFields in interface org.apache.hadoop.io.Writable

  Throws:

  IOException

• write

  public void write(DataOutput out)
             throws IOException

  Specified by:

  write in interface org.apache.hadoop.io.Writable

  Throws:

  IOException

• toString

  public String toString()

  Overrides:

  toString in class Object