Examples of execute()

Examples of com.artemis.Weaver.execute()

40
41
42
43
44
45
46
47
48
49
50
  void execute() {
    long start = System.currentTimeMillis();
   
    Weaver.enablePooledWeaving(!disablePooledWeaving);
    Weaver weaver = new Weaver(classRoot);
    WeaverLog processed = weaver.execute();
    if (verbose && processed.components.size() > 0) {
      System.out.println(getSummary(processed.components, start));
    } else {
      System.out.println(processed.getFormattedLog());
    }
View Full Code Here

Examples of com.asakusafw.testdriver.JobExecutor.execute()

203
204
205
206
207
208
209
210
211
212
213
            }
        });

        JobExecutor executor = new InProcessJobExecutor(context);
        try {
            executor.execute(job(MockHadoopJob.class.getName()), Collections.<String, String>emptyMap());
        } catch (IOException e) {
            throw new AssertionError(e);
        }
        assertThat(call.get(), is(true));
    }
View Full Code Here

Examples of com.asakusafw.windgate.core.AbortTask.execute()

119
120
121
122
123
124
125
126
127
128
129
            WGLOG.error(e, "E01001");
            return 1;
        }
        try {
            if (RuntimeContext.get().canExecute(task)) {
                task.execute();
            }
            return 0;
        } catch (Exception e) {
            WGLOG.error(e, "E01002");
            return 1;
View Full Code Here

Examples of com.asakusafw.windgate.core.GateTask.execute()

152
153
154
155
156
157
158
159
160
161
162
            WGLOG.error(e, "E00001");
            return 1;
        }
        try {
            if (RuntimeContext.get().canExecute(task)) {
                task.execute();
            }
            return 0;
        } catch (Exception e) {
            WGLOG.error(e, "E00002");
            return 1;
View Full Code Here

Examples of com.asakusafw.windgate.core.process.ProcessProvider.execute()

376
377
378
379
380
381
382
383
384
385
386
                    LOG.debug("Starting gate process: {}",
                            process.getName(),
                            sessionId);
                    try {
                        if (RuntimeContext.get().canExecute(processProvider)) {
                            processProvider.execute(drivers, process);
                        } else {
                            LOG.info("Skipped process execution (simulated)");
                        }
                    } catch (IOException e) {
                        WGLOG.error(e, "E00003",
View Full Code Here

Examples of com.asakusafw.yaess.core.CommandScriptHandler.execute()

233
234
235
236
237
238
239
240
241
242
243
                map());

        CommandScriptHandler handler = handler();
        ExecutionContext context = new ExecutionContext(
                "tbatch", "tflow", "texec", ExecutionPhase.MAIN, map());
        handler.execute(PhaseMonitor.NULL, context, script);
    }

    /**
     * Script is missing.
     * @throws Exception if failed
View Full Code Here

Examples of com.asakusafw.yaess.core.HadoopScriptHandler.execute()

254
255
256
257
258
259
260
261
262
263
264
                map());

        HadoopScriptHandler handler = handler("env.ASAKUSA_HOME", getAsakusaHome().getAbsolutePath());
        ExecutionContext context = new ExecutionContext(
                "tbatch", "tflow", "texec", ExecutionPhase.MAIN, map());
        handler.execute(ExecutionMonitor.NULL, context, script);
    }

    /**
     * Asakusa home is missing.
     * @throws Exception if failed
View Full Code Here

Examples of com.asakusafw.yaess.core.JobScheduler.execute()

59
60
61
62
63
64
65
66
67
68
69
    public void simple() throws Exception {
        JobScheduler instance = create("parallel.default", "1");

        List<Mock> jobs = new ArrayList<Mock>();
        jobs.add(new Mock("a"));
        instance.execute(PhaseMonitor.NULL, CONTEXT, jobs, JobScheduler.STRICT);
        Set<String> rest = collectRest(jobs);
        assertThat(rest.size(), is(0));
    }

    /**
 
View Full Code Here

Examples of com.atlassian.clover.ant.tasks.CloverLogTask.execute()

92
93
94
95
96
97
98
99
100
101
102
        cloverLogTask.setOutputProperty("cloverlogproperty");
        if (this.contextFilters != null) {
            cloverLogTask.setFilter(this.contextFilters);
        }
        setTestSourceRoots(cloverLogTask);
        cloverLogTask.execute();

        getLog().info(antProject.getProperty("cloverlogproperty"));
    }

    /**
 
View Full Code Here

Examples of com.atlassian.clover.ant.tasks.CloverMergeTask.execute()

106
107
108
109
110
111
112
113
114
115
116
                dbSet.setSpan(new Interval(span));
            }

            merge.addCloverDbSet(dbSet);

            merge.execute();
        } catch (BuildException e) {
            throw new MojoExecutionException(e.getMessage(), e);
        }
    }
}
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.