Class DelimitedRecordFormat
- java.lang.Object
-
- org.apache.storm.hdfs.trident.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.- 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(TridentTuple 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(TridentTuple tuple)
- Specified by:
format
in interfaceRecordFormat
-
-