PersistentQueryMetadataImpl¶

PersistentQueryMetadataImpl is a QueryMetadataImpl and a PersistentQueryMetadata.

Creating Instance¶

PersistentQueryMetadataImpl takes the following to be created:

• PersistentQueryType
• Statement Text
• PhysicalSchema
• Source Names
• Sink DataSource
• Execution Plan
• Query ID
• MaterializationProviderBuilder
• Query Application ID
• Topology (Kafka Streams)
• KafkaStreamsBuilder
• QuerySchemas
• Streams Properties (Map<String, Object>)
• Overrideen Properties (Map<String, Object>)
• Close Timeout
• QueryErrorClassifier
• ExecutionStep
• maxQueryErrorsQueueSize
• ProcessingLogger
• retryBackoffInitialMs
• retryBackoffMaxMs
• QueryMetadata.Listener
• ScalablePushRegistry

PersistentQueryMetadataImpl is created when:

• QueryBuilder is requested to buildPersistentQueryInDedicatedRuntime

ProcessingLogger¶

PersistentQueryMetadataImpl is given a ProcessingLogger when created.

The ProcessingLogger is used in uncaughtHandler (to error log unhandled exceptions caught in streams threads).

uncaughtHandler¶

StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse uncaughtHandler(
  Throwable error)

uncaughtHandler is part of the PersistentQueryMetadata abstraction.

uncaughtHandler...FIXME