Files

graffles
images
LICENSE
SUMMARY.adoc
book-intro.adoc
book.json
kafka-logging.adoc
kafka-streams-AbstractNotifyingBatchingRestoreCallback.adoc
kafka-streams-AbstractNotifyingRestoreCallback.adoc
kafka-streams-AbstractProcessor.adoc
kafka-streams-BatchingStateRestoreCallback.adoc
kafka-streams-Cancellable.adoc
kafka-streams-Consumed.adoc
kafka-streams-DefaultPartitionGrouper.adoc
kafka-streams-DelegatingStateRestoreListener.adoc
kafka-streams-ExtractRecordMetadataTimestamp.adoc
kafka-streams-FailOnInvalidTimestamp.adoc
kafka-streams-GlobalKTable.adoc
kafka-streams-Grouped.adoc
kafka-streams-JoinWindows.adoc
kafka-streams-Joined.adoc
kafka-streams-KGroupedStream.adoc
kafka-streams-KGroupedTable.adoc
kafka-streams-KStream.adoc
kafka-streams-KTable.adoc
kafka-streams-KafkaClientSupplier.adoc
kafka-streams-KafkaStreams.adoc
kafka-streams-KeyValueBytesStoreSupplier.adoc
kafka-streams-KeyValueMapper.adoc
kafka-streams-KeyValueStore.adoc
kafka-streams-Materialized.adoc
kafka-streams-PartitionGrouper.adoc
kafka-streams-Printed.adoc
kafka-streams-Processor.adoc
kafka-streams-ProcessorContext.adoc
kafka-streams-ProcessorSupplier.adoc
kafka-streams-Produced.adoc
kafka-streams-PunctuationSchedule.adoc
kafka-streams-Punctuator.adoc
kafka-streams-ReadOnlyKeyValueStore.adoc
kafka-streams-RecordContext.adoc
kafka-streams-SessionBytesStoreSupplier.adoc
kafka-streams-SessionStore.adoc
kafka-streams-SessionWindowedKStream.adoc
kafka-streams-Stamped.adoc
kafka-streams-StateRestoreCallback.adoc
kafka-streams-StateRestoreListener.adoc
kafka-streams-StateStore.adoc
kafka-streams-StoreBuilder.adoc
kafka-streams-StoreSupplier.adoc
kafka-streams-Stores.adoc
kafka-streams-StreamPartitioner.adoc
kafka-streams-StreamTask-TaskMetrics.adoc
kafka-streams-StreamThread-RebalanceListener.adoc
kafka-streams-StreamThread-StateListener.adoc
kafka-streams-StreamThreads-StreamTasks-and-StandbyTasks.adoc
kafka-streams-StreamsBuilder.adoc
kafka-streams-StreamsConfig.adoc
kafka-streams-StreamsMetrics.adoc
kafka-streams-TaskId.adoc
kafka-streams-TimeWindowedKStream.adoc
kafka-streams-TimeWindowedSerializer.adoc
kafka-streams-TimeWindows.adoc
kafka-streams-TimestampExtractor.adoc
kafka-streams-TimestampedKeyValueStore.adoc
kafka-streams-To.adoc
kafka-streams-TopicNameExtractor.adoc
kafka-streams-Topology.adoc
kafka-streams-TopologyDescription-Node.adoc
kafka-streams-TopologyDescription-Processor.adoc
kafka-streams-TopologyDescription-Sink.adoc
kafka-streams-TopologyDescription-Source.adoc
kafka-streams-TopologyDescription.adoc
kafka-streams-TopologyTestDriver.adoc
kafka-streams-Transformer.adoc
kafka-streams-TransformerSupplier.adoc
kafka-streams-UnlimitedWindows.adoc
kafka-streams-ValueJoiner.adoc
kafka-streams-ValueTransformer.adoc
kafka-streams-ValueTransformerSupplier.adoc
kafka-streams-ValueTransformerWithKey.adoc
kafka-streams-WallclockTimestampExtractor.adoc
kafka-streams-Window.adoc
kafka-streams-WindowBytesStoreSupplier.adoc
kafka-streams-WindowStore.adoc
kafka-streams-Windowed.adoc
kafka-streams-WindowedSerdes.adoc
kafka-streams-Windows.adoc
kafka-streams-demo-creating-topology-with-state-store-logging-enabled.adoc
kafka-streams-exactly-once-support-eos.adoc
kafka-streams-internals-AbstractProcessorContext.adoc
kafka-streams-internals-AbstractRocksDBSegmentedBytesStore.adoc
kafka-streams-internals-AbstractStateManager.adoc
kafka-streams-internals-AbstractStoreBuilder.adoc
kafka-streams-internals-AbstractStream.adoc
kafka-streams-internals-AbstractTask.adoc
kafka-streams-internals-AbstractTaskCreator.adoc
kafka-streams-internals-AssignedStandbyTasks.adoc
kafka-streams-internals-AssignedStreamsTasks.adoc
kafka-streams-internals-AssignedTasks.adoc
kafka-streams-internals-AssignmentInfo.adoc
kafka-streams-internals-BaseJoinProcessorNode.adoc
kafka-streams-internals-BaseRepartitionNode.adoc
kafka-streams-internals-CacheFlushListener.adoc
kafka-streams-internals-CachedStateStore.adoc
kafka-streams-internals-CachingKeyValueStore.adoc
kafka-streams-internals-CachingSessionStore.adoc
kafka-streams-internals-CachingWindowStore.adoc
kafka-streams-internals-ChangeLoggingKeyValueBytesStore.adoc
kafka-streams-internals-ChangeLoggingSessionBytesStore.adoc
kafka-streams-internals-ChangeLoggingWindowBytesStore.adoc
kafka-streams-internals-ChangelogReader.adoc
kafka-streams-internals-Checkpointable.adoc
kafka-streams-internals-ClientMetadata.adoc
kafka-streams-internals-CompositeRestoreListener.adoc
kafka-streams-internals-ConsumedInternal.adoc
kafka-streams-internals-CopartitionedTopicsValidator.adoc
kafka-streams-internals-DefaultKafkaClientSupplier.adoc
kafka-streams-internals-ForwardingDisabledProcessorContext.adoc
kafka-streams-internals-GlobalKTableImpl.adoc
kafka-streams-internals-GlobalProcessorContextImpl.adoc
kafka-streams-internals-GlobalStateMaintainer.adoc
kafka-streams-internals-GlobalStateManager.adoc
kafka-streams-internals-GlobalStateManagerImpl.adoc
kafka-streams-internals-GlobalStateStoreProvider.adoc
kafka-streams-internals-GlobalStateUpdateTask.adoc
kafka-streams-internals-GlobalStoreNode.adoc
kafka-streams-internals-GlobalStreamThread.adoc
kafka-streams-internals-GroupedStreamAggregateBuilder.adoc
kafka-streams-internals-GroupedTableOperationRepartitionNode.adoc
kafka-streams-internals-GroupedTableOperationRepartitionNodeBuilder.adoc
kafka-streams-internals-InMemoryKeyValueStore.adoc
kafka-streams-internals-InMemorySessionBytesStoreSupplier.adoc
kafka-streams-internals-InMemorySessionStore.adoc
kafka-streams-internals-InMemoryTimeOrderedKeyValueBuffer.adoc
kafka-streams-internals-InMemoryWindowStore.adoc
kafka-streams-internals-InternalNameProvider.adoc
kafka-streams-internals-InternalProcessorContext.adoc
kafka-streams-internals-InternalStreamsBuilder.adoc
kafka-streams-internals-InternalTopicConfig.adoc
kafka-streams-internals-InternalTopicManager.adoc
kafka-streams-internals-InternalTopologyBuilder-AbstractNode.adoc
kafka-streams-internals-InternalTopologyBuilder-GlobalStore.adoc
kafka-streams-internals-InternalTopologyBuilder-NodeFactory.adoc
kafka-streams-internals-InternalTopologyBuilder-Processor.adoc
kafka-streams-internals-InternalTopologyBuilder-ProcessorNodeFactory.adoc
kafka-streams-internals-InternalTopologyBuilder-Sink.adoc
kafka-streams-internals-InternalTopologyBuilder-SinkNodeFactory.adoc
kafka-streams-internals-InternalTopologyBuilder-Source.adoc
kafka-streams-internals-InternalTopologyBuilder-SourceNodeFactory.adoc
kafka-streams-internals-InternalTopologyBuilder-StateStoreFactory.adoc
kafka-streams-internals-InternalTopologyBuilder-TopologyDescription.adoc
kafka-streams-internals-InternalTopologyBuilder.adoc
kafka-streams-internals-KGroupedStreamImpl.adoc
kafka-streams-internals-KGroupedTableImpl.adoc
kafka-streams-internals-KStreamAggProcessorSupplier.adoc
kafka-streams-internals-KStreamAggregate.adoc
kafka-streams-internals-KStreamBranch.adoc
kafka-streams-internals-KStreamFilter.adoc
kafka-streams-internals-KStreamFilterProcessor.adoc
kafka-streams-internals-KStreamImpl-KStreamImplJoin.adoc
kafka-streams-internals-KStreamImpl.adoc
kafka-streams-internals-KStreamJoinWindowProcessor.adoc
kafka-streams-internals-KStreamPassThrough.adoc
kafka-streams-internals-KStreamPeek.adoc
kafka-streams-internals-KStreamSessionWindowAggregate.adoc
kafka-streams-internals-KStreamSessionWindowAggregateProcessor.adoc
kafka-streams-internals-KStreamTransform.adoc
kafka-streams-internals-KStreamTransformProcessor.adoc
kafka-streams-internals-KStreamTransformValues.adoc
kafka-streams-internals-KStreamTransformValuesProcessor.adoc
kafka-streams-internals-KStreamWindowAggregate.adoc
kafka-streams-internals-KStreamWindowAggregateProcessor.adoc
kafka-streams-internals-KTableImpl.adoc
kafka-streams-internals-KTableKTableAbstractJoinValueGetterSupplier.adoc
kafka-streams-internals-KTableKTableJoinNode.adoc
kafka-streams-internals-KTableMaterializedValueGetterSupplier.adoc
kafka-streams-internals-KTableSource.adoc
kafka-streams-internals-KTableSourceProcessor.adoc
kafka-streams-internals-KTableSourceValueGetterSupplier.adoc
kafka-streams-internals-KTableSuppressProcessor.adoc
kafka-streams-internals-KTableValueGetter.adoc
kafka-streams-internals-KTableValueGetterSupplier.adoc
kafka-streams-internals-KeyValueStoreBuilder.adoc
kafka-streams-internals-KeyValueStoreMaterializer.adoc
kafka-streams-internals-KeyValueToTimestampedKeyValueByteStoreAdapter.adoc
kafka-streams-internals-MaterializedInternal.adoc
kafka-streams-internals-MemoryLRUCache.adoc
kafka-streams-internals-MeteredKeyValueBytesStore.adoc
kafka-streams-internals-MeteredKeyValueStore.adoc
kafka-streams-internals-MeteredSessionStore.adoc
kafka-streams-internals-MeteredWindowStore.adoc
kafka-streams-internals-NamedCache.adoc
kafka-streams-internals-NodeMetrics.adoc
kafka-streams-internals-OffsetCheckpoint.adoc
kafka-streams-internals-OptimizableRepartitionNode.adoc
kafka-streams-internals-PartitionGroup.adoc
kafka-streams-internals-ProcessorContextImpl.adoc
kafka-streams-internals-ProcessorGraphNode.adoc
kafka-streams-internals-ProcessorNode.adoc
kafka-streams-internals-ProcessorNodePunctuator.adoc
kafka-streams-internals-ProcessorParameters.adoc
kafka-streams-internals-ProcessorRecordContext.adoc
kafka-streams-internals-ProcessorStateManager.adoc
kafka-streams-internals-ProcessorTopology.adoc
kafka-streams-internals-ProducedInternal.adoc
kafka-streams-internals-ProducerSupplier.adoc
kafka-streams-internals-PunctuationQueue.adoc
kafka-streams-internals-QueryableStoreProvider.adoc
kafka-streams-internals-QuickUnion.adoc
kafka-streams-internals-RecordBatchingStateRestoreCallback.adoc
kafka-streams-internals-RecordCollector.adoc
kafka-streams-internals-RecordCollectorImpl.adoc
kafka-streams-internals-RecordDeserializer.adoc
kafka-streams-internals-RecordInfo.adoc
kafka-streams-internals-RecordQueue.adoc
kafka-streams-internals-RestoringTasks.adoc
kafka-streams-internals-RocksDBSegmentedBytesStore.adoc
kafka-streams-internals-RocksDBSessionStore.adoc
kafka-streams-internals-RocksDBStore.adoc
kafka-streams-internals-RocksDBTimestampedStore.adoc
kafka-streams-internals-RocksDBWindowStore.adoc
kafka-streams-internals-RocksDbKeyValueBytesStoreSupplier.adoc
kafka-streams-internals-RocksDbSessionBytesStoreSupplier.adoc
kafka-streams-internals-RocksDbWindowBytesStoreSupplier.adoc
kafka-streams-internals-SegmentedBytesStore.adoc
kafka-streams-internals-SessionStoreBuilder.adoc
kafka-streams-internals-SessionWindow.adoc
kafka-streams-internals-SessionWindowedKStreamImpl.adoc
kafka-streams-internals-SinkNode.adoc
kafka-streams-internals-SourceNode.adoc
kafka-streams-internals-StampedRecord.adoc
kafka-streams-internals-StandbyContextImpl.adoc
kafka-streams-internals-StandbyTask.adoc
kafka-streams-internals-StandbyTaskCreator.adoc
kafka-streams-internals-StateConsumer.adoc
kafka-streams-internals-StateDirectory.adoc
kafka-streams-internals-StateListener.adoc
kafka-streams-internals-StateManager.adoc
kafka-streams-internals-StateRestoreCallbackAdapter.adoc
kafka-streams-internals-StateRestorer.adoc
kafka-streams-internals-StateStoreNode.adoc
kafka-streams-internals-StateStoreProvider.adoc
kafka-streams-internals-StatefulProcessorNode.adoc
kafka-streams-internals-StaticTopicNameExtractor.adoc
kafka-streams-internals-StickyTaskAssignor.adoc
kafka-streams-internals-StoreChangeLogger.adoc
kafka-streams-internals-StoreChangelogReader.adoc
kafka-streams-internals-StreamSinkNode.adoc
kafka-streams-internals-StreamSourceNode.adoc
kafka-streams-internals-StreamStreamJoinNode.adoc
kafka-streams-internals-StreamTableJoinNode.adoc
kafka-streams-internals-StreamTask.adoc
kafka-streams-internals-StreamThread.adoc
kafka-streams-internals-StreamThreadStateStoreProvider.adoc
kafka-streams-internals-StreamsGraphNode.adoc
kafka-streams-internals-StreamsMetadataState.adoc
kafka-streams-internals-StreamsMetricsImpl.adoc
kafka-streams-internals-StreamsMetricsThreadImpl.adoc
kafka-streams-internals-StreamsPartitionAssignor.adoc
kafka-streams-internals-SubscriptionInfo.adoc
kafka-streams-internals-TableProcessorNode.adoc
kafka-streams-internals-TableSourceNode.adoc
kafka-streams-internals-Task.adoc
kafka-streams-internals-TaskAssignor.adoc
kafka-streams-internals-TaskCreator.adoc
kafka-streams-internals-TaskManager.adoc
kafka-streams-internals-ThreadCache.adoc
kafka-streams-internals-TimeOrderedKeyValueBuffer.adoc
kafka-streams-internals-TimeWindow.adoc
kafka-streams-internals-TimeWindowedKStreamImpl.adoc
kafka-streams-internals-TimestampedKeyValueStoreBuilder.adoc
kafka-streams-internals-TimestampedWindowStoreBuilder.adoc
kafka-streams-internals-TopicsInfo.adoc
kafka-streams-internals-UnlimitedWindow.adoc
kafka-streams-internals-UnwindowedChangelogTopicConfig.adoc
kafka-streams-internals-WindowStoreBuilder.adoc
kafka-streams-internals-WindowToTimestampedWindowByteStoreAdapter.adoc
kafka-streams-internals-WindowedChangelogTopicConfig.adoc
kafka-streams-internals-WindowedSerializer.adoc
kafka-streams-internals-WindowedStreamPartitioner.adoc
kafka-streams-internals-WrappedStateStore.adoc
kafka-streams-internals-WrappingStoreProvider.adoc
kafka-streams-multi-instance-kafka-streams-application.adoc
kafka-streams-processor-api.adoc
kafka-streams-properties.adoc
kafka-streams-scala-Consumed.adoc
kafka-streams-scala-Grouped.adoc
kafka-streams-scala-ImplicitConversions.adoc
kafka-streams-scala-Materialized.adoc
kafka-streams-scala-Produced.adoc
kafka-streams-scala-Serdes.adoc
kafka-streams-scala.adoc
kafka-streams-stateful-stream-processing.adoc
kafka-streams-streams-dsl.adoc
kafka-streams-why.adoc
kafka-streams.adoc

kafka-streams-internals-BaseRepartitionNode.adoc

jaceklaskowski

ProcessorGraphNode (and direct StreamsGraphNodes)

Jan 20, 2019

261d596 · Jan 20, 2019

History

BaseRepartitionNode Contract

BaseRepartitionNode is the base of StreamsGraphNodes that…FIXME

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Files

kafka-streams-internals-BaseRepartitionNode.adoc

kafka-streams-internals-BaseRepartitionNode.adoc

BaseRepartitionNode Contract

Files

kafka-streams-internals-BaseRepartitionNode.adoc

Latest commit

History

kafka-streams-internals-BaseRepartitionNode.adoc

File metadata and controls

BaseRepartitionNode Contract