Package org.apache.storm.hdfs.trident.format

Class DefaultSequenceFormat

java.lang.Object
org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
All Implemented Interfaces:
Serializable, SequenceFormat
public class DefaultSequenceFormat extends Object implements SequenceFormat
Basic SequenceFormat implementation that uses LongWritable for keys and Text for values.
See Also:

  • Constructor Details

    • DefaultSequenceFormat

      public DefaultSequenceFormat(String keyField, String valueField)

  • Method Details

    • keyClass

      public Class keyClass()
      Description copied from interface: SequenceFormat
      Key class used by implementation (e.g. IntWritable.class, etc.).
      Specified by:
      keyClass in interface SequenceFormat

    • valueClass

      public Class valueClass()
      Description copied from interface: SequenceFormat
      Value class used by implementation (e.g. Text.class, etc.).
      Specified by:
      valueClass in interface SequenceFormat

    • key

      public org.apache.hadoop.io.Writable key(TridentTuple tuple)
      Description copied from interface: SequenceFormat
      Given a tuple, return the key that should be written to the sequence file.
      Specified by:
      key in interface SequenceFormat

    • value

      public org.apache.hadoop.io.Writable value(TridentTuple tuple)
      Description copied from interface: SequenceFormat
      Given a tuple, return the value that should be written to the sequence file.
      Specified by:
      value in interface SequenceFormat