org.apache.storm.sql.runtime.serde.csv

Class CsvScheme

java.lang.Object

org.apache.storm.sql.runtime.serde.csv.CsvScheme

All Implemented Interfaces:

Serializable, Scheme

public class CsvScheme
extends Object
implements Scheme

CsvScheme 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 and Description
CsvScheme(List<String> fieldNames)

Method Summary

Modifier and Type	Method and Description
List<Object>	deserialize(ByteBuffer ser)
Fields	getOutputFields()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CsvScheme

public CsvScheme(List<String> fieldNames)

Method Detail

deserialize

public List<Object> deserialize(ByteBuffer ser)

Specified by:

deserialize in interface Scheme

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface Scheme