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.

results matching ""