TransientQueryMetadata¶

TransientQueryMetadata is a QueryMetadataImpl and a PushQueryMetadata.

Creating Instance¶

TransientQueryMetadata takes the following to be created:

• Statement text
• LogicalSchema
• Source Names
• Execution Plan
• BlockingRowQueue
• Query ID
• Query Application ID
• Topology (Kafka Streams)
• KafkaStreamsBuilder
• Streams Properties
• Overridden Properties
• ksql.streams.shutdown.timeout.ms
• ksql.query.error.max.queue.size
• ResultType
• ksql.query.retry.backoff.initial.ms
• ksql.query.retry.backoff.max.ms
• Listener
• ProcessingLoggerFactory

TransientQueryMetadata is created when:

• QueryBuilder is requested to build a transient query
• SandboxedTransientQueryMetadata is created

ProcessingLoggerFactory¶

TransientQueryMetadata is given a ProcessingLoggerFactory when created.

The ProcessingLoggerFactory is part of QueryMetadataImpl abstraction.

Query Type¶

KsqlQueryType getQueryType()

getQueryType is part of the QueryMetadata abstraction.

getQueryType is KsqlQueryType.PUSH.