Class DefaultSequenceFormat
- java.lang.Object
-
- org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
-
- All Implemented Interfaces:
Serializable
,SequenceFormat
public class DefaultSequenceFormat extends Object implements SequenceFormat
BasicSequenceFormat
implementation that usesLongWritable
for keys andText
for values.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description DefaultSequenceFormat(String keyField, String valueField)
-
Method Summary
All Methods Instance Methods Concrete Methods 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 Detail
-
keyClass
public Class keyClass()
Description copied from interface:SequenceFormat
Key class used by implementation (e.g. IntWritable.class, etc.).- Specified by:
keyClass
in interfaceSequenceFormat
-
valueClass
public Class valueClass()
Description copied from interface:SequenceFormat
Value class used by implementation (e.g. Text.class, etc.).- Specified by:
valueClass
in interfaceSequenceFormat
-
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 interfaceSequenceFormat
-
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 interfaceSequenceFormat
-
-