@Internal public class HBaseRowDataAsyncLookupFunction extends AsyncLookupFunction
RowData
.Constructor and Description |
---|
HBaseRowDataAsyncLookupFunction(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(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–2024 The Apache Software Foundation. All rights reserved.