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