Examples of ProgramTerminator

co.cask.cdap.internal.app.deploy.ProgramTerminator
Interface that is responsible to stopping programs. Used while stop programs that are being deleted during re-deploy process.

Examples of co.cask.cdap.internal.app.deploy.ProgramTerminator

  public static Manager<Location, ApplicationWithPrograms> getLocalManager() {
    ManagerFactory<Location, ApplicationWithPrograms> factory =
      getInjector().getInstance(Key.get(new TypeLiteral<ManagerFactory<Location, ApplicationWithPrograms>>() {
      }));


    return factory.create(new ProgramTerminator() {
      @Override
      public void stop(Id.Account id, Id.Program programId, ProgramType type) throws Exception {
        //No-op
      }
    });

View Full Code Here

Examples of co.cask.cdap.internal.app.deploy.ProgramTerminator

  private void deploy(final String accountId, final String appId , Location archive) throws Exception {


    try {
      Id.Account id = Id.Account.from(accountId);
      Location archiveLocation = archive;
      Manager<Location, ApplicationWithPrograms> manager = managerFactory.create(new ProgramTerminator() {
        @Override
        public void stop(Id.Account id, Id.Program programId, ProgramType type) throws ExecutionException {
          deleteHandler(programId, type);
        }
      });

View Full Code Here

TOP

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.