QueryMetadataImpl¶
QueryMetadataImpl
is a QueryMetadata.
Creating Instance¶
QueryMetadataImpl
takes the following to be created:
- Statement Text
-
LogicalSchema
- Names of the Sources
- Execution Plan
- queryApplicationId
-
Topology
- KafkaStreamsBuilder
- Streams Properties
- overriddenProperties
-
closeTimeout
-
QueryId
-
QueryErrorClassifier
-
maxQueryErrorsQueueSize
-
baseWaitingTimeMs
-
retryBackoffMaxMs
-
Listener
KafkaStreamsBuilder¶
QueryMetadataImpl
is given a KafkaStreamsBuilder when created.
initialize¶
void initialize()
initialize
requests the KafkaStreamsBuilder to build a KafkaStreams instance (with the Topology and the streamsProperties).
initialize
resets the KafkaStreams instance and turns the initialized flag on.
initialize
is part of the QueryMetadata abstraction.