Skip to content

KsqlResource

configure

void configure(
  KsqlConfig config)

configure...FIXME

configure is part of the KsqlConfigurable abstraction.

shouldSynchronize

boolean shouldSynchronize(
  Class<? extends Statement> statementClass)

shouldSynchronize is true when the given statementClass is as follows:

  1. Not in SYNC_BLACKLIST
  2. In EXECUTOR_MAP

shouldSynchronize is used when:

SYNC_BLACKLIST

  • ListTopics
  • ListFunctions
  • DescribeFunction
  • ListProperties
  • SetProperty
  • UnsetProperty

RequestHandler

KsqlResource creates a RequestHandler when requested to configure.

RequestHandler is used when:

Handling Statements

EndpointResponse handleKsqlStatements(
  KsqlSecurityContext securityContext,
  KsqlRequest request)

handleKsqlStatements prints out the following INFO message to the logs:

Received: [request]

handleKsqlStatements requests the KsqlEngine to parse the SQL text (from the given KsqlRequest).

handleKsqlStatements requests the RequestValidator to validate the statements (in a SandboxedServiceContext).

handleKsqlStatements requests the RequestHandler to execute the SQL statements.

In the end, handleKsqlStatements prints out the following INFO message to the logs:

Processed successfully: [request]

handleKsqlStatements is used when:

  • KsqlServerEndpoints is requested to execute a KsqlRequest
  • ServerInternalKsqlClient is requested to makeKsqlRequest
Back to top