Class SingleTopologyCluster

java.lang.Object
org.apache.storm.scheduler.Cluster
org.apache.storm.scheduler.SingleTopologyCluster
All Implemented Interfaces:
ISchedulingState

public class SingleTopologyCluster extends Cluster
A Cluster that only allows modification to a single topology.
  • Constructor Details

    • SingleTopologyCluster

      public SingleTopologyCluster(Cluster other, String topologyId)
      Create a new cluster that only allows modifications to a single topology.
      Parameters:
      other - the current cluster to base this off of
      topologyId - the topology that is allowed to be modified.
  • Method Details

    • assertValidTopologyForModification

      protected void assertValidTopologyForModification(String topologyId)
      Description copied from class: Cluster
      Check if the given topology is allowed for modification right now. If not throw an IllegalArgumentException else go on.
      Overrides:
      assertValidTopologyForModification in class Cluster
      Parameters:
      topologyId - the id of the topology to check