THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Sqoop Repository API
Entity Related APIs
| Entity | API | Notes |
|---|---|---|
CONNECTOR | ||
DRIVER | ||
LINK | ||
JOB | ||
CONFIG | ||
| SUBMISSION |
Repository Upgrade related APIs
| Code Block |
|---|
/**
* Create or update the repository schema structures.
*
* This method will be called from the Sqoop server if enabled via a config
* {@link RepoConfigurationConstants#SYSCFG_REPO_SCHEMA_IMMUTABLE} to enforce
* changing the repository schema structure or explicitly via the
* {@link UpgradeTool} Repository should not change its schema structure
* outside of this method. This method must be no-op in case that the schema
* structure do not need any upgrade.
*/
public abstract void createOrUpgradeRepository();
/**
* Return true if internal repository structures exists and are suitable for use.
* This method should return false in case that the structures do exists, but
* are not suitable to use i.e corrupted as part of the upgrade
*
* @return Boolean values if internal structures are suitable for use
*/
public abstract boolean isRepositorySuitableForUse();
|
Configurable Upgrade related APIs
( NOTE: The following apis could have been its own independent API, but it exists in the repository since the configurables config/input objects reside in the repository )
Connector Upgrade API
upgradeConnector has a default implementation provided in the Repository.java | Code Block |
|---|
/**
* Upgrade the connector with the same {@linkplain MConnector#uniqueName}
* in the repository with values from <code>newConnector</code>.
* <p/>
* All links and jobs associated with this connector will be upgraded
* automatically.
*
* @param oldConnector The old connector that should be upgraded.
* @param newConnector New properties for the Connector that should be
* upgraded.
*/
public final void upgradeConnector(MConnector oldConnector, MConnector newConnector) {
..}
/**
* Update the connector with the new data supplied in the
* <tt>newConnector</tt>. Also Update all configs associated with this
* connector in the repository with the configs specified in
* <tt>mConnector</tt>. <tt>mConnector </tt> must
* minimally have the configurableID and all required configs (including ones
* which may not have changed). After this operation the repository is
* guaranteed to only have the new configs specified in this object.
*
* @param newConnector The new data to be inserted into the repository for
* this connector.
* @param tx The repository transaction to use to push the data to the
* repository. If this is null, a new transaction will be created.
* method will not call begin, commit,
* rollback or close on this transaction.
*/
public abstract void upgradeConnectorAndConfigs(MConnector newConnector, RepositoryTransaction tx);
|
Driver Upgrade API
upgradeDriver has a default implementation provided in the Repository.java | Code Block |
|---|
public final void upgradeDriver(MDriver driver) {
..}
/**
* Upgrade the driver with the new data supplied in the
* <tt>mDriver</tt>. Also Update all configs associated with the driver
* in the repository with the configs specified in
* <tt>mDriver</tt>. <tt>mDriver </tt> must
* minimally have the configurableID and all required configs (including ones
* which may not have changed). After this operation the repository is
* guaranteed to only have the new configs specified in this object.
*
* @param newDriver The new data to be inserted into the repository for
* the driverConfig.
* @param tx The repository transaction to use to push the data to the
* repository. If this is null, a new transaction will be created.
* method will not call begin, commit,
* rollback or close on this transaction.
*/
public abstract void upgradeDriverAndConfigs(MDriver newDriver, RepositoryTransaction tx); |
Sqoop Repository Concrete Implementations
...