Package | Description |
---|---|
org.apache.flink.addons.hbase | |
org.apache.flink.api.java.io.jdbc | |
org.apache.flink.table.sources |
Modifier and Type | Method and Description |
---|---|
AsyncTableFunction<Row> |
HBaseTableSource.getAsyncLookupFunction(String[] lookupKeys) |
Modifier and Type | Method and Description |
---|---|
AsyncTableFunction<Row> |
JDBCTableSource.getAsyncLookupFunction(String[] lookupKeys) |
Modifier and Type | Method and Description |
---|---|
AsyncTableFunction<Row> |
CsvTableSource.getAsyncLookupFunction(String[] lookupKeys) |
AsyncTableFunction<T> |
LookupableTableSource.getAsyncLookupFunction(String[] lookupKeys)
Gets the
AsyncTableFunction which supports async lookup one key at a time. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.