org.apache.flink.table.endpoint.hive.util

Class OperationExecutorFactory

java.lang.Object

org.apache.flink.table.endpoint.hive.util.OperationExecutorFactory

public class OperationExecutorFactory
extends Object

Factory to create the operation executor.

Constructor Summary

Constructors

Constructor and Description
OperationExecutorFactory()

Method Summary

Modifier and Type	Method and Description
static Callable<ResultSet>	createGetCatalogsExecutor(SqlGatewayService service, SessionHandle sessionHandle)
static Callable<ResultSet>	createGetColumnsExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName, String tableName, String columnsName)
static Callable<ResultSet>	createGetFunctionsExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String databasePattern, String functionNamePattern)
static Callable<ResultSet>	createGetPrimaryKeys(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName, String tableName)
static Callable<ResultSet>	createGetSchemasExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName)
static Callable<ResultSet>	createGetTablesExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName, String tableName, Set<CatalogBaseTable.TableKind> tableKinds)
static Callable<ResultSet>	createGetTableTypesExecutor()
static Callable<ResultSet>	createGetTypeInfoExecutor()

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationExecutorFactory

public OperationExecutorFactory()

Method Detail

createGetCatalogsExecutor

public static Callable<ResultSet> createGetCatalogsExecutor(SqlGatewayService service,
                                                            SessionHandle sessionHandle)

createGetSchemasExecutor

public static Callable<ResultSet> createGetSchemasExecutor(SqlGatewayService service,
                                                           SessionHandle sessionHandle,
                                                           @Nullable
                                                           String catalogName,
                                                           @Nullable
                                                           String schemaName)

createGetTablesExecutor

public static Callable<ResultSet> createGetTablesExecutor(SqlGatewayService service,
                                                          SessionHandle sessionHandle,
                                                          @Nullable
                                                          String catalogName,
                                                          @Nullable
                                                          String schemaName,
                                                          @Nullable
                                                          String tableName,
                                                          Set<CatalogBaseTable.TableKind> tableKinds)

createGetColumnsExecutor

public static Callable<ResultSet> createGetColumnsExecutor(SqlGatewayService service,
                                                           SessionHandle sessionHandle,
                                                           @Nullable
                                                           String catalogName,
                                                           @Nullable
                                                           String schemaName,
                                                           @Nullable
                                                           String tableName,
                                                           @Nullable
                                                           String columnsName)

createGetTableTypesExecutor

public static Callable<ResultSet> createGetTableTypesExecutor()

createGetPrimaryKeys

public static Callable<ResultSet> createGetPrimaryKeys(SqlGatewayService service,
                                                       SessionHandle sessionHandle,
                                                       @Nullable
                                                       String catalogName,
                                                       @Nullable
                                                       String schemaName,
                                                       @Nullable
                                                       String tableName)

createGetFunctionsExecutor

public static Callable<ResultSet> createGetFunctionsExecutor(SqlGatewayService service,
                                                             SessionHandle sessionHandle,
                                                             @Nullable
                                                             String catalogName,
                                                             @Nullable
                                                             String databasePattern,
                                                             @Nullable
                                                             String functionNamePattern)

createGetTypeInfoExecutor

public static Callable<ResultSet> createGetTypeInfoExecutor()