Repository: sqoop Updated Branches: refs/heads/sqoop2 e41bc6e31 -> 89f737b2a
http://git-wip-us.apache.org/repos/asf/sqoop/blob/89f737b2/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Loader.java ---------------------------------------------------------------------- diff --git a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Loader.java b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Loader.java index e47b244..a085eca 100644 --- a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Loader.java +++ b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Loader.java @@ -17,9 +17,14 @@ */ package org.apache.sqoop.job.etl; +import org.apache.sqoop.classification.InterfaceAudience; +import org.apache.sqoop.classification.InterfaceStability; + /** * This allows connector to load data into a target system. */ [email protected] [email protected] public abstract class Loader<LinkConfiguration, ToJobConfiguration> { /** http://git-wip-us.apache.org/repos/asf/sqoop/blob/89f737b2/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partition.java ---------------------------------------------------------------------- diff --git a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partition.java b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partition.java index db07844..c4664a6 100644 --- a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partition.java +++ b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partition.java @@ -17,6 +17,9 @@ */ package org.apache.sqoop.job.etl; +import org.apache.sqoop.classification.InterfaceAudience; +import org.apache.sqoop.classification.InterfaceStability; + import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; @@ -24,6 +27,8 @@ import java.io.IOException; /** * A part of the input data partitioned by the Partitioner. */ [email protected] [email protected] public abstract class Partition { /** http://git-wip-us.apache.org/repos/asf/sqoop/blob/89f737b2/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partitioner.java ---------------------------------------------------------------------- diff --git a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partitioner.java b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partitioner.java index 3636130..067c509 100644 --- a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partitioner.java +++ b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Partitioner.java @@ -17,12 +17,17 @@ */ package org.apache.sqoop.job.etl; +import org.apache.sqoop.classification.InterfaceAudience; +import org.apache.sqoop.classification.InterfaceStability; + import java.util.List; /** * This allows connector to define how input data from the FROM source can be partitioned. * The number of data partitions also determines the degree of parallelism. */ [email protected] [email protected] public abstract class Partitioner<LinkConfiguration, FromJobConfiguration> { /** http://git-wip-us.apache.org/repos/asf/sqoop/blob/89f737b2/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/To.java ---------------------------------------------------------------------- diff --git a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/To.java b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/To.java index 64ba225..bbb6e41 100644 --- a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/To.java +++ b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/To.java @@ -17,6 +17,9 @@ */ package org.apache.sqoop.job.etl; +import org.apache.sqoop.classification.InterfaceAudience; +import org.apache.sqoop.classification.InterfaceStability; + /** * This specifies classes that perform connector-defined steps * within export execution: @@ -25,6 +28,8 @@ package org.apache.sqoop.job.etl; * -> Loader * -> Destroyer */ [email protected] [email protected] public class To extends Transferable { private Class<? extends Loader> loader; http://git-wip-us.apache.org/repos/asf/sqoop/blob/89f737b2/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Transferable.java ---------------------------------------------------------------------- diff --git a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Transferable.java b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Transferable.java index dfe1d5e..6410894 100644 --- a/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Transferable.java +++ b/connector/connector-sdk/src/main/java/org/apache/sqoop/job/etl/Transferable.java @@ -17,11 +17,16 @@ */ package org.apache.sqoop.job.etl; +import org.apache.sqoop.classification.InterfaceAudience; +import org.apache.sqoop.classification.InterfaceStability; + /** * This entity encapsulates the workflow for data transfer via the * {@link SqoopConnector}.It basically acts as an adapter between the data-source * imported from or exported to. */ [email protected] [email protected] public abstract class Transferable { private Class<? extends Initializer> initializer; http://git-wip-us.apache.org/repos/asf/sqoop/blob/89f737b2/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index 3297c00..66451e7 100644 --- a/pom.xml +++ b/pom.xml @@ -253,7 +253,6 @@ limitations under the License. <artifactId>hadoop-auth</artifactId> <version>${hadoop.2.version}</version> </dependency> - </dependencies> </dependencyManagement> </profile>
