public class GlobalStateUpdateTask
extends java.lang.Object
Constructor and Description |
---|
GlobalStateUpdateTask(ProcessorTopology topology,
InternalProcessorContext processorContext,
GlobalStateManager stateMgr,
DeserializationExceptionHandler deserializationExceptionHandler,
org.apache.kafka.common.utils.LogContext logContext) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
flushState() |
java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> |
initialize() |
void |
update(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record) |
public GlobalStateUpdateTask(ProcessorTopology topology, InternalProcessorContext processorContext, GlobalStateManager stateMgr, DeserializationExceptionHandler deserializationExceptionHandler, org.apache.kafka.common.utils.LogContext logContext)
public java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> initialize()
java.lang.IllegalStateException
- If store gets registered after initialized is already finishedStreamsException
- If the store's change log does not contain the partitionpublic void update(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record)
public void flushState()
public void close() throws java.io.IOException
java.io.IOException