Package org.apache.kafka.streams.processor.internals

Class GlobalStateUpdateTask

java.lang.Object

org.apache.kafka.streams.processor.internals.GlobalStateUpdateTask

public class GlobalStateUpdateTask
extends Object

Updates the state for all Global State Stores.

Constructor Summary

Constructors

Constructor	Description
GlobalStateUpdateTask(org.apache.kafka.common.utils.LogContext logContext, ProcessorTopology topology, InternalProcessorContext processorContext, GlobalStateManager stateMgr, DeserializationExceptionHandler deserializationExceptionHandler)

Method Summary

Modifier and Type	Method	Description
void	close(boolean wipeStateStore)
void	flushState()
Map<TopicPartition,Long>	initialize()
void	update(ConsumerRecord<byte[],byte[]> record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GlobalStateUpdateTask

public GlobalStateUpdateTask(org.apache.kafka.common.utils.LogContext logContext,
                             ProcessorTopology topology,
                             InternalProcessorContext processorContext,
                             GlobalStateManager stateMgr,
                             DeserializationExceptionHandler deserializationExceptionHandler)

Method Detail

initialize

public Map<TopicPartition,Long> initialize()

Throws:

IllegalStateException - If store gets registered after initialized is already finished

StreamsException - If the store's change log does not contain the partition

update

public void update(ConsumerRecord<byte[],byte[]> record)

flushState

public void flushState()

close

public void close(boolean wipeStateStore)
           throws IOException

Throws:

IOException