public class AvroResolver extends Plugin implements ReadResolver
Constructor and Description |
---|
AvroResolver(InputData input)
Constructs an AvroResolver.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<OneField> |
getFields(OneRow row)
Returns a list of the fields of one record.
|
isThreadSafe
public AvroResolver(InputData input) throws java.io.IOException
input
- all input parameters coming from the clientjava.io.IOException
- if Avro schema could not be retrieved or parsedpublic java.util.List<OneField> getFields(OneRow row) throws java.lang.Exception
getFields
in interface ReadResolver
row
- the row to get the fields fromOneField
list of one row.java.lang.Exception
- if decomposing the row into fields failed