Class DelimitedRecordFormat
java.lang.Object
org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
- All Implemented Interfaces:
- Serializable,- 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:
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionbyte[]format(TridentTuple tuple) withFieldDelimiter(String delimiter) Overrides the default field delimiter.withFields(Fields fields) Only output the specified fields.withRecordDelimiter(String delimiter) Overrides the default record delimiter.
- 
Field Details- 
DEFAULT_FIELD_DELIMITER- See Also:
 
- 
DEFAULT_RECORD_DELIMITER- See Also:
 
 
- 
- 
Constructor Details- 
DelimitedRecordFormatpublic DelimitedRecordFormat()
 
- 
- 
Method Details- 
withFieldsOnly output the specified fields.
- 
withFieldDelimiterOverrides the default field delimiter.
- 
withRecordDelimiterOverrides the default record delimiter.
- 
format- Specified by:
- formatin interface- RecordFormat
 
 
-