WSQueryEndpoint¶

Creating Instance¶

WSQueryEndpoint takes the following to be created:

• KsqlConfig
• StatementParser
• KsqlEngine
• CommandQueue
• ListeningScheduledExecutorService
• ActivenessRegistrar
• ksql.server.command.response.timeout.ms
• KsqlAuthorizationValidator
• Errors
• DenyListPropertyValidator
• QueryExecutor

WSQueryEndpoint is created when:

• KsqlRestApplication is requested to start (and initialize wsQueryEndpoint)

StatementParser¶

WSQueryEndpoint is given a StatementParser when created.

The StatementParser is used in parseStatement (to parse a KSQL statement).

KsqlEngine¶

WSQueryEndpoint is given a KsqlEngine when created.

The KsqlEngine is used to executeStreamQuery (to access the MetaStore) for authorization (only when KsqlAuthorizationValidator is given).

executeStreamQuery¶

void executeStreamQuery(
  ServerWebSocket webSocket,
  MultiMap requestParams,
  KsqlSecurityContext ksqlSecurityContext,
  Context context,
  Optional<Long> timeout)

executeStreamQuery...FIXME

executeStreamQuery is used when:

• KsqlServerEndpoints is requested to executeWebsocketStream