Examples of org.apache.sqoop.repository.Repository

org.apache.sqoop.repository.Repository
Defines the contract of a Repository used by Sqoop. A Repository allows Sqoop to store metadata, statistics and other state relevant to Sqoop Jobs in the system.

    // 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);


    if(submission == null || !submission.getStatus().isRunning()) {
      throw new SqoopException(FrameworkError.FRAMEWORK_0003,
        "Job with id " + jobId + " is not running");
    }

View Full Code Here

    // Return updated structure
    return submission;
  }


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


    if(submission == null) {
      return new MSubmission(jobId, new Date(), SubmissionStatus.NEVER_EXECUTED);
    }

View Full Code Here

   */
  private JsonBean deleteConnection(RequestContext ctx) {
    String sxid = ctx.getLastURLElement();
    long xid = Long.valueOf(sxid);


    Repository repository = RepositoryManager.getInstance().getRepository();
    repository.deleteConnection(xid);


    return JsonBean.EMPTY_BEAN;
  }

View Full Code Here

  private JsonBean getConnections(RequestContext ctx) {
    String sxid = ctx.getLastURLElement();
    ConnectionBean bean;


    Locale locale = ctx.getAcceptLanguageHeader();
    Repository repository = RepositoryManager.getInstance().getRepository();


    if (sxid.equals("all")) {


      List<MConnection> connections = repository.findConnections();
      bean = new ConnectionBean(connections);


      // Add associated resources into the bean
      for( MConnection connection : connections) {
        long connectorId = connection.getConnectorId();
        if(!bean.hasConnectorBundle(connectorId)) {
          bean.addConnectorBundle(connectorId,
            ConnectorManager.getInstance().getResourceBundle(connectorId, locale));
        }
      }
    } else {
      long xid = Long.valueOf(sxid);


      MConnection connection = repository.findConnection(xid);
      long connectorId = connection.getConnectorId();


      bean = new ConnectionBean(connection);


      bean.addConnectorBundle(connectorId,

View Full Code Here

   */
  private JsonBean deleteJob(RequestContext ctx) {
    String sxid = ctx.getLastURLElement();
    long jid = Long.valueOf(sxid);


    Repository repository = RepositoryManager.getInstance().getRepository();
    repository.deleteJob(jid);


    return JsonBean.EMPTY_BEAN;
  }

View Full Code Here

  private JsonBean getJobs(RequestContext ctx) {
    String sjid = ctx.getLastURLElement();
    JobBean bean;


    Locale locale = ctx.getAcceptLanguageHeader();
    Repository repository = RepositoryManager.getInstance().getRepository();


    if (sjid.equals("all")) {


      List<MJob> jobs = repository.findJobs();
      bean = new JobBean(jobs);


      // Add associated resources into the bean
      for( MJob job : jobs) {
        long connectorId = job.getConnectorId();
        if(!bean.hasConnectorBundle(connectorId)) {
          bean.addConnectorBundle(connectorId,
            ConnectorManager.getInstance().getResourceBundle(connectorId, locale));
        }
      }
    } else {
      long jid = Long.valueOf(sjid);


      MJob job = repository.findJob(jid);
      long connectorId = job.getConnectorId();


      bean = new JobBean(job);


      bean.addConnectorBundle(connectorId,

View Full Code Here

0 1 2

TOP

Related Classes of org.apache.sqoop.repository.Repository

org.apache.sqoop.connector.ConnectorManager

org.apache.sqoop.connector.spi.MetadataUpgrader

org.apache.sqoop.connector.spi.SqoopConnector

org.apache.sqoop.framework.FrameworkManager

org.apache.sqoop.framework.JobManager

org.apache.sqoop.handler.ConnectionRequestHandler

org.apache.sqoop.handler.JobRequestHandler

org.apache.sqoop.model.MConnection

org.apache.sqoop.model.MConnectionForms

org.apache.sqoop.model.MJob

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.