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 and Description
byte[]	format(Tuple tuple)

Method Detail

format

byte[] format(Tuple tuple)