[MINOR] Page renames

Author: jaceklaskowski

SUMMARY.adoc

@@ -332,7 +332,7 @@
 
 . link:kafka-streams-internals-AssignedTasks.adoc[AssignedTasks]
 .. link:kafka-streams-AssignedStandbyTasks.adoc[AssignedStandbyTasks -- AssignedTasks For StandbyTasks]
-.. link:kafka-streams-AssignedStreamsTasks.adoc[AssignedStreamsTasks -- AssignedTasks For StreamTasks]
+.. link:kafka-streams-internals-AssignedStreamsTasks.adoc[AssignedStreamsTasks -- AssignedTasks For StreamTasks]
 
 . link:kafka-streams-internals-ProcessorNodePunctuator.adoc[ProcessorNodePunctuator Contract]
 
@@ -402,7 +402,7 @@
 . link:kafka-streams-internals-StateManager.adoc[StateManager Contract -- State Store Managers]
 .. link:kafka-streams-internals-AbstractStateManager.adoc[AbstractStateManager]
 
-. link:kafka-streams-ProcessorStateManager.adoc[ProcessorStateManager]
+. link:kafka-streams-internals-ProcessorStateManager.adoc[ProcessorStateManager]
 . link:kafka-streams-GlobalStateManager.adoc[GlobalStateManager]
 .. link:kafka-streams-internals-GlobalStateManagerImpl.adoc[GlobalStateManagerImpl]
 

kafka-streams-ChangelogReader.adoc

@@ -20,7 +20,7 @@ a| [[register]]
 void register(final StateRestorer restorer)
 ----
 
-Used exclusively when `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#register, register a persistent state store>> (with an underlying changelog topic)
+Used exclusively when `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#register, register a persistent state store>> (with an underlying changelog topic)
 
 | reset
 a| [[reset]]
@@ -54,6 +54,6 @@ Map<TopicPartition, Long> restoredOffsets()
 
 Restores offsets (for <<kafka-streams-StateStore.adoc#persistent, persistent state stores>>)
 
-Used exclusively when `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#checkpoint, checkpoint offsets>>
+Used exclusively when `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#checkpoint, checkpoint offsets>>
 
 |===

kafka-streams-CompositeRestoreListener.adoc

@@ -2,7 +2,7 @@
 
 `CompositeRestoreListener` is a concrete `BatchingStateRestoreCallback` and a <<kafka-streams-StateRestoreListener.adoc#, StateRestoreListener>>.
 
-`CompositeRestoreListener` is <<creating-instance, created>> exclusively when `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#register, register a state store>> (and restores it from the changelog topic).
+`CompositeRestoreListener` is <<creating-instance, created>> exclusively when `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#register, register a state store>> (and restores it from the changelog topic).
 
 [[userRestoreListener]]
 `CompositeRestoreListener` uses a <<kafka-streams-StateRestoreListener.adoc#, StateRestoreListener>> in <<onRestoreStart, onRestoreStart>>, <<onBatchRestored, onBatchRestored>> and <<onRestoreEnd, onRestoreEnd>> callbacks. A `StateRestoreListener` can be assigned using <<setUserRestoreListener, setUserRestoreListener>> method.

kafka-streams-StateRestorer.adoc

@@ -4,7 +4,7 @@
 
 `StateRestorer` uses a <<compositeRestoreListener, CompositeRestoreListener>> to propagate the events: <<restoreStarted, restoreStarted>>, <<restoreDone, restoreDone>>, <<restoreBatchCompleted, restoreBatchCompleted>>, <<restore, restore>>.
 
-`StateRestorer` is <<creating-instance, created>> exclusively when `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#register, register a state store>>.
+`StateRestorer` is <<creating-instance, created>> exclusively when `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#register, register a state store>>.
 
 === [[creating-instance]] Creating StateRestorer Instance
 

kafka-streams-StateStore.adoc

@@ -27,7 +27,7 @@ Used when:
 
 * `AbstractStateManager` is requested to <<kafka-streams-internals-AbstractStateManager.adoc#reinitializeStateStoresForPartitions, reinitializeStateStoresForPartitions>>
 
-* <<kafka-streams-internals-GlobalStateManagerImpl.adoc#close, GlobalStateManagerImpl>> and <<kafka-streams-ProcessorStateManager.adoc#close, ProcessorStateManager>> are requested to close
+* <<kafka-streams-internals-GlobalStateManagerImpl.adoc#close, GlobalStateManagerImpl>> and <<kafka-streams-internals-ProcessorStateManager.adoc#close, ProcessorStateManager>> are requested to close
 
 * `RocksDBStore` is requested to `toggleDbForBulkLoading`
 
@@ -45,7 +45,7 @@ Flushes cached data
 
 Used when:
 
-* <<kafka-streams-internals-GlobalStateManagerImpl.adoc#flush, GlobalStateManagerImpl>> and <<kafka-streams-ProcessorStateManager.adoc#flush, ProcessorStateManager>> are requested to flush their state stores
+* <<kafka-streams-internals-GlobalStateManagerImpl.adoc#flush, GlobalStateManagerImpl>> and <<kafka-streams-internals-ProcessorStateManager.adoc#flush, ProcessorStateManager>> are requested to flush their state stores
 
 * <<kafka-streams-StateStore-CachingKeyValueStore.adoc#close, CachingKeyValueStore>>, <<kafka-streams-StateStore-CachingSessionStore.adoc#close, CachingSessionStore>> and <<kafka-streams-StateStore-CachingWindowStore.adoc#close, CachingWindowStore>> are requested to close state stores
 
@@ -117,7 +117,7 @@ Used when:
 
 * `GlobalStateManagerImpl` is <<kafka-streams-internals-GlobalStateManagerImpl.adoc#creating-instance, created>>
 
-* `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#register, register a state store>> and <<kafka-streams-ProcessorStateManager.adoc#checkpoint, checkpoint>>
+* `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#register, register a state store>> and <<kafka-streams-internals-ProcessorStateManager.adoc#checkpoint, checkpoint>>
 |===
 
 [[implementations]]

kafka-streams-internals-AbstractStateManager.adoc

@@ -17,7 +17,7 @@ NOTE: `AbstractStateManager` is a Java abstract class and cannot be <<creating-i
 | <<kafka-streams-internals-GlobalStateManagerImpl.adoc#, GlobalStateManagerImpl>>
 | [[GlobalStateManagerImpl]]
 
-| <<kafka-streams-ProcessorStateManager.adoc#, ProcessorStateManager>>
+| <<kafka-streams-internals-ProcessorStateManager.adoc#, ProcessorStateManager>>
 | [[ProcessorStateManager]]
 |===
 
@@ -39,7 +39,7 @@ Used when:
 
 * `GlobalStateManagerImpl` is requested to <<kafka-streams-internals-GlobalStateManagerImpl.adoc#initialize, initialize>> and <<kafka-streams-internals-GlobalStateManagerImpl.adoc#checkpoint, checkpoint>>
 
-* `ProcessorStateManager` is <<kafka-streams-ProcessorStateManager.adoc#, created>> and requested to <<kafka-streams-ProcessorStateManager.adoc#checkpoint, checkpoint>>
+* `ProcessorStateManager` is <<kafka-streams-internals-ProcessorStateManager.adoc#, created>> and requested to <<kafka-streams-internals-ProcessorStateManager.adoc#checkpoint, checkpoint>>
 
 | checkpointableOffsets
 a| [[checkpointableOffsets]] Collection of Kafka https://kafka.apache.org/22/javadoc/index.html?org/apache/kafka/common/TopicPartition.html[TopicPartitions] with offsets (`Map<TopicPartition, Long>`)
@@ -48,7 +48,7 @@ Entries (partitions with offsets) added when:
 
 * `GlobalStateManagerImpl` is requested to <<kafka-streams-internals-GlobalStateManagerImpl.adoc#initialize, initialize>>, <<kafka-streams-internals-GlobalStateManagerImpl.adoc#restoreState, restoreState>> and <<kafka-streams-internals-GlobalStateManagerImpl.adoc#checkpoint, checkpoint>>
 
-* `ProcessorStateManager` is <<kafka-streams-ProcessorStateManager.adoc#, created>> and requested to <<kafka-streams-ProcessorStateManager.adoc#checkpoint, checkpoint>>
+* `ProcessorStateManager` is <<kafka-streams-internals-ProcessorStateManager.adoc#, created>> and requested to <<kafka-streams-internals-ProcessorStateManager.adoc#checkpoint, checkpoint>>
 
 | globalStores
 a| [[globalStores]] Global <<kafka-streams-StateStore.adoc#, state stores>> by name (managed by <<kafka-streams-internals-GlobalStateManagerImpl.adoc#, GlobalStateManagerImpl>> _mostly_)
@@ -57,22 +57,22 @@ New state stores added when:
 
 * `GlobalStateManagerImpl` is requested to <<kafka-streams-internals-GlobalStateManagerImpl.adoc#register, register a state store>>
 
-* `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#registerGlobalStateStores, registerGlobalStateStores>>
+* `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#registerGlobalStateStores, registerGlobalStateStores>>
 
 State stores removed when:
 
 * `GlobalStateManagerImpl` is requested to <<kafka-streams-internals-GlobalStateManagerImpl.adoc#close, close>>
 
 | stores
-a| [[stores]] <<kafka-streams-StateStore.adoc#, State stores>> by name (managed by <<kafka-streams-ProcessorStateManager.adoc#, ProcessorStateManager>>)
+a| [[stores]] <<kafka-streams-StateStore.adoc#, State stores>> by name (managed by <<kafka-streams-internals-ProcessorStateManager.adoc#, ProcessorStateManager>>)
 
 New state stores added when:
 
-* `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#register, register a state store>>
+* `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#register, register a state store>>
 
 State stores removed when:
 
-* `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#close, close>>
+* `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#close, close>>
 |===
 
 === [[reinitializeStateStoresForPartitions]] `reinitializeStateStoresForPartitions` Method
@@ -95,7 +95,7 @@ void reinitializeStateStoresForPartitions(
 
 * `GlobalStateManagerImpl` is requested to <<kafka-streams-internals-GlobalStateManagerImpl.adoc#reinitializeStateStoresForPartitions, reinitializeStateStoresForPartitions>>
 
-* `ProcessorStateManager` is requested to <<kafka-streams-ProcessorStateManager.adoc#reinitializeStateStoresForPartitions, reinitializeStateStoresForPartitions>>
+* `ProcessorStateManager` is requested to <<kafka-streams-internals-ProcessorStateManager.adoc#reinitializeStateStoresForPartitions, reinitializeStateStoresForPartitions>>
 ====
 
 === [[inverseOneToOneMap]] `inverseOneToOneMap` Internal Method

kafka-streams-internals-AbstractTask.adoc

@@ -52,9 +52,9 @@ a| [[processorContext]] <<kafka-streams-internals-InternalProcessorContext.adoc#
 * <<kafka-streams-internals-StandbyContextImpl.adoc#, StandbyContextImpl>> for <<kafka-streams-internals-StandbyTask.adoc#, StandbyTask>>
 
 | stateMgr
-a| [[stateMgr]] <<kafka-streams-ProcessorStateManager.adoc#, ProcessorStateManager>>
+a| [[stateMgr]] <<kafka-streams-internals-ProcessorStateManager.adoc#, ProcessorStateManager>>
 
-<<kafka-streams-ProcessorStateManager.adoc#creating-instance, Created>> when `AbstractTask` is <<creating-instance, created>>
+<<kafka-streams-internals-ProcessorStateManager.adoc#creating-instance, Created>> when `AbstractTask` is <<creating-instance, created>>
 
 Used when:
 
@@ -111,7 +111,7 @@ NOTE: `hasStateStores` is part of link:kafka-streams-internals-Task.adoc#hasStat
 void flushState()
 ----
 
-`flushState` simply requests the <<stateMgr, ProcessorStateManager>> to <<kafka-streams-ProcessorStateManager.adoc#flush, flush>>.
+`flushState` simply requests the <<stateMgr, ProcessorStateManager>> to <<kafka-streams-internals-ProcessorStateManager.adoc#flush, flush>>.
 
 NOTE: `flushState` is used exclusively when `StreamTask` is requested to <<kafka-streams-internals-StreamTask.adoc#commit, commit>> (using the custom <<kafka-streams-internals-StreamTask.adoc#flushState, flushState>>).
 
@@ -146,7 +146,7 @@ Collection<TopicPartition> changelogPartitions()
 
 NOTE: `changelogPartitions` is part of <<kafka-streams-internals-Task.adoc#changelogPartitions, Task Contract>> to get the changelog partitions of a task.
 
-`changelogPartitions` simply requests the <<stateMgr, ProcessorStateManager>> for the <<kafka-streams-ProcessorStateManager.adoc#changelogPartitions, changelogPartitions>>.
+`changelogPartitions` simply requests the <<stateMgr, ProcessorStateManager>> for the <<kafka-streams-internals-ProcessorStateManager.adoc#changelogPartitions, changelogPartitions>>.
 
 === [[getStore]] Accessing State Store by Name -- `getStore` Method
 
@@ -157,7 +157,7 @@ StateStore getStore(final String name)
 
 NOTE: `getStore` is part of the <<kafka-streams-internals-Task.adoc#getStore, Task Contract>> to access the <<kafka-streams-StateStore.adoc#, state store>> by name.
 
-`getStore` simply requests the <<stateMgr, ProcessorStateManager>> for the <<kafka-streams-ProcessorStateManager.adoc#getStore, StateStore by name>>.
+`getStore` simply requests the <<stateMgr, ProcessorStateManager>> for the <<kafka-streams-internals-ProcessorStateManager.adoc#getStore, StateStore by name>>.
 
 === [[updateOffsetLimits]] `updateOffsetLimits` Method
 
@@ -186,7 +186,7 @@ void updateOffsetLimits()
 void reinitializeStateStoresForPartitions(final Collection<TopicPartition> partitions)
 ----
 
-`reinitializeStateStoresForPartitions` simply requests the <<stateMgr, ProcessorStateManager>> to <<kafka-streams-ProcessorStateManager.adoc#reinitializeStateStoresForPartitions, reinitializeStateStores>> for the input `partitions` and the <<processorContext, InternalProcessorContext>>.
+`reinitializeStateStoresForPartitions` simply requests the <<stateMgr, ProcessorStateManager>> to <<kafka-streams-internals-ProcessorStateManager.adoc#reinitializeStateStoresForPartitions, reinitializeStateStores>> for the input `partitions` and the <<processorContext, InternalProcessorContext>>.
 
 [NOTE]
 ====

kafka-streams-AssignedStreamsTasks.adoc kafka-streams-internals-AssignedStreamsTasks.adoc

@@ -4,7 +4,7 @@
 
 `AssignedTasks` uses the following <<internal-properties, internal registries>> to determine the status of a task:
 
-* <<running, running>> for tasks that are considered *running* (that `AssignedStreamsTasks` uses when requested to link:kafka-streams-AssignedStreamsTasks.adoc#process[process])
+* <<running, running>> for tasks that are considered *running* (that `AssignedStreamsTasks` uses when requested to link:kafka-streams-internals-AssignedStreamsTasks.adoc#process[process])
 
 * <<created, created>> for tasks that are considered *new*
 
@@ -26,7 +26,7 @@ NOTE: `AssignedTasks` is a Java abstract class and cannot be <<creating-instance
 | <<kafka-streams-AssignedStandbyTasks.adoc#, AssignedStandbyTasks>>
 | Manages <<kafka-streams-internals-StandbyTask.adoc#, StandbyTasks>>
 
-| <<kafka-streams-AssignedStreamsTasks.adoc#, AssignedStreamsTasks>>
+| <<kafka-streams-internals-AssignedStreamsTasks.adoc#, AssignedStreamsTasks>>
 | Manages <<kafka-streams-internals-StreamTask.adoc#, StreamTasks>>
 |===
 
@@ -102,7 +102,7 @@ Transitioning [taskTypeName] [taskId] to running
 
 `transitionToRunning` marks the task as running (by adding it to the <<running, running>> internal registry).
 
-NOTE: Registering a task in the <<running, running>> internal registry is the only way to mark the task as running and ready for <<kafka-streams-AssignedStreamsTasks.adoc#process, processing records>>.
+NOTE: Registering a task in the <<running, running>> internal registry is the only way to mark the task as running and ready for <<kafka-streams-internals-AssignedStreamsTasks.adoc#process, processing records>>.
 
 `transitionToRunning` requests the task to <<kafka-streams-internals-Task.adoc#initializeTopology, initialize the topology of processor nodes>>.
 
@@ -112,7 +112,7 @@ NOTE: Registering a task in the <<running, running>> internal registry is the on
 ====
 `transitionToRunning` is used when:
 
-* `AssignedStreamsTasks` is requested to <<kafka-streams-AssignedStreamsTasks.adoc#updateRestored, updateRestored>>
+* `AssignedStreamsTasks` is requested to <<kafka-streams-internals-AssignedStreamsTasks.adoc#updateRestored, updateRestored>>
 
 * `AssignedTasks` is requested to <<initializeNewTasks, initialize new tasks>> and <<maybeResumeSuspendedTask, attempt to resume a suspended task>>
 ====
@@ -157,7 +157,7 @@ Initializing [taskTypeName]s [created]
 
 If the above yielded `true`, `initializeNewTasks` <<transitionToRunning, marks the task as ready for execution and processing records>>.
 
-Otherwise, when the above <<kafka-streams-internals-Task.adoc#initializeStateStores, state store initialization>> yielded `false`, `initializeNewTasks` prints out the following DEBUG message to the logs and the concrete `AssignedStreamsTasks` is requested to <<kafka-streams-AssignedStreamsTasks.adoc#addToRestoring, register the StreamTask as restoring>>.
+Otherwise, when the above <<kafka-streams-internals-Task.adoc#initializeStateStores, state store initialization>> yielded `false`, `initializeNewTasks` prints out the following DEBUG message to the logs and the concrete `AssignedStreamsTasks` is requested to <<kafka-streams-internals-AssignedStreamsTasks.adoc#addToRestoring, register the StreamTask as restoring>>.
 
 ```
 Transitioning [taskTypeName] [taskId] to restoring
@@ -365,7 +365,7 @@ void applyToRunningTasks(final TaskAction<T> action)
 ====
 `applyToRunningTasks` is used when:
 
-* `AssignedStreamsTasks` is requested to link:kafka-streams-AssignedStreamsTasks.adoc#maybeCommit[maybeCommit]
+* `AssignedStreamsTasks` is requested to link:kafka-streams-internals-AssignedStreamsTasks.adoc#maybeCommit[maybeCommit]
 
 * `AssignedTasks` is requested to <<commit, commit>>
 ====

kafka-streams-internals-AssignedTasks.adoc

@@ -6,7 +6,7 @@
 
 1. `AbstractStateManager` is link:kafka-streams-internals-AbstractStateManager.adoc#creating-instance[created]
 
-1. `ProcessorStateManager` is requested to link:kafka-streams-ProcessorStateManager.adoc#checkpoint[checkpoint]
+1. `ProcessorStateManager` is requested to link:kafka-streams-internals-ProcessorStateManager.adoc#checkpoint[checkpoint]
 
 [[creating-instance]]
 [[file]]
@@ -31,7 +31,7 @@ Map<TopicPartition, Long> read() throws IOException
 `read` is used when:
 
 * `GlobalStateManagerImpl` is requested to link:kafka-streams-internals-GlobalStateManagerImpl.adoc#initialize[initialize]
-* `ProcessorStateManager` is link:kafka-streams-ProcessorStateManager.adoc#creating-instance[created]
+* `ProcessorStateManager` is link:kafka-streams-internals-ProcessorStateManager.adoc#creating-instance[created]
 ====
 
 === [[write]] Writing Offsets to Checkpoint File -- `write` Method
@@ -49,7 +49,7 @@ void write(final Map<TopicPartition, Long> offsets) throws IOException
 
 * `AbstractStateManager` is requested to link:kafka-streams-internals-AbstractStateManager.adoc#reinitializeStateStoresForPartitions[reinitializeStateStoresForPartitions]
 * `GlobalStateManagerImpl` is requested to link:kafka-streams-internals-GlobalStateManagerImpl.adoc#checkpoint[checkpoint]
-* `ProcessorStateManager` is requested to link:kafka-streams-ProcessorStateManager.adoc#checkpoint[checkpoint]
+* `ProcessorStateManager` is requested to link:kafka-streams-internals-ProcessorStateManager.adoc#checkpoint[checkpoint]
 ====
 
 === [[delete]] Deleting Offset Checkpoint File -- `delete` Method
@@ -61,4 +61,4 @@ void delete() throws IOException
 
 `delete` simply deletes the <<file, offset checkpoint file>> if exists.
 
-NOTE: `delete` is used exclusively when `ProcessorStateManager` is link:kafka-streams-ProcessorStateManager.adoc#creating-instance[created] (with link:kafka-streams-exactly-once-support-eos.adoc[Exactly-Once Support (EOS)] enabled).
+NOTE: `delete` is used exclusively when `ProcessorStateManager` is link:kafka-streams-internals-ProcessorStateManager.adoc#creating-instance[created] (with link:kafka-streams-exactly-once-support-eos.adoc[Exactly-Once Support (EOS)] enabled).

kafka-streams-internals-OffsetCheckpoint.adoc

@@ -38,7 +38,7 @@ NOTE: `schedule` is part of <<kafka-streams-ProcessorContext.adoc#schedule, Proc
 * [[task]] <<kafka-streams-internals-StreamTask.adoc#, StreamTask>>
 * [[config]] <<kafka-streams-StreamsConfig.adoc#, StreamsConfig>>
 * [[collector]] <<kafka-streams-internals-RecordCollector.adoc#, RecordCollector>>
-* [[stateMgr]] <<kafka-streams-ProcessorStateManager.adoc#, ProcessorStateManager>>
+* [[stateMgr]] <<kafka-streams-internals-ProcessorStateManager.adoc#, ProcessorStateManager>>
 * [[metrics]] <<kafka-streams-internals-StreamsMetricsImpl.adoc#, StreamsMetricsImpl>>
 * [[cache]] <<kafka-streams-internals-ThreadCache.adoc#, ThreadCache>>