Package org.apache.storm.hdfs.bolt.format

Interface RecordFormat

All Superinterfaces:

Serializable

All Known Implementing Classes:

DelimitedRecordFormat, KafkaClientHdfsTopo.LineWriter, StrGenSpoutHdfsBoltTopo.LineWriter

public interface RecordFormat
extends Serializable

Formats a Tuple object into a byte array that will be written to HDFS.

Method Summary

Modifier and Type	Method	Description
byte[]	format(Tuple tuple)

Method Details

format

byte[] format(Tuple tuple)