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)