Package co.cask.cdap.internal.app.runtime

Examples of co.cask.cdap.internal.app.runtime.AbstractListener

88
89
90
91
92
93
94
95
96
97
98
      runtimeInfos.put(type, runId, addRemover(runtimeInfo));
    }
  }

  private RuntimeInfo addRemover(final RuntimeInfo runtimeInfo) {
    runtimeInfo.getController().addListener(new AbstractListener() {
      @Override
      public void stopped() {
        remove(runtimeInfo);
      }
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
      Preconditions.checkState(!destinationUnpackedJarDir.exists());
      destinationUnpackedJarDir.mkdirs();

      Program bundleJarProgram = Programs.createWithUnpack(program.getJarLocation(), destinationUnpackedJarDir);
      RuntimeInfo info = super.run(bundleJarProgram, options);
      info.getController().addListener(new AbstractListener() {
        @Override
        public void stopped() {
          try {
            FileUtils.deleteDirectory(destinationUnpackedJarDir);
          } catch (IOException e) {
View Full Code Here
827
828
829
830
831
832
833
834
835
836
837
        runtimeService.run(program, new SimpleProgramOptions(id.getId(), new BasicArguments(), userArguments, debug));

      ProgramController controller = runtimeInfo.getController();
      final String runId = controller.getRunId().getId();

      controller.addListener(new AbstractListener() {
        @Override
        public void stopped() {
          store.setStop(id, runId,
                        TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS),
                        ProgramController.State.STOPPED.toString());
View Full Code Here
234
235
236
237
238
239
240
241
242
243
244
      Services.chainStart(zkClientService, kafkaClientService, metricsCollectionService, resourceReporter));

    LOG.info("Starting runnable: {}", name);
    controller = injector.getInstance(getProgramClass()).run(program, programOpts);
    final SettableFuture<ProgramController.State> state = SettableFuture.create();
    controller.addListener(new AbstractListener() {
      @Override
      public void stopped() {
        state.set(ProgramController.State.STOPPED);
      }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
                   TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS));

    final Id.Program programId = program.getId();
    final String runId = controller.getRunId().getId();
    final CountDownLatch latch = new CountDownLatch(1);
    controller.addListener(new AbstractListener() {
      @Override
      public void stopped() {
        store.setStop(programId, runId,
                      TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS),
                      ProgramController.State.STOPPED.toString());
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
    final MapReduceContext context = (controller instanceof MapReduceProgramController)
                                        ? ((MapReduceProgramController) controller).getContext()
                                        : null;
    // Execute the program.
    final SettableFuture<MapReduceContext> completion = SettableFuture.create();
    controller.addListener(new AbstractListener() {
      @Override
      public void stopped() {
        completion.set(context);
      }
View Full Code Here
TOP

Related Classes of co.cask.cdap.internal.app.runtime.AbstractListener

  • co.cask.cdap.app.runtime.AbstractProgramRuntimeService
  • co.cask.cdap.gateway.handlers.AppFabricHttpHandler
  • co.cask.cdap.internal.app.runtime.distributed.AbstractProgramTwillRunnable
  • co.cask.cdap.internal.app.runtime.schedule.ScheduleTaskRunner
  • co.cask.cdap.internal.app.runtime.service.InMemoryProgramRuntimeService
  • co.cask.cdap.internal.app.runtime.workflow.WorkflowMapReduceRunnerFactory
    • 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.