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