public class DelimitedRecordFormat extends Object implements RecordFormat
withFields()
to
specify which tuple fields to output.Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_FIELD_DELIMITER |
static String |
DEFAULT_RECORD_DELIMITER |
Constructor and Description |
---|
DelimitedRecordFormat() |
Modifier and Type | Method and 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.
|
public static final String DEFAULT_FIELD_DELIMITER
public static final String DEFAULT_RECORD_DELIMITER
public DelimitedRecordFormat withFields(Fields fields)
fields
- public DelimitedRecordFormat withFieldDelimiter(String delimiter)
delimiter
- public DelimitedRecordFormat withRecordDelimiter(String delimiter)
delimiter
- public byte[] format(Tuple tuple)
format
in interface RecordFormat
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.