Path	Lines of Code
streams/src/main/java/org/apache/kafka/streams/Consumed.java	56
streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java	12
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	577
streams/src/main/java/org/apache/kafka/streams/KeyValue.java	32
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java	166
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	584
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java	31
streams/src/main/java/org/apache/kafka/streams/Topology.java	194
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java	30
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java	13
streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java	19
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LockException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java	23
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java	23
streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java	18
streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/TaskAssignmentException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/TaskMigratedException.java	24
streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/TopologyException.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java	10
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java	60
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java	49
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java	123
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java	58
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java	193
streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java	306
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java	191
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java	85
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java	49
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java	42
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java	21
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java	69
streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java	15
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java	12
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Window.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java	150
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CacheFlushListener.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java	41
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java	31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ForwardingCacheFlushListener.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GlobalKTableImpl.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java	63
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalNameProvider.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java	161
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalValueTransformerWithKey.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalValueTransformerWithKeySupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	441
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java	234
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java	75
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFilter.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMap.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValues.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoin.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	769
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamJoinWindow.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPassThrough.java	16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPeek.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPrint.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java	73
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	122
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransform.java	46
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java	137
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java	108
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowReduce.java	106
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java	64
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java	95
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	710
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoinValueGetterSupplier.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java	91
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java	76
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java	78
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinValueGetter.java	34
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java	78
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java	89
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java	60
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java	65
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KeyValueStoreMaterializer.java	31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java	47
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintForeachAction.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintedInternal.java	12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ProducedInternal.java	18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionKeySerde.java	116
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindow.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	172
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java	21
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	152
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java	42
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedDeserializer.java	63
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedSerializer.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitioner.java	17
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingBatchingRestoreCallback.java	26
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingRestoreCallback.java	21
streams/src/main/java/org/apache/kafka/streams/processor/AbstractProcessor.java	20
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java	6
streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java	4
streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java	51
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java	17
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java	22
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java	16
streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java	8
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java	10
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java	31
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java	5
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java	4
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java	6
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java	15
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java	10
streams/src/main/java/org/apache/kafka/streams/processor/StateStoreSupplier.java	9
streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java	5
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java	67
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java	44
streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java	59
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java	8
streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java	391
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java	18
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java	10
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java	159
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractStateManager.java	77
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java	190
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasks.java	98
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java	385
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java	10
streams/src/main/java/org/apache/kafka/streams/processor/internals/Checkpointable.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListener.java	72
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java	28
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java	41
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java	11
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManager.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java	297
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java	77
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java	243
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java	38
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java	180
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1507
streams/src/main/java/org/apache/kafka/streams/processor/internals/MinTimestampTracker.java	40
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java	99
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java	93
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java	150
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java	6
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java	45
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	263
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java	152
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java	36
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationSchedule.java	61
streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	28
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java	201
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordContext.java	8
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java	61
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java	101
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java	45
streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java	79
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java	68
streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java	16
streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java	26
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyContextImpl.java	124
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java	89
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java	241
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	19
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestorer.java	81
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	246
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java	523
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	418
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	836
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java	183
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetricsImpl.java	151
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	29
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	325
streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadStateTransitionValidator.java	4
streams/src/main/java/org/apache/kafka/streams/processor/internals/TimestampTracker.java	9
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java	42
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java	53
streams/src/main/java/org/apache/kafka/streams/processor/internals/WrappedBatchingStateRestoreCallback.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java	137
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java	112
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java	247
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java	109
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignor.java	4
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java	44
streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/state/KeyValueIterator.java	9
streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java	10
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java	7
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java	58
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java	8
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java	6
streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java	60
streams/src/main/java/org/apache/kafka/streams/state/StoreBuilder.java	12
streams/src/main/java/org/apache/kafka/streams/state/StoreSupplier.java	7
streams/src/main/java/org/apache/kafka/streams/state/Stores.java	288
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java	61
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java	7
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java	104
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreBuilder.java	58
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreSupplier.java	36
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFunction.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java	232
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java	168
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java	195
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java	70
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java	59
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java	46
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java	79
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java	55
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java	82
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.java	61
streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java	76
streams/src/main/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProvider.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/HasNextCondition.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStore.java	86
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java	137
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreSupplier.java	18
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreSupplier.java	20
streams/src/main/java/org/apache/kafka/streams/state/internals/InnerMeteredKeyValueStore.java	256
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIterators.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java	38
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java	55
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	134
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java	58
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIterator.java	30
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterator.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java	35
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java	48
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueBytesStore.java	105
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java	84
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java	139
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java	117
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java	52
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java	58
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java	317
streams/src/main/java/org/apache/kafka/streams/state/internals/NextIteratorFunction.java	5
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java	111
streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/PeekingKeyValueIterator.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreSupplier.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java	114
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java	87
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreSupplier.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	448
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java	100
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreSupplier.java	42
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java	62
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java	27
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunction.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java	197
streams/src/main/java/org/apache/kafka/streams/state/internals/SerializedKeyValueIterator.java	43
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java	68
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/StateStoreProvider.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreChangeLogger.java	30
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java	38
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java	250
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java	43
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java	149
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreUtils.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java	57
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java	24