Page History

CONNECTOR

public abstract MConnector registerConnector(MConnector mConnector, boolean autoUpgrade);
 
public abstract MConnector findConnector(String shortName);

public abstract List<MConnector> findConnectors();

READ ONLY APIs.

DRIVER

public abstract MDriver registerDriver(MDriver mDriverConfig, boolean autoUpgrade);

public abstract MDriver findDriver(String shortName);

LINK

public abstract void createLink(MLink link);

public abstract void updateLink(MLink link);

public abstract void updateLink(final MLink link, RepositoryTransaction tx);

public abstract void enableLink(long id, boolean enabled);

public abstract void deleteLink(long id);

public abstract MLink findLink(long id);
 
public abstract MLink findLink(String name);

public abstract List<MLink> findLinksForConnector(long connectorId);

public abstract List<MLink> findLinks();

JOB

public abstract void createJob(MJob job);

public abstract void updateJob(MJob job);

public abstract void updateJob(MJob job, RepositoryTransaction tx);

public abstract void enableJob(long id, boolean enabled);

public abstract void deleteJob(long id);

public abstract MJob findJob(long id);

public abstract MJob findJob(String name);

public abstract List<MJob> findJobs();

public abstract List<MJob> findJobsForConnector(long connectorId);

CONFIG

public abstract void deleteJobInputs(long jobId, RepositoryTransaction tx);

public abstract void deleteLinkInputs(long linkId, RepositoryTransaction tx);

No Public API for users yet

See SQOP-1516 for more details - 1.99.5 changes got Input RU

Input deletion can happen as part of the connector/driver upgrade path

public abstract void createSubmission(MSubmission submission);

public abstract void updateSubmission(MSubmission submission);

public abstract void purgeSubmissions(Date threshold);

public abstract List<MSubmission> findUnfinishedSubmissions();

public abstract List<MSubmission> findSubmissions();

public abstract List<MSubmission> findSubmissionsForJob(long jobId);

public abstract MSubmission findLastSubmissionForJob(long jobId);

CUD for internal sqoop use only

READ ONLY APIs for user