Class CsvSerializer
- java.lang.Object
-
- org.apache.storm.sql.runtime.serde.csv.CsvSerializer
-
- All Implemented Interfaces:
Serializable
,IOutputSerializer
public class CsvSerializer extends Object implements IOutputSerializer, Serializable
CsvSerializer uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted. eg: a,"b,c",d is allowed.- See Also:
- RFC4180, Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CsvSerializer(List<String> fields)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ByteBuffer
write(List<Object> data, ByteBuffer buffer)
Serialize the data to a ByteBuffer.
-
-
-
Method Detail
-
write
public ByteBuffer write(List<Object> data, ByteBuffer buffer)
Description copied from interface:IOutputSerializer
Serialize the data to a ByteBuffer. The caller can pass in a ByteBuffer so that the serializer can reuse the memory.- Specified by:
write
in interfaceIOutputSerializer
- Returns:
- A ByteBuffer contains the serialized result.
-
-