public interface HiveInspectors
Modifier and Type | Interface and Description |
---|---|
static class |
HiveInspectors.typeInfoConversions |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.catalyst.types.DataType |
inspectorToDataType(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector) |
org.apache.spark.sql.catalyst.types.DataType |
javaClassToDataType(Class<?> clz) |
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector |
toInspector(org.apache.spark.sql.catalyst.types.DataType dataType) |
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector |
toInspector(org.apache.spark.sql.catalyst.expressions.Expression expr) |
Object |
unwrap(Object data,
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
Converts hive types to native catalyst types.
|
Object |
wrap(Object a,
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
Converts native catalyst types to the types expected by Hive
|
Object[] |
wrap(scala.collection.Seq<Object> row,
scala.collection.Seq<org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector> inspectors,
Object[] cache) |
scala.Function1<Object,Object> |
wrapperFor(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
Wraps with Hive types based on object inspector.
|
org.apache.spark.sql.catalyst.types.DataType javaClassToDataType(Class<?> clz)
Object unwrap(Object data, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
data
- the data in Hive typeoi
- the ObjectInspector associated with the Hive Typescala.Function1<Object,Object> wrapperFor(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
Object wrap(Object a, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector oi)
a
- the value to be wrappedoi
- This ObjectInspector associated with the value returned by this function, and
the ObjectInspector should also be consistent with those returned from
toInspector: DataType => ObjectInspector and
toInspector: Expression => ObjectInspectorObject[] wrap(scala.collection.Seq<Object> row, scala.collection.Seq<org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector> inspectors, Object[] cache)
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector toInspector(org.apache.spark.sql.catalyst.types.DataType dataType)
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector toInspector(org.apache.spark.sql.catalyst.expressions.Expression expr)
org.apache.spark.sql.catalyst.types.DataType inspectorToDataType(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector)