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 ""