public class HBaseLookupFunction extends TableFunction<Row>
collector
Constructor and Description |
---|
HBaseLookupFunction(Configuration configuration,
String hTableName,
HBaseTableSchema hbaseTableSchema) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Tear-down method for user-defined function.
|
void |
eval(Object rowKey)
The invoke entry point of lookup function.
|
TypeInformation<Row> |
getResultType()
Returns the result type of the evaluation method with a given signature.
|
void |
open(FunctionContext context)
Setup method for user-defined function.
|
collect, getKind, getParameterTypes, setCollector
functionIdentifier, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequirements, isDeterministic
public HBaseLookupFunction(Configuration configuration, String hTableName, HBaseTableSchema hbaseTableSchema)
public void eval(Object rowKey) throws IOException
rowKey
- the lookup key. Currently only support single rowkey.IOException
public TypeInformation<Row> getResultType()
TableFunction
This method needs to be overridden in case Flink's type extraction facilities are not
sufficient to extract the TypeInformation
based on the return type of the evaluation
method. Flink's type extraction facilities can handle basic types or
simple POJOs but might be wrong for more complex, custom, or composite types.
getResultType
in class TableFunction<Row>
TypeInformation
of result type or null
if Flink should determine the typepublic void open(FunctionContext context)
UserDefinedFunction
open
in class UserDefinedFunction
public void close()
UserDefinedFunction
close
in class UserDefinedFunction
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.