co.cask.cdap.format

Class TextRecordFormat

java.lang.Object

co.cask.cdap.api.data.format.RecordFormat<StreamEvent,T>

co.cask.cdap.spi.stream.AbstractStreamEventRecordFormat<co.cask.cdap.api.data.format.StructuredRecord>

co.cask.cdap.format.TextRecordFormat

public class TextRecordFormat
extends AbstractStreamEventRecordFormat<co.cask.cdap.api.data.format.StructuredRecord>

Stream record format that interprets the entire body as a single string.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHARSET

Fields inherited from class co.cask.cdap.api.data.format.RecordFormat

schema

Constructor Summary

Constructors

Constructor and Description
TextRecordFormat()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	configure(Map<String,String> settings)
protected co.cask.cdap.api.data.schema.Schema	getDefaultSchema()
co.cask.cdap.api.data.format.StructuredRecord	read(StreamEvent event)
protected void	validateSchema(co.cask.cdap.api.data.schema.Schema desiredSchema)

Methods inherited from class co.cask.cdap.api.data.format.RecordFormat

getSchema, initialize

Methods inherited from class java.lang.Object

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

Field Detail

CHARSET

public static final String CHARSET

See Also:

Constant Field Values

Constructor Detail

TextRecordFormat

public TextRecordFormat()

Method Detail

read

public co.cask.cdap.api.data.format.StructuredRecord read(StreamEvent event)

Specified by:

read in class co.cask.cdap.api.data.format.RecordFormat<StreamEvent,co.cask.cdap.api.data.format.StructuredRecord>

getDefaultSchema

protected co.cask.cdap.api.data.schema.Schema getDefaultSchema()

Specified by:

getDefaultSchema in class co.cask.cdap.api.data.format.RecordFormat<StreamEvent,co.cask.cdap.api.data.format.StructuredRecord>

validateSchema

protected void validateSchema(co.cask.cdap.api.data.schema.Schema desiredSchema)
                       throws co.cask.cdap.api.data.schema.UnsupportedTypeException

Specified by:

validateSchema in class co.cask.cdap.api.data.format.RecordFormat<StreamEvent,co.cask.cdap.api.data.format.StructuredRecord>

Throws:

co.cask.cdap.api.data.schema.UnsupportedTypeException

configure

protected void configure(Map<String,String> settings)

Overrides:

configure in class co.cask.cdap.api.data.format.RecordFormat<StreamEvent,co.cask.cdap.api.data.format.StructuredRecord>