Package org.apache.storm.perf

Class KafkaClientHdfsTopo.LineWriter

java.lang.Object

org.apache.storm.perf.KafkaClientHdfsTopo.LineWriter

All Implemented Interfaces:

Serializable, RecordFormat

Enclosing class:

KafkaClientHdfsTopo

public static class KafkaClientHdfsTopo.LineWriter
extends Object
implements RecordFormat

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
LineWriter(String fieldName)

Method Summary

Modifier and Type	Method	Description
byte[]	format(Tuple tuple)
KafkaClientHdfsTopo.LineWriter	withLineDelimiter(String delimiter)	Overrides the default record delimiter.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LineWriter

public LineWriter(String fieldName)

Method Details

withLineDelimiter

public KafkaClientHdfsTopo.LineWriter withLineDelimiter(String delimiter)

Overrides the default record delimiter.

format

public byte[] format(Tuple tuple)

Specified by:

format in interface RecordFormat