public Set<PartitionId> getCurrentlyReplicatingPriorityPartitions() {
    return currentlyReplicatingPriorityPartitions;
  }
Creates a new ReplicationPrioritizationManager.

@param replicationEngine The ReplicationEngine to control partition replication.
@param clusterMap        The ClusterMap to get partition and replica information.
@param dataNodeId        The DataNodeId of the local node.
@param scheduler         The scheduler to run periodic tasks.
ambry-prioritization/src/main/java/com/github/ambry/replica/prioritization/ReplicationPrioritizationManager.java