Examples of org.apache.sqoop.job.etl.Destroyer.destroy()

Class org.apache.sqoop.job.etl.Destroyer

Examples of org.apache.sqoop.job.etl.Destroyer.destroy()

org.apache.sqoop.job.etl.Destroyer.destroy()
Callback to clean up after job execution. @param success True if the execution was successfull @param context Connector context object @param connectionConfiguration Connection configuration object @param jobConfiguration Job configuration object

    Schema schema = ConfigurationUtils.getConnectorSchema(configuration);


    DestroyerContext destroyerContext = new DestroyerContext(subContext, success, schema);


    LOG.info("Executing destroyer class " + destroyer.getClass());
    destroyer.destroy(destroyerContext, configConnection, configJob);
  }


  private SqoopDestroyerExecutor() {
    // Instantiation is prohibited
  }

View Full Code Here

      throw  new SqoopException(FrameworkError.FRAMEWORK_0006,
        "Can't create destroyer instance: " + destroyerClass.getName());
    }


    // Initialize submission from connector perspective
    destroyer.destroy(false, request.getConnectorContext(),
      request.getConfigConnectorConnection(), request.getConfigConnectorJob());
  }


  public static MSubmission stop(long jobId) {
    Repository repository = RepositoryManager.getRepository();

View Full Code Here

    PrefixContext subContext = new PrefixContext(configuration, JobConstants.PREFIX_CONNECTOR_CONTEXT);
    Object configConnection = ConfigurationUtils.getConnectorConnection(configuration);
    Object configJob = ConfigurationUtils.getConnectorJob(configuration);


    LOG.info("Executing destroyer class " + destroyer.getClass());
    destroyer.destroy(success, subContext, configConnection, configJob);
  }


  private SqoopDestroyerExecutor() {
    // Instantiation is prohibited
  }

View Full Code Here

    Object configJob = ConfigurationUtils.getConnectorJob(configuration);


    DestroyerContext destroyerContext = new DestroyerContext(subContext, success);


    LOG.info("Executing destroyer class " + destroyer.getClass());
    destroyer.destroy(destroyerContext, configConnection, configJob);
  }


  private SqoopDestroyerExecutor() {
    // Instantiation is prohibited
  }

View Full Code Here

    }


    DestroyerContext destroyerContext = new DestroyerContext(request.getConnectorContext(), false);


    // Initialize submission from connector perspective
    destroyer.destroy(destroyerContext, request.getConfigConnectorConnection(), request.getConfigConnectorJob());
  }


  public MSubmission stop(long jobId) {
    Repository repository = RepositoryManager.getInstance().getRepository();
    MSubmission submission = repository.findSubmissionLastForJob(jobId);

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.