Package com.findwise.hydra

Examples of com.findwise.hydra.Pipeline.addGroup()

109
110
111
112
113
114
115
116
117
118
119
                if (cmd.getStageNames() != null) {
                    if (cmd.getStageNames().contains(stage.getName())) {
                        log.info("Preparing to upload stage, " + stage.getName());
                        StageGroup g = new StageGroup(stage.getName());
                        g.addStage(stage);
                        pipeline.addGroup(g);
                    }
                } else {
                    log.info("Preparing to upload stage, " + stage.getName());
                    StageGroup g = new StageGroup(stage.getName());
                    g.addStage(stage);
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
                    }
                } else {
                    log.info("Preparing to upload stage, " + stage.getName());
                    StageGroup g = new StageGroup(stage.getName());
                    g.addStage(stage);
                    pipeline.addGroup(g);
                }
            }
            log.info("Uploading stages");
            log.info(pipeline.toString());
            mdc.getPipelineWriter().write(pipeline);
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
    while(cursor.hasNext()) {
      DBObject obj = cursor.next();
      if(!obj.containsField(TYPE_KEY) || STAGE_TYPE.equals(obj.get(TYPE_KEY))) {
        Stage s = getStage(obj);
        if(!p.hasGroup(getGroupName(obj))) {
          p.addGroup(new StageGroup(getGroupName(obj)));
        }
        p.getGroup(getGroupName(obj)).addStage(s);
      } else {
        addGroup(p, getGroup(obj));
      }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
  public void addStage(Stage stage, String groupName) throws IOException {

    Pipeline pipeline = connector.getPipelineReader().getPipeline();
    if(!pipeline.hasGroup(groupName)) {
      pipeline.addGroup(new StageGroup(groupName));
    }
    pipeline.getGroup(groupName).addStage(stage);
    connector.getPipelineWriter().write(pipeline);
  }
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
      Pipeline pipeline = connector.getPipelineReader().getPipeline();
      if(groupName == null) {
        groupName = getStageGroupForStage(stageToDelete);
      }
      if(!pipeline.hasGroup(groupName)) {
        pipeline.addGroup(new StageGroup(groupName));
      }
      pipeline.getGroup(groupName).removeStage(stageName);
      connector.getPipelineWriter().write(pipeline);
   
      ret.put("stageStatus", "Deleted stage " + stageName);
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    Stage multi2 = new Stage("multi2", new DatabaseFile());
    multiGroup.addStage(multi1);
    multiGroup.addStage(multi2);
    singleGroup.addStage(single);
   
    p.addGroup(multiGroup);
    p.addGroup(singleGroup);
   
    assertEquals(2, p.getStageGroups().size());
    assertTrue(p.hasGroup("multi"));
    assertTrue(p.hasGroup("singleStage"));
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
    multiGroup.addStage(multi1);
    multiGroup.addStage(multi2);
    singleGroup.addStage(single);
   
    p.addGroup(multiGroup);
    p.addGroup(singleGroup);
   
    assertEquals(2, p.getStageGroups().size());
    assertTrue(p.hasGroup("multi"));
    assertTrue(p.hasGroup("singleStage"));
   
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
    Stage multi2 = new Stage("multi2", new DatabaseFile());
    multiGroup.addStage(multi1);
    multiGroup.addStage(multi2);
    singleGroup.addStage(single);
   
    p.addGroup(multiGroup);
    p.addGroup(singleGroup);
   
    multiGroup.setJvmParameters("jvm");
    multiGroup.setRetries(3);
    multiGroup.setLogging(false);
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
    multiGroup.addStage(multi1);
    multiGroup.addStage(multi2);
    singleGroup.addStage(single);
   
    p.addGroup(multiGroup);
    p.addGroup(singleGroup);
   
    multiGroup.setJvmParameters("jvm");
    multiGroup.setRetries(3);
    multiGroup.setLogging(false);
    multiGroup.setCmdlineArgs("cmd");
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
  public void testGetStages() throws Exception {
    Pipeline p = new Pipeline();
    StageGroup g = new StageGroup("1");
    g.addStage(new Stage("stage", Mockito.mock(DatabaseFile.class)));
    g.addStage(new Stage("stage2", Mockito.mock(DatabaseFile.class)));
    p.addGroup(g);
   
    Mockito.when(reader.getPipeline()).thenReturn(p);
   
    List<String> stages = GroupStarter.getStages("localhost", server.getPort(), "1");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.