QueryMetadata¶

QueryMetadata is an abstraction of query metadatas.

Contract (Subset)¶

getKafkaStreams¶

KafkaStreams getKafkaStreams()

KafkaStreams (Kafka Streams) to execute this query

Used when:

• SandboxedExecutionContext is requested to execute
• PersistentQueryMetadataImpl is requested to initialize
• TransientQueryMetadata is requested to isRunning
• PersistentQuerySaturationMetrics is requested to measure
• QueryMetricsUtil is requested to initializePullStreamMetricsCallback

getQueryType¶

KsqlConstants.KsqlQueryType getQueryType()

KsqlQueryType of this query

Used when:

• QueryDescriptionFactory is requested to create a QueryDescription
• ListQueriesExecutor is requested to getLocalSimple (for LIST QUERIES command)

getTopology¶

Topology getTopology()

Topology (Kafka Streams) of this query

Used when:

• PersistentQueryMetadataImpl is requested to initialize
• SandboxedSharedKafkaStreamsRuntimeImpl is created
• SharedKafkaStreamsRuntimeImpl is requested to start a query and restartStreamsRuntime

start¶

void start()

Starts this query

Used when:

• KsqlContext is requested to sql
• StandaloneExecutor is requested to processesQueryFile
• CommandRunner is requested to processPriorCommands
• InteractiveStatementExecutor is requested to executePlan

Implementations¶

• PersistentQueryMetadata
• QueryMetadataImpl