ReassignPartitionsCommand

ReassignPartitionsCommand is…​FIXME

Starting ReassignPartitionsCommand on Command Line — main Entry Method

main(args: Array[String]): Unit

main…​FIXME

executeAssignment Method

executeAssignment(
  zkUtils: ZkUtils,
  adminClientOpt: Option[AdminClient],
  opts: ReassignPartitionsCommand.ReassignPartitionsCommandOptions): Unit

executeAssignment(
  zkUtils: ZkUtils,
  adminClientOpt: Option[AdminClient],
  reassignmentJsonString: String,
  throttle: ReassignPartitionsCommand.Throttle,
  timeoutMs: Long = 10000L): Unit

executeAssignment…​FIXME

Note
executeAssignment is used exclusively when ReassignPartitionsCommand is started on command line with execute option.

reassignPartitions Method

reassignPartitions(throttle: Throttle = NoThrottle, timeoutMs: Long = 10000L): Boolean

reassignPartitions…​FIXME

Note
reassignPartitions is used exclusively when ReassignPartitionsCommand executeAssignment.

alterReplicaLogDirsIgnoreReplicaNotAvailable Internal Method

alterReplicaLogDirsIgnoreReplicaNotAvailable(
  replicaAssignment: Map[TopicPartitionReplica, String],
  adminClient: JAdminClient,
  timeoutMs: Long): Set[TopicPartitionReplica]

alterReplicaLogDirsIgnoreReplicaNotAvailable…​FIXME

Note
alterReplicaLogDirsIgnoreReplicaNotAvailable is used exclusively when ReassignPartitionsCommand reassignPartitions

results matching ""

    No results matching ""