co.cask.hydrator.common

Class RecordConverter<INPUT,OUTPUT>

java.lang.Object

co.cask.hydrator.common.RecordConverter<INPUT,OUTPUT>

Type Parameters:

INPUT - type of input record

OUTPUT - type of output record

public abstract class RecordConverter<INPUT,OUTPUT>
extends Object

Converts an object with a schema into another type of object with the same schema. For example, child implementations could convert a StructuredRecord to a GenericRecord and vice versa as can be seen in AvroToStructuredTransformer and StructuredToAvroTransformer

Constructor Summary

Constructors

Constructor and Description
RecordConverter()

Method Summary

Methods

Modifier and Type	Method and Description
protected Object	convertBytes(Object field)
protected Object	convertField(Object field, co.cask.cdap.api.data.schema.Schema fieldSchema)
abstract OUTPUT	transform(INPUT record, co.cask.cdap.api.data.schema.Schema schema)

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordConverter

public RecordConverter()

Method Detail

transform

public abstract OUTPUT transform(INPUT record,
               co.cask.cdap.api.data.schema.Schema schema)
                          throws IOException

Throws:

IOException

convertField

protected Object convertField(Object field,
                  co.cask.cdap.api.data.schema.Schema fieldSchema)
                       throws IOException

Throws:

IOException

convertBytes

protected Object convertBytes(Object field)