org.apache.flink.table.functions.hive

Class DeferredObjectAdapter

java.lang.Object

org.apache.flink.table.functions.hive.DeferredObjectAdapter

All Implemented Interfaces:

org.apache.hadoop.hive.ql.udf.generic.GenericUDF.DeferredObject

@Internal
public class DeferredObjectAdapter
extends Object
implements org.apache.hadoop.hive.ql.udf.generic.GenericUDF.DeferredObject

Adapter from Java Object to Hive DeferredObject.

Constructor Summary

Constructors

Constructor and Description
DeferredObjectAdapter(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector, org.apache.flink.table.types.logical.LogicalType logicalType, HiveShim hiveShim)

Method Summary

Modifier and Type	Method and Description
Object	get()
void	prepare(int version)
void	set(Object ob)

Methods inherited from class java.lang.Object

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

Constructor Detail

DeferredObjectAdapter

public DeferredObjectAdapter(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
                             org.apache.flink.table.types.logical.LogicalType logicalType,
                             HiveShim hiveShim)

Method Detail

set

public void set(Object ob)

prepare

public void prepare(int version)

Specified by:

prepare in interface org.apache.hadoop.hive.ql.udf.generic.GenericUDF.DeferredObject

get

public Object get()

Specified by:

get in interface org.apache.hadoop.hive.ql.udf.generic.GenericUDF.DeferredObject