public class HiveResolver extends Plugin implements ReadResolver
Constructor and Description |
---|
HiveResolver(InputData input)
Constructs the HiveResolver by parsing the userdata in the input and
obtaining the serde class name, the serde properties string and the
partition keys.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<OneField> |
getFields(OneRow onerow)
Gets the
OneField list of one row. |
isThreadSafe
public HiveResolver(InputData input) throws java.lang.Exception
input
- contains the Serde class name, the serde properties string
and the partition keysjava.lang.Exception
- if user data was wrong or serde failed to be
instantiatedpublic java.util.List<OneField> getFields(OneRow onerow) throws java.lang.Exception
ReadResolver
OneField
list of one row.getFields
in interface ReadResolver
onerow
- the row to get the fields fromOneField
list of one row.java.lang.Exception
- if decomposing the row into fields failed