Class ClientState
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.assignment.ClientState
-
public class ClientState extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description ClientState()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
activeTaskCount()
java.util.Set<TaskId>
activeTasks()
void
addPreviousActiveTasks(java.util.Set<TaskId> prevTasks)
void
addPreviousStandbyTasks(java.util.Set<TaskId> standbyTasks)
void
assign(TaskId taskId, boolean active)
int
assignedTaskCount()
ClientState
copy()
void
incrementCapacity()
java.util.Set<TaskId>
prevActiveTasks()
java.util.Set<TaskId>
prevStandbyTasks()
java.util.Set<TaskId>
standbyTasks()
java.lang.String
toString()
-
-
-
Method Detail
-
copy
public ClientState copy()
-
assign
public void assign(TaskId taskId, boolean active)
-
activeTasks
public java.util.Set<TaskId> activeTasks()
-
standbyTasks
public java.util.Set<TaskId> standbyTasks()
-
prevActiveTasks
public java.util.Set<TaskId> prevActiveTasks()
-
prevStandbyTasks
public java.util.Set<TaskId> prevStandbyTasks()
-
assignedTaskCount
public int assignedTaskCount()
-
incrementCapacity
public void incrementCapacity()
-
activeTaskCount
public int activeTaskCount()
-
addPreviousActiveTasks
public void addPreviousActiveTasks(java.util.Set<TaskId> prevTasks)
-
addPreviousStandbyTasks
public void addPreviousStandbyTasks(java.util.Set<TaskId> standbyTasks)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-