BlockingQueryPublisher¶

BlockingQueryPublisher is a QueryPublisher that is used by QueryEndpoint to handle the result of pull or push queries.

Creating Instance¶

BlockingQueryPublisher takes the following to be created:

• Context (Vert.x)
• WorkerExecutor (Vert.x)

BlockingQueryPublisher is created when:

• QueryEndpoint is requested to create a QueryPublisher (for the result of pull or push queries)

isPullQuery¶

boolean isPullQuery()

isPullQuery is part of the QueryPublisher abstraction.

isPullQuery flag is set in setQueryHandle to indicate whether the query is a pull query (true) or a push query (false).

setQueryHandle¶

void setQueryHandle(
  QueryHandle queryHandle,
  boolean isPullQuery,
  boolean isScalablePushQuery)

setQueryHandle...FIXME

setQueryHandle is used when:

• QueryEndpoint is requested to create a QueryPublisher (for the result of pull or push queries)

Logging¶

Enable ALL logging level for io.confluent.ksql.api.impl.BlockingQueryPublisher logger to see what happens inside.

Add the following line to log4j.properties:

log4j.logger.io.confluent.ksql.api.impl.BlockingQueryPublisher=ALL

Refer to Logging.