co.cask.cdap.format

Class AvroRecordFormat

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.AvroRecordFormat

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

Stream record format that interprets the body as avro encoded binary data.

Field Summary

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

schema

Constructor Summary

Constructors

Constructor and Description
AvroRecordFormat()

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

Constructor Detail

AvroRecordFormat

public AvroRecordFormat()

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>