Modifier and Type | Field | Description |
---|---|---|
int |
partition |
The ID of the partition.
|
int |
topicGroupId |
The ID of the topic group.
|
Constructor | Description |
---|---|
TaskId(int topicGroupId,
int partition) |
Modifier and Type | Method | Description |
---|---|---|
int |
compareTo(TaskId other) |
|
boolean |
equals(java.lang.Object o) |
|
int |
hashCode() |
|
static TaskId |
parse(java.lang.String taskIdStr) |
|
static TaskId |
readFrom(java.io.DataInputStream in) |
|
static TaskId |
readFrom(java.nio.ByteBuffer buf) |
|
java.lang.String |
toString() |
|
void |
writeTo(java.io.DataOutputStream out) |
|
void |
writeTo(java.nio.ByteBuffer buf) |
public final int topicGroupId
public final int partition
public java.lang.String toString()
toString
in class java.lang.Object
public static TaskId parse(java.lang.String taskIdStr)
TaskIdFormatException
- if the taskIdStr is not a valid TaskId
public void writeTo(java.io.DataOutputStream out) throws java.io.IOException
java.io.IOException
- if cannot write to output streampublic static TaskId readFrom(java.io.DataInputStream in) throws java.io.IOException
java.io.IOException
- if cannot read from input streampublic void writeTo(java.nio.ByteBuffer buf)
public static TaskId readFrom(java.nio.ByteBuffer buf)
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object