@Internal public class HBaseRowDataLookupFunction extends LookupFunction
RowData
.Constructor and Description |
---|
HBaseRowDataLookupFunction(Configuration configuration,
String hTableName,
HBaseTableSchema hbaseTableSchema,
String nullStringLiteral,
int maxRetryTimes) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Tear-down method for user-defined function.
|
String |
getHTableName() |
Collection<RowData> |
lookup(RowData keyRow)
The invoke entry point of lookup function.
|
void |
open(FunctionContext context)
Setup method for user-defined function.
|
eval
collect, getKind, getParameterTypes, getResultType, getTypeInference, setCollector
functionIdentifier, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequirements, isDeterministic
public HBaseRowDataLookupFunction(Configuration configuration, String hTableName, HBaseTableSchema hbaseTableSchema, String nullStringLiteral, int maxRetryTimes)
public Collection<RowData> lookup(RowData keyRow) throws IOException
lookup
in class LookupFunction
keyRow
- - A RowData
that wraps lookup keys. Currently only support single
rowkey.IOException
public void open(FunctionContext context)
UserDefinedFunction
open
in class UserDefinedFunction
public void close()
UserDefinedFunction
close
in class UserDefinedFunction
@VisibleForTesting public String getHTableName()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.