Skip to content

CustomExecutors

CustomExecutors is a collection of StatementExecutors that do not need to be distributed.

CustomExecutors is used by KsqlResource to create a RequestHandler (and shouldSynchronize for the DefaultCommandQueueSync).

EXECUTOR_MAP

Enum Name Class StatementExecutor
CreateConnector ConnectExecutor::execute
DefineVariable VariableExecutor::set
DescribeConnector DescribeConnectorExecutor::execute
DescribeFunction DescribeFunctionExecutor::execute
DESCRIBE_STREAMS DescribeStreams ListSourceExecutor::describeStreams
DESCRIBE_TABLES DescribeTables ListSourceExecutor::describeTables
DropConnector DropConnectorExecutor::execute
Explain ExplainExecutor::execute
InsertValues InsertValuesExecutor::execute
LIST_CONNECTORS ListConnectors ListConnectorsExecutor::execute
LIST_CONNECTOR_PLUGINS ListConnectorPlugins ListConnectorPluginsExecutor::execute
LIST_FUNCTIONS ListFunctions ListFunctionsExecutor::execute
LIST_PROPERTIES ListProperties ListPropertiesExecutor::execute
LIST_QUERIES ListQueries ListQueriesExecutor::execute
LIST_STREAMS ListStreams ListSourceExecutor::streams
LIST_TABLES ListTables ListSourceExecutor::tables
LIST_TOPICS ListTopics ListTopicsExecutor::execute
LIST_TYPES ListTypes ListTypesExecutor::execute
LIST_VARIABLES ListVariables ListVariablesExecutor::execute
SetProperty PropertyExecutor::set
ShowColumns ListSourceExecutor::columns
TerminateQuery TerminateQueryExecutor::execute
UndefineVariable VariableExecutor::unset
UnsetProperty PropertyExecutor::unset

Explain

Back to top