org.apache.storm.perf

Class KafkaHdfsTopo.LineWriter

java.lang.Object

org.apache.storm.perf.KafkaHdfsTopo.LineWriter

All Implemented Interfaces:

Serializable, RecordFormat

Enclosing class:

KafkaHdfsTopo

public static class KafkaHdfsTopo.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)
KafkaHdfsTopo.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 KafkaHdfsTopo.LineWriter withLineDelimiter(String delimiter)

Overrides the default record delimiter.

Parameters:

delimiter -

Returns:

format

public byte[] format(Tuple tuple)

Specified by:

format in interface RecordFormat