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.
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)
Only output the specified fields.
public DelimitedRecordFormat withFieldDelimiter(String delimiter)
Overrides the default field delimiter.
public DelimitedRecordFormat withRecordDelimiter(String delimiter)
Overrides the default record delimiter.
public byte[] format(Tuple tuple)
format
in interface RecordFormat
Copyright © 2020 The Apache Software Foundation. All rights reserved.