kafka-streams-internals-InternalNameProvider.adoc

InternalNameProvider Contract

InternalNameProvider is the abstraction of internal name providers that give a new name for a processor or a store.

Table 1. InternalNameProvider Contract

Method	Description
newProcessorName	String newProcessorName(String prefix) Returns a name of a processor with the given prefix Used when: GroupedStreamAggregateBuilder is requested to build InternalStreamsBuilder is requested to stream, table, globalTable and addGlobalStore KGroupedTableImpl is requested to doAggregate KStreamImpl is requested to filter, etc. KStreamImplJoin is requested to join KTableImpl is requested to doFilter, etc.
newStoreName	String newStoreName(String prefix) Returns a name of a state store with the given prefix Used when: KGroupedStreamImpl, SessionWindowedKStreamImpl, and TimeWindowedKStreamImpl are requested to count KTableImpl is requested to suppress MaterializedInternal is requested to generateStoreNameIfNeeded

Note	InternalStreamsBuilder is the one and only known implementation of InternalNameProvider Contract in Kafka Streams.