public abstract class AbstractTask extends java.lang.Object implements Task
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> |
activeTaskCheckpointableOffsets() |
java.lang.String |
applicationId() |
java.util.Collection<org.apache.kafka.common.TopicPartition> |
changelogPartitions() |
boolean |
commitNeeded() |
ProcessorContext |
context() |
StateStore |
getStore(java.lang.String name) |
boolean |
hasStateStores() |
TaskId |
id() |
boolean |
isClosed() |
boolean |
isEosEnabled() |
java.util.Set<org.apache.kafka.common.TopicPartition> |
partitions() |
ProcessorTopology |
topology() |
java.lang.String |
toString()
Produces a string representation containing useful information about a Task.
|
java.lang.String |
toString(java.lang.String indent)
Produces a string representation containing useful information about a Task starting with the given indent.
|
protected void |
updateOffsetLimits() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, closeSuspended, commit, initializeStateStores, initializeTopology, resume, suspend
public java.lang.String applicationId()
applicationId
in interface Task
public java.util.Set<org.apache.kafka.common.TopicPartition> partitions()
partitions
in interface Task
public ProcessorTopology topology()
public ProcessorContext context()
public StateStore getStore(java.lang.String name)
public java.lang.String toString()
toString
in class java.lang.Object
public boolean isEosEnabled()
public java.lang.String toString(java.lang.String indent)
protected java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> activeTaskCheckpointableOffsets()
protected void updateOffsetLimits()
public boolean isClosed()
public boolean commitNeeded()
commitNeeded
in interface Task
public boolean hasStateStores()
hasStateStores
in interface Task
public java.util.Collection<org.apache.kafka.common.TopicPartition> changelogPartitions()
changelogPartitions
in interface Task