PersistentQueryMetadata¶

PersistentQueryMetadata is an extension of the QueryMetadata abstraction for metadata of persistent queries.

Contract (Subset)¶

getPersistentQueryType¶

KsqlConstants.PersistentQueryType getPersistentQueryType()

One of the following:

• CREATE_SOURCE
• CREATE_AS
• INSERT

Used when:

• QueryRegistryImpl is requested to registerPersistentQuery and unregisterQuery
• PersistentQueryMetadataImpl is created
• ValidatedCommandFactory is requested to createForTerminateQuery

getProcessingLogger¶

ProcessingLogger getProcessingLogger()

ProcessingLogger of this persistent query

Implementations¶

• BinPackedPersistentQueryMetadataImpl
• PersistentQueryMetadataImpl