INPUT - type of input recordOUTPUT - type of output recordpublic abstract class RecordConverter<INPUT,OUTPUT> extends Object
| Constructor and Description |
|---|
RecordConverter() |
| 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) |
public abstract OUTPUT transform(INPUT record, co.cask.cdap.api.data.schema.Schema schema) throws IOException
IOExceptionprotected Object convertField(Object field, co.cask.cdap.api.data.schema.Schema fieldSchema) throws IOException
IOExceptionCopyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.