MetaStoreImpl¶

MetaStoreImpl is a MutableMetaStore.

Creating Instance¶

MetaStoreImpl takes the following to be created:

• Data Sources (Map<SourceName, SourceInfo>)
• FunctionRegistry
• TypeRegistry
• Drop constraints (Map<SourceName, Set<SourceName>>)

MetaStoreImpl is created when:

• EngineExecutor is requested to sourceTablePlan
• KsqlEngine is created

dataSources¶

Map<SourceName, SourceInfo> dataSources

MetaStoreImpl starts with an empty dataSources registry when created.

A new entry is added in putSource.

Registering DataSource¶

void putSource(
  DataSource dataSource,
  boolean allowReplace)

putSource is part of the MutableMetaStore abstraction.

putSource adds the given DataSource to the dataSources registry.

putSource prints out the following INFO message to the logs:

Source [name] created on the metastore

putSource re-builds DROP constraints (if there are any).

Logging¶

Enable ALL logging level for io.confluent.ksql.metastore.MetaStoreImpl logger to see what happens inside.

Add the following line to log4j.properties:

log4j.logger.io.confluent.ksql.metastore.MetaStoreImpl=ALL

Refer to Logging.