CommandIdAssigner¶

CommandIdAssigner is used by DistributingExecutor to execute KSQL statements.

Generating CommandId (for Statement)¶

CommandId getCommandId(
  Statement command)

getCommandId looks up the CommandIdSupplier for the given Statement in the SUPPLIERS registry and executes it (with the command statement).

getCommandId throws a RuntimeException when a CommandIdSupplier could not be found:

Cannot assign command ID to statement of type [commandClassName]

getCommandId is used when:

• DistributingExecutor is requested to execute a KSQL statement

CommandId Suppliers¶

CommandIdAssigner defines SUPPLIERS registry of Statements and their CommandId suppliers (functions that produce a CommandId).

The registry is used to getCommandId.

getInsertIntoCommandId¶

CommandId getInsertIntoCommandId(
  InsertInto insertInto)

getInsertIntoCommandId creates a CommandId.

getInsertIntoCommandId is used when:

• CommandIdAssigner is requested for the CommandId supplier of InsertInto statements