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

Method Summary

Modifier and Type	Method	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 Details

CsvScheme

public CsvScheme(List<String> fieldNames)

Method Details

deserialize

public List<Object> deserialize(ByteBuffer ser)

Specified by:

deserialize in interface Scheme

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface Scheme