co.cask.cdap.format

Class StructuredRecordDatumReader

java.lang.Object

org.apache.avro.generic.GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

co.cask.cdap.format.StructuredRecordDatumReader

All Implemented Interfaces:

DatumReader<co.cask.cdap.api.data.format.StructuredRecord>

public class StructuredRecordDatumReader
extends GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

An Avro DatumReader that reads data into StructuredRecord.

Constructor Summary

Constructors

Constructor and Description
StructuredRecordDatumReader(co.cask.cdap.api.data.schema.Schema schema, Schema avroSchema) Constructs a new instance.

Method Summary

Methods

Modifier and Type	Method and Description
protected Object	createEnum(String symbol, Schema schema)
protected Object	newArray(Object old, int size, Schema schema)
protected Object	read(Object old, Schema expected, ResolvingDecoder in)
protected Object	readArray(Object old, Schema expected, ResolvingDecoder in)
protected Object	readMap(Object old, Schema expected, ResolvingDecoder in)
protected Object	readRecord(Object old, Schema expected, ResolvingDecoder in)
protected Object	readString(Object old, Decoder in)

Methods inherited from class org.apache.avro.generic.GenericDatumReader

addToArray, addToMap, createBytes, createFixed, createFixed, createString, getData, getExpected, getResolver, getSchema, newMap, newRecord, peekArray, read, readBytes, readEnum, readFixed, readInt, readString, setExpected, setSchema, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

StructuredRecordDatumReader

public StructuredRecordDatumReader(co.cask.cdap.api.data.schema.Schema schema,
                           Schema avroSchema)

Constructs a new instance.

Parameters:

schema - The schema for the StructuredRecord created through this class

avroSchema - The Avro Schema equivalent of the schema

Method Detail

read

protected Object read(Object old,
          Schema expected,
          ResolvingDecoder in)
               throws IOException

Overrides:

read in class GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IOException

newArray

protected Object newArray(Object old,
              int size,
              Schema schema)

Overrides:

newArray in class GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

createEnum

protected Object createEnum(String symbol,
                Schema schema)

Overrides:

createEnum in class GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

readString

protected Object readString(Object old,
                Decoder in)
                     throws IOException

Overrides:

readString in class GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IOException

readArray

protected Object readArray(Object old,
               Schema expected,
               ResolvingDecoder in)
                    throws IOException

Overrides:

readArray in class GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IOException

readMap

protected Object readMap(Object old,
             Schema expected,
             ResolvingDecoder in)
                  throws IOException

Overrides:

readMap in class GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IOException

readRecord

protected Object readRecord(Object old,
                Schema expected,
                ResolvingDecoder in)
                     throws IOException

Overrides:

readRecord in class GenericDatumReader<co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IOException