org.apache.paimon.flink.lookup

Class LookupRuntimeProviderFactory

java.lang.Object

org.apache.paimon.flink.lookup.LookupRuntimeProviderFactory

public class LookupRuntimeProviderFactory
extends Object

Factory to create LookupTableSource.LookupRuntimeProvider.

Constructor Summary

Constructors

Constructor and Description
LookupRuntimeProviderFactory()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider	create(FileStoreLookupFunction function, boolean enableAsync, int asyncThreadNumber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LookupRuntimeProviderFactory

public LookupRuntimeProviderFactory()

Method Detail

create

public static org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider create(FileStoreLookupFunction function,
                                                                                                     boolean enableAsync,
                                                                                                     int asyncThreadNumber)