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

Interface SequenceFormat

All Superinterfaces:
Serializable
All Known Implementing Classes:
DefaultSequenceFormat
public interface SequenceFormat extends Serializable
Interface for converting TridentTuple objects to HDFS sequence file key-value pairs.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.io.Writable
    key(TridentTuple tuple)
    Given a tuple, return the key that should be written to the sequence file.
    Class
    keyClass()
    Key class used by implementation (e.g.
    org.apache.hadoop.io.Writable
    value(TridentTuple tuple)
    Given a tuple, return the value that should be written to the sequence file.
    Class
    valueClass()
    Value class used by implementation (e.g.

  • Method Details

    • keyClass

      Class keyClass()
      Key class used by implementation (e.g. IntWritable.class, etc.).

    • valueClass

      Class valueClass()
      Value class used by implementation (e.g. Text.class, etc.).

    • key

      org.apache.hadoop.io.Writable key(TridentTuple tuple)
      Given a tuple, return the key that should be written to the sequence file.

    • value

      org.apache.hadoop.io.Writable value(TridentTuple tuple)
      Given a tuple, return the value that should be written to the sequence file.