Class DelimitedRecordFormat
- java.lang.Object
-
- org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
-
- All Implemented Interfaces:
Serializable
,RecordFormat
public class DelimitedRecordFormat extends Object implements RecordFormat
RecordFormat implementation that uses field and record delimiters. By default uses a comma (",") as the field delimiter and a newline ("\n") as the record delimiter.Also by default, this implementation will output all the field values in the tuple in the order they were declared. To override this behavior, call
withFields()
to specify which tuple fields to output.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static String
DEFAULT_FIELD_DELIMITER
static String
DEFAULT_RECORD_DELIMITER
-
Constructor Summary
Constructors Constructor Description DelimitedRecordFormat()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]
format(Tuple tuple)
DelimitedRecordFormat
withFieldDelimiter(String delimiter)
Overrides the default field delimiter.DelimitedRecordFormat
withFields(Fields fields)
Only output the specified fields.DelimitedRecordFormat
withRecordDelimiter(String delimiter)
Overrides the default record delimiter.
-
-
-
Field Detail
-
DEFAULT_FIELD_DELIMITER
public static final String DEFAULT_FIELD_DELIMITER
- See Also:
- Constant Field Values
-
DEFAULT_RECORD_DELIMITER
public static final String DEFAULT_RECORD_DELIMITER
- See Also:
- Constant Field Values
-
-
Method Detail
-
withFields
public DelimitedRecordFormat withFields(Fields fields)
Only output the specified fields.
-
withFieldDelimiter
public DelimitedRecordFormat withFieldDelimiter(String delimiter)
Overrides the default field delimiter.
-
withRecordDelimiter
public DelimitedRecordFormat withRecordDelimiter(String delimiter)
Overrides the default record delimiter.
-
format
public byte[] format(Tuple tuple)
- Specified by:
format
in interfaceRecordFormat
-
-