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 and Description
LineWriter(String fieldName)

Method Summary

Modifier and Type	Method and 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 Detail

LineWriter

public LineWriter(String fieldName)

Method Detail

withLineDelimiter

public KafkaClientHdfsTopo.LineWriter withLineDelimiter(String delimiter)

Overrides the default record delimiter.

Parameters:

delimiter -

Returns:

format

public byte[] format(Tuple tuple)

Specified by:

format in interface RecordFormat