Package com.alibaba.jstorm.daemon.nimbus

Examples of com.alibaba.jstorm.daemon.nimbus.TopologyAssignEvent

34
35
36
37
38
39
40
41
42
43
44
45
46
47
  @Override
  public <T> Object execute(T... args) {

    // default is true
    TopologyAssignEvent assignEvent = new TopologyAssignEvent();
    assignEvent.setTopologyId(topologyid);
    assignEvent.setScratch(false);
    assignEvent.setOldStatus(oldStatus);

    TopologyAssign.push(assignEvent);

    return null;
  }
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
  }

  @Override
  public <T> Object execute(T... args) {
    try {
      TopologyAssignEvent event = new TopologyAssignEvent();

      event.setTopologyId(topologyid);
      event.setScratch(true);
      event.setOldStatus(oldStatus);

      TopologyAssign.push(event);

    } catch (Exception e) {
      LOG.error("do-rebalance error!", e);
View Full Code Here
TOP

Related Classes of com.alibaba.jstorm.daemon.nimbus.TopologyAssignEvent

  • com.alibaba.jstorm.callback.impl.DoRebalanceTransitionCallback
  • com.alibaba.jstorm.callback.impl.ReassignTransitionCallback
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.