@Internal public class HBaseRowDataAsyncLookupFunction extends AsyncTableFunction<RowData>
RowData
.Constructor and Description |
---|
HBaseRowDataAsyncLookupFunction(Configuration configuration,
String hTableName,
HBaseTableSchema hbaseTableSchema,
String nullStringLiteral,
HBaseLookupOptions lookupOptions) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Tear-down method for user-defined function.
|
void |
eval(CompletableFuture<Collection<RowData>> future,
Object rowKey)
The invoke entry point of lookup function.
|
String |
getHTableName() |
void |
open(FunctionContext context)
Setup method for user-defined function.
|
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, HBaseLookupOptions lookupOptions)
public void open(FunctionContext context)
UserDefinedFunction
open
in class UserDefinedFunction
public void eval(CompletableFuture<Collection<RowData>> future, Object rowKey)
future
- The result or exception is returned.rowKey
- the lookup key. 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.