Skip to content

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
  • QueryId
  • 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: