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 and 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 Detail

keyClass

Class keyClass()

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

Returns:

valueClass

Class valueClass()

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

Returns:

key

org.apache.hadoop.io.Writable key(TridentTuple tuple)

Given a tuple, return the key that should be written to the sequence file.

Parameters:

tuple -

Returns:

value

org.apache.hadoop.io.Writable value(TridentTuple tuple)

Given a tuple, return the value that should be written to the sequence file.

Parameters:

tuple -

Returns: