Examples of execute()

Examples of org.apache.felix.shell.Command.execute()

244
245
246
247
248
249
250
251
252
253
254
                }
                else
                {
                    try
                    {
                        command.execute(commandLine, out, err);
                    }
                    catch (Throwable ex)
                    {
                        err.println("Unable to execute command: " + ex);
                        ex.printStackTrace(err);
View Full Code Here

Examples of org.apache.flink.api.common.operators.CollectionExecutor.execute()

29
30
31
32
33
34
35
36
37
38
39
  @Override
  public JobExecutionResult execute(String jobName) throws Exception {
    Plan p = createProgramPlan(jobName);
   
    CollectionExecutor exec = new CollectionExecutor(mutableObjectSafeMode);
    return exec.execute(p);
  }
 
  @Override
  public int getDegreeOfParallelism() {
    return 1; // always serial
View Full Code Here

Examples of org.apache.flink.api.java.CollectionEnvironment.execute()

51
52
53
54
55
56
57
58
59
60
61
     
      env.fromElements(TEST_DATA)
          .map(new SuffixAppender()).withBroadcastSet(bcData, BC_VAR_NAME)
          .output(new LocalCollectionOutputFormat<String>(result));
     
      env.execute();
     
      assertEquals(TEST_DATA.length, result.size());
      for (String s : result) {
        assertTrue(s.indexOf(SUFFIX) > 0);
      }
View Full Code Here

Examples of org.apache.flink.api.java.ExecutionEnvironment.execute()

69
70
71
72
73
74
75
76
77
78
79
    DataSet<Tuple2<Long, Double>> result = intialRanks.runOperation(
      VertexCentricIteration.withValuedEdges(edgesWithProbability,
            new VertexRankUpdater(numVertices, BETA), new RankMessenger(), 20));
   
    result.print();
    env.execute("Spargel PageRank");
  }
 
  /**
   * Function that updates the rank of a vertex by summing up the partial ranks from all incoming messages
   * and then applying the dampening formula.
View Full Code Here

Examples of org.apache.flink.runtime.executiongraph.ExecutionGraph.execute()

448
449
450
451
452
453
454
455
456
457
458
      public void run() {
        eg.cancel();
      }
    };

    eg.execute(cancelJobRunnable);

    return new JobCancelResult(AbstractJobResult.ReturnCode.SUCCESS, null);
  }
 
  @Override
View Full Code Here

Examples of org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute()

42
43
44
45
46
47
48
49
    DataStream<String> stream = env.fromElements(WordCountData.WORDS).map(new IdentityMap());

    stream.print();

    env.execute();
  }
}
View Full Code Here

Examples of org.apache.ftpserver.command.Command.execute()

79
80
81
82
83
84
85
86
87
88
89
        // call appropriate command method
        String optsRequest = "OPTS_" + argument;
        Command command = COMMAND_MAP.get(optsRequest);
        try {
            if (command != null) {
                command.execute(session, context, request);
            } else {
                session.resetState();
                session.write(LocalizedFtpReply.translate(session, request, context,
                        FtpReply.REPLY_502_COMMAND_NOT_IMPLEMENTED,
                        "OPTS.not.implemented", argument));
View Full Code Here

Examples of org.apache.ftpserver.interfaces.Command.execute()

74
75
76
77
78
79
80
81
82
83
84
        // call appropriate command method
        String optsRequest = "OPTS_" + argument;
        Command command = (Command)COMMAND_MAP.get( optsRequest );
        try {
            if(command != null) {
                command.execute(session, context, request);
            }
            else {
                session.resetState();
                session.write(FtpReplyUtil.translate(session, request, context, FtpReply.REPLY_502_COMMAND_NOT_IMPLEMENTED, "OPTS.not.implemented", argument));
            }
View Full Code Here

Examples of org.apache.geronimo.datastore.impl.remote.messaging.CommandRequest.execute()

222
223
224
225
226
227
228
229
230
231
232
        Object id = header.getHeader(MsgHeaderConstants.CORRELATION_ID);
        CommandRequest command;
        String gateway;
        command = (CommandRequest) body.getContent();
        command.setTarget(this);
        CommandResult result = command.execute();
        Msg msg = new Msg();
        body = msg.getBody();
        body.setContent(result);
        MsgOutInterceptor reqOut =
            new HeaderOutInterceptor(
View Full Code Here

Examples of org.apache.geronimo.deployment.cli.AbstractCommand.execute()

43
44
45
46
47
48
49
50
51
        AbstractCommand command = new CommandUnlockKeystore();

        BaseCommandArgs args = new BaseCommandArgs(keystoreNames.toArray(new String[keystoreNames.size()]));

        command.execute(this, connection, args);
        return null;
    }
}
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.