AssignmentInfo

AssignmentInfo is…​FIXME

Decoding User Data — decode Static Method

static AssignmentInfo decode(ByteBuffer data)

decode…​FIXME

Note
decode is used exclusively when StreamsPartitionAssignor is requested to handle partition assignment from the group leader.

decodeVersionOneData Internal Static Method

static void decodeVersionOneData(
  final AssignmentInfo assignmentInfo,
  final DataInputStream in) throws IOException

decodeVersionOneData…​FIXME

Note
decodeVersionOneData is used exclusively when AssignmentInfo is requested to decode the user data.

encodeActiveAndStandbyTaskAssignment Internal Method

void encodeActiveAndStandbyTaskAssignment(final DataOutputStream out)

encodeActiveAndStandbyTaskAssignment…​FIXME

Note
encodeActiveAndStandbyTaskAssignment is used when AssignmentInfo is requested to encodeVersionOne, encodeVersionTwo, encodeVersionThree, and encodeVersionFour.

decodeActiveTasks Internal Factory Method

static void decodeActiveTasks(
  final AssignmentInfo assignmentInfo,
  final DataInputStream in)

decodeActiveTasks…​FIXME

Note
decodeActiveTasks is used when…​FIXME

decodeStandbyTasks Internal Factory Method

static void decodeStandbyTasks(
  final AssignmentInfo assignmentInfo,
  final DataInputStream in)

decodeStandbyTasks…​FIXME

Note
decodeStandbyTasks is used when…​FIXME

encodeVersionFour Internal Method

void encodeVersionFour(final DataOutputStream out)

encodeVersionFour…​FIXME

Note
encodeVersionFour is used exclusively when AssignmentInfo is requested to encode (for the metadata version as 4).

encodeVersionThree Internal Method

void encodeVersionThree(final DataOutputStream out)

encodeVersionThree…​FIXME

Note
encodeVersionThree is used when…​FIXME

encodeVersionTwo Internal Method

void encodeVersionTwo(final DataOutputStream out)

encodeVersionTwo…​FIXME

Note
encodeVersionTwo is used when…​FIXME

encodeVersionOne Internal Method

void encodeVersionOne(final DataOutputStream out)

encodeVersionOne…​FIXME

Note
encodeVersionOne is used when…​FIXME

encode Method

ByteBuffer encode()

encode…​FIXME

Note
encode is used exclusively when StreamsPartitionAssignor is requested to errorAssignment, computeNewAssignment, and versionProbingAssignment.

results matching ""

    No results matching ""