Move org.apache.hadoop.sqoop to com.cloudera.sqoop
authorAndrew Bayer <abayer@apache.org>
Fri, 22 Jul 2011 20:03:52 +0000 (20:03 +0000)
committerAndrew Bayer <abayer@apache.org>
Fri, 22 Jul 2011 20:03:52 +0000 (20:03 +0000)
From: Aaron Kimball <aaron@cloudera.com>

git-svn-id: https://svn.apache.org/repos/asf/incubator/sqoop/trunk@1149906 13f79535-47bb-0310-9956-ffa450edef68

157 files changed:
bin/sqoop
build.xml
conf/sqoop-default.xml
src/docs/dev/api-reference.txt
src/java/com/cloudera/sqoop/ConnFactory.java [moved from src/java/org/apache/hadoop/sqoop/ConnFactory.java with 94% similarity]
src/java/com/cloudera/sqoop/Sqoop.java [moved from src/java/org/apache/hadoop/sqoop/Sqoop.java with 96% similarity]
src/java/com/cloudera/sqoop/SqoopOptions.java [moved from src/java/org/apache/hadoop/sqoop/SqoopOptions.java with 99% similarity]
src/java/com/cloudera/sqoop/cli/RelatedOptions.java [moved from src/java/org/apache/hadoop/sqoop/cli/RelatedOptions.java with 97% similarity]
src/java/com/cloudera/sqoop/cli/SqoopParser.java [moved from src/java/org/apache/hadoop/sqoop/cli/SqoopParser.java with 99% similarity]
src/java/com/cloudera/sqoop/cli/ToolOptions.java [moved from src/java/org/apache/hadoop/sqoop/cli/ToolOptions.java with 99% similarity]
src/java/com/cloudera/sqoop/hive/HiveImport.java [moved from src/java/org/apache/hadoop/sqoop/hive/HiveImport.java with 97% similarity]
src/java/com/cloudera/sqoop/hive/HiveTypes.java [moved from src/java/org/apache/hadoop/sqoop/hive/HiveTypes.java with 98% similarity]
src/java/com/cloudera/sqoop/hive/TableDefWriter.java [moved from src/java/org/apache/hadoop/sqoop/hive/TableDefWriter.java with 98% similarity]
src/java/com/cloudera/sqoop/io/CodecMap.java [moved from src/java/org/apache/hadoop/sqoop/io/CodecMap.java with 98% similarity]
src/java/com/cloudera/sqoop/io/FixedLengthInputStream.java [moved from src/java/org/apache/hadoop/sqoop/io/FixedLengthInputStream.java with 98% similarity]
src/java/com/cloudera/sqoop/io/LobFile.java [moved from src/java/org/apache/hadoop/sqoop/io/LobFile.java with 99% similarity]
src/java/com/cloudera/sqoop/io/LobReaderCache.java [moved from src/java/org/apache/hadoop/sqoop/io/LobReaderCache.java with 99% similarity]
src/java/com/cloudera/sqoop/io/SplittableBufferedWriter.java [moved from src/java/org/apache/hadoop/sqoop/io/SplittableBufferedWriter.java with 98% similarity]
src/java/com/cloudera/sqoop/io/SplittingOutputStream.java [moved from src/java/org/apache/hadoop/sqoop/io/SplittingOutputStream.java with 99% similarity]
src/java/com/cloudera/sqoop/io/UnsupportedCodecException.java [moved from src/java/org/apache/hadoop/sqoop/io/UnsupportedCodecException.java with 97% similarity]
src/java/com/cloudera/sqoop/lib/BigDecimalSerializer.java [moved from src/java/org/apache/hadoop/sqoop/lib/BigDecimalSerializer.java with 98% similarity]
src/java/com/cloudera/sqoop/lib/BlobRef.java [moved from src/java/org/apache/hadoop/sqoop/lib/BlobRef.java with 98% similarity]
src/java/com/cloudera/sqoop/lib/ClobRef.java [moved from src/java/org/apache/hadoop/sqoop/lib/ClobRef.java with 97% similarity]
src/java/com/cloudera/sqoop/lib/FieldFormatter.java [moved from src/java/org/apache/hadoop/sqoop/lib/FieldFormatter.java with 98% similarity]
src/java/com/cloudera/sqoop/lib/JdbcWritableBridge.java [moved from src/java/org/apache/hadoop/sqoop/lib/JdbcWritableBridge.java with 99% similarity]
src/java/com/cloudera/sqoop/lib/LargeObjectLoader.java [moved from src/java/org/apache/hadoop/sqoop/lib/LargeObjectLoader.java with 99% similarity]
src/java/com/cloudera/sqoop/lib/LobRef.java [moved from src/java/org/apache/hadoop/sqoop/lib/LobRef.java with 98% similarity]
src/java/com/cloudera/sqoop/lib/LobSerializer.java [moved from src/java/org/apache/hadoop/sqoop/lib/LobSerializer.java with 97% similarity]
src/java/com/cloudera/sqoop/lib/RecordParser.java [moved from src/java/org/apache/hadoop/sqoop/lib/RecordParser.java with 99% similarity]
src/java/com/cloudera/sqoop/lib/SqoopRecord.java [moved from src/java/org/apache/hadoop/sqoop/lib/SqoopRecord.java with 98% similarity]
src/java/com/cloudera/sqoop/lib/TaskId.java [moved from src/java/org/apache/hadoop/sqoop/lib/TaskId.java with 97% similarity]
src/java/com/cloudera/sqoop/manager/ConnManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/ConnManager.java with 97% similarity]
src/java/com/cloudera/sqoop/manager/DefaultManagerFactory.java [moved from src/java/org/apache/hadoop/sqoop/manager/DefaultManagerFactory.java with 97% similarity]
src/java/com/cloudera/sqoop/manager/DirectMySQLManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/DirectMySQLManager.java with 91% similarity]
src/java/com/cloudera/sqoop/manager/DirectPostgresqlManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/DirectPostgresqlManager.java with 95% similarity]
src/java/com/cloudera/sqoop/manager/ExportJobContext.java [moved from src/java/org/apache/hadoop/sqoop/manager/ExportJobContext.java with 94% similarity]
src/java/com/cloudera/sqoop/manager/GenericJdbcManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/GenericJdbcManager.java with 96% similarity]
src/java/com/cloudera/sqoop/manager/HsqldbManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/HsqldbManager.java with 95% similarity]
src/java/com/cloudera/sqoop/manager/ImportJobContext.java [moved from src/java/org/apache/hadoop/sqoop/manager/ImportJobContext.java with 96% similarity]
src/java/com/cloudera/sqoop/manager/ManagerFactory.java [moved from src/java/org/apache/hadoop/sqoop/manager/ManagerFactory.java with 93% similarity]
src/java/com/cloudera/sqoop/manager/MySQLManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/MySQLManager.java with 98% similarity]
src/java/com/cloudera/sqoop/manager/MySQLUtils.java [moved from src/java/org/apache/hadoop/sqoop/manager/MySQLUtils.java with 96% similarity]
src/java/com/cloudera/sqoop/manager/OracleManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/OracleManager.java with 97% similarity]
src/java/com/cloudera/sqoop/manager/PostgresqlManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/PostgresqlManager.java with 97% similarity]
src/java/com/cloudera/sqoop/manager/SqlManager.java [moved from src/java/org/apache/hadoop/sqoop/manager/SqlManager.java with 96% similarity]
src/java/com/cloudera/sqoop/mapreduce/AutoProgressMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/AutoProgressMapper.java with 99% similarity]
src/java/com/cloudera/sqoop/mapreduce/DataDrivenImportJob.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/DataDrivenImportJob.java with 92% similarity]
src/java/com/cloudera/sqoop/mapreduce/ExportJobBase.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/ExportJobBase.java with 93% similarity]
src/java/com/cloudera/sqoop/mapreduce/ImportJobBase.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/ImportJobBase.java with 94% similarity]
src/java/com/cloudera/sqoop/mapreduce/JdbcExportJob.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/JdbcExportJob.java with 94% similarity]
src/java/com/cloudera/sqoop/mapreduce/JobBase.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/JobBase.java with 97% similarity]
src/java/com/cloudera/sqoop/mapreduce/MySQLDumpImportJob.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/MySQLDumpImportJob.java with 91% similarity]
src/java/com/cloudera/sqoop/mapreduce/MySQLDumpMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/MySQLDumpMapper.java with 97% similarity]
src/java/com/cloudera/sqoop/mapreduce/MySQLExportJob.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/MySQLExportJob.java with 94% similarity]
src/java/com/cloudera/sqoop/mapreduce/MySQLExportMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/MySQLExportMapper.java with 97% similarity]
src/java/com/cloudera/sqoop/mapreduce/MySQLRecordExportMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/MySQLRecordExportMapper.java with 94% similarity]
src/java/com/cloudera/sqoop/mapreduce/MySQLTextExportMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/MySQLTextExportMapper.java with 95% similarity]
src/java/com/cloudera/sqoop/mapreduce/SequenceFileExportMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/SequenceFileExportMapper.java with 94% similarity]
src/java/com/cloudera/sqoop/mapreduce/SequenceFileImportMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/SequenceFileImportMapper.java with 93% similarity]
src/java/com/cloudera/sqoop/mapreduce/TextExportMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/TextExportMapper.java with 95% similarity]
src/java/com/cloudera/sqoop/mapreduce/TextImportMapper.java [moved from src/java/org/apache/hadoop/sqoop/mapreduce/TextImportMapper.java with 93% similarity]
src/java/com/cloudera/sqoop/orm/ClassWriter.java [moved from src/java/org/apache/hadoop/sqoop/orm/ClassWriter.java with 98% similarity]
src/java/com/cloudera/sqoop/orm/CompilationManager.java [moved from src/java/org/apache/hadoop/sqoop/orm/CompilationManager.java with 98% similarity]
src/java/com/cloudera/sqoop/orm/TableClassName.java [moved from src/java/org/apache/hadoop/sqoop/orm/TableClassName.java with 97% similarity]
src/java/com/cloudera/sqoop/shims/HadoopShim.java [moved from src/java/org/apache/hadoop/sqoop/shims/HadoopShim.java with 99% similarity]
src/java/com/cloudera/sqoop/shims/ShimLoader.java [moved from src/java/org/apache/hadoop/sqoop/shims/ShimLoader.java with 95% similarity]
src/java/com/cloudera/sqoop/tool/BaseSqoopTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/BaseSqoopTool.java with 98% similarity]
src/java/com/cloudera/sqoop/tool/CodeGenTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/CodeGenTool.java with 92% similarity]
src/java/com/cloudera/sqoop/tool/CreateHiveTableTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/CreateHiveTableTool.java with 91% similarity]
src/java/com/cloudera/sqoop/tool/EvalSqlTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/EvalSqlTool.java with 91% similarity]
src/java/com/cloudera/sqoop/tool/ExportTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/ExportTool.java with 94% similarity]
src/java/com/cloudera/sqoop/tool/HelpTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/HelpTool.java with 95% similarity]
src/java/com/cloudera/sqoop/tool/ImportAllTablesTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/ImportAllTablesTool.java with 91% similarity]
src/java/com/cloudera/sqoop/tool/ImportTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/ImportTool.java with 96% similarity]
src/java/com/cloudera/sqoop/tool/ListDatabasesTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/ListDatabasesTool.java with 92% similarity]
src/java/com/cloudera/sqoop/tool/ListTablesTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/ListTablesTool.java with 92% similarity]
src/java/com/cloudera/sqoop/tool/SqoopTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/SqoopTool.java with 96% similarity]
src/java/com/cloudera/sqoop/tool/VersionTool.java [moved from src/java/org/apache/hadoop/sqoop/tool/VersionTool.java with 87% similarity]
src/java/com/cloudera/sqoop/util/AsyncSink.java [moved from src/java/org/apache/hadoop/sqoop/util/AsyncSink.java with 97% similarity]
src/java/com/cloudera/sqoop/util/ClassLoaderStack.java [moved from src/java/org/apache/hadoop/sqoop/util/ClassLoaderStack.java with 98% similarity]
src/java/com/cloudera/sqoop/util/DirectImportUtils.java [moved from src/java/org/apache/hadoop/sqoop/util/DirectImportUtils.java with 94% similarity]
src/java/com/cloudera/sqoop/util/ErrorableAsyncSink.java [moved from src/java/org/apache/hadoop/sqoop/util/ErrorableAsyncSink.java with 96% similarity]
src/java/com/cloudera/sqoop/util/ErrorableThread.java [moved from src/java/org/apache/hadoop/sqoop/util/ErrorableThread.java with 96% similarity]
src/java/com/cloudera/sqoop/util/Executor.java [moved from src/java/org/apache/hadoop/sqoop/util/Executor.java with 98% similarity]
src/java/com/cloudera/sqoop/util/ExportException.java [moved from src/java/org/apache/hadoop/sqoop/util/ExportException.java with 97% similarity]
src/java/com/cloudera/sqoop/util/FileListing.java [moved from src/java/org/apache/hadoop/sqoop/util/FileListing.java with 99% similarity]
src/java/com/cloudera/sqoop/util/ImportException.java [moved from src/java/org/apache/hadoop/sqoop/util/ImportException.java with 97% similarity]
src/java/com/cloudera/sqoop/util/JdbcUrl.java [moved from src/java/org/apache/hadoop/sqoop/util/JdbcUrl.java with 99% similarity]
src/java/com/cloudera/sqoop/util/LoggingAsyncSink.java [moved from src/java/org/apache/hadoop/sqoop/util/LoggingAsyncSink.java with 98% similarity]
src/java/com/cloudera/sqoop/util/NullAsyncSink.java [moved from src/java/org/apache/hadoop/sqoop/util/NullAsyncSink.java with 98% similarity]
src/java/com/cloudera/sqoop/util/PerfCounters.java [moved from src/java/org/apache/hadoop/sqoop/util/PerfCounters.java with 98% similarity]
src/java/com/cloudera/sqoop/util/ResultSetPrinter.java [moved from src/java/org/apache/hadoop/sqoop/util/ResultSetPrinter.java with 98% similarity]
src/perftest/ExportStressTest.java
src/perftest/LobFilePerfTest.java
src/perftest/LobFileStressTest.java
src/scripts/write-version-info.sh
src/shims/apache/com/cloudera/sqoop/shims/Apache22HadoopShim.java [moved from src/shims/apache/org/apache/hadoop/sqoop/shims/Apache22HadoopShim.java with 98% similarity]
src/shims/cloudera/com/cloudera/sqoop/shims/CDH3Shim.java [moved from src/shims/cloudera/org/apache/hadoop/sqoop/shims/CDH3Shim.java with 98% similarity]
src/shims/common/com/cloudera/sqoop/mapreduce/CombineShimRecordReader.java [moved from src/shims/common/org/apache/hadoop/sqoop/mapreduce/CombineShimRecordReader.java with 98% similarity]
src/shims/common/com/cloudera/sqoop/mapreduce/ExportInputFormat.java [moved from src/shims/common/org/apache/hadoop/sqoop/mapreduce/ExportInputFormat.java with 98% similarity]
src/shims/common/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java [moved from src/shims/common/org/apache/hadoop/sqoop/mapreduce/ExportOutputFormat.java with 99% similarity]
src/shims/common/com/cloudera/sqoop/mapreduce/MySQLDumpInputFormat.java [moved from src/shims/common/org/apache/hadoop/sqoop/mapreduce/MySQLDumpInputFormat.java with 98% similarity]
src/shims/common/com/cloudera/sqoop/mapreduce/OracleExportOutputFormat.java [moved from src/shims/common/org/apache/hadoop/sqoop/mapreduce/OracleExportOutputFormat.java with 97% similarity]
src/shims/common/com/cloudera/sqoop/mapreduce/RawKeyTextOutputFormat.java [moved from src/shims/common/org/apache/hadoop/sqoop/mapreduce/RawKeyTextOutputFormat.java with 98% similarity]
src/shims/common/com/cloudera/sqoop/shims/CommonHadoopShim.java [moved from src/shims/common/org/apache/hadoop/sqoop/shims/CommonHadoopShim.java with 98% similarity]
src/test/com/cloudera/sqoop/AllTests.java [moved from src/test/org/apache/hadoop/sqoop/AllTests.java with 86% similarity]
src/test/com/cloudera/sqoop/SmokeTests.java [moved from src/test/org/apache/hadoop/sqoop/SmokeTests.java with 68% similarity]
src/test/com/cloudera/sqoop/TestAllTables.java [moved from src/test/org/apache/hadoop/sqoop/TestAllTables.java with 93% similarity]
src/test/com/cloudera/sqoop/TestColumnTypes.java [moved from src/test/org/apache/hadoop/sqoop/TestColumnTypes.java with 95% similarity]
src/test/com/cloudera/sqoop/TestConnFactory.java [moved from src/test/org/apache/hadoop/sqoop/TestConnFactory.java with 95% similarity]
src/test/com/cloudera/sqoop/TestExport.java [moved from src/test/org/apache/hadoop/sqoop/TestExport.java with 98% similarity]
src/test/com/cloudera/sqoop/TestMultiCols.java [moved from src/test/org/apache/hadoop/sqoop/TestMultiCols.java with 98% similarity]
src/test/com/cloudera/sqoop/TestMultiMaps.java [moved from src/test/org/apache/hadoop/sqoop/TestMultiMaps.java with 92% similarity]
src/test/com/cloudera/sqoop/TestSplitBy.java [moved from src/test/org/apache/hadoop/sqoop/TestSplitBy.java with 91% similarity]
src/test/com/cloudera/sqoop/TestSqoopOptions.java [moved from src/test/org/apache/hadoop/sqoop/TestSqoopOptions.java with 98% similarity]
src/test/com/cloudera/sqoop/TestWhere.java [moved from src/test/org/apache/hadoop/sqoop/TestWhere.java with 92% similarity]
src/test/com/cloudera/sqoop/ThirdPartyTests.java [moved from src/test/org/apache/hadoop/sqoop/ThirdPartyTests.java with 77% similarity]
src/test/com/cloudera/sqoop/hive/TestHiveImport.java [moved from src/test/org/apache/hadoop/sqoop/hive/TestHiveImport.java with 95% similarity]
src/test/com/cloudera/sqoop/hive/TestTableDefWriter.java [moved from src/test/org/apache/hadoop/sqoop/hive/TestTableDefWriter.java with 97% similarity]
src/test/com/cloudera/sqoop/io/TestLobFile.java [moved from src/test/org/apache/hadoop/sqoop/io/TestLobFile.java with 99% similarity]
src/test/com/cloudera/sqoop/io/TestSplittableBufferedWriter.java [moved from src/test/org/apache/hadoop/sqoop/io/TestSplittableBufferedWriter.java with 98% similarity]
src/test/com/cloudera/sqoop/lib/TestBlobRef.java [moved from src/test/org/apache/hadoop/sqoop/lib/TestBlobRef.java with 98% similarity]
src/test/com/cloudera/sqoop/lib/TestClobRef.java [moved from src/test/org/apache/hadoop/sqoop/lib/TestClobRef.java with 98% similarity]
src/test/com/cloudera/sqoop/lib/TestFieldFormatter.java [moved from src/test/org/apache/hadoop/sqoop/lib/TestFieldFormatter.java with 99% similarity]
src/test/com/cloudera/sqoop/lib/TestLargeObjectLoader.java [moved from src/test/org/apache/hadoop/sqoop/lib/TestLargeObjectLoader.java with 96% similarity]
src/test/com/cloudera/sqoop/lib/TestRecordParser.java [moved from src/test/org/apache/hadoop/sqoop/lib/TestRecordParser.java with 99% similarity]
src/test/com/cloudera/sqoop/manager/DirectMySQLExportTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/DirectMySQLExportTest.java with 95% similarity]
src/test/com/cloudera/sqoop/manager/DirectMySQLTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/DirectMySQLTest.java with 98% similarity]
src/test/com/cloudera/sqoop/manager/JdbcMySQLExportTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/JdbcMySQLExportTest.java with 96% similarity]
src/test/com/cloudera/sqoop/manager/MySQLAuthTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/MySQLAuthTest.java with 98% similarity]
src/test/com/cloudera/sqoop/manager/MySQLCompatTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/MySQLCompatTest.java with 97% similarity]
src/test/com/cloudera/sqoop/manager/MySQLTestUtils.java [moved from src/test/org/apache/hadoop/sqoop/manager/MySQLTestUtils.java with 98% similarity]
src/test/com/cloudera/sqoop/manager/OracleCompatTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/OracleCompatTest.java with 97% similarity]
src/test/com/cloudera/sqoop/manager/OracleExportTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/OracleExportTest.java with 97% similarity]
src/test/com/cloudera/sqoop/manager/OracleManagerTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/OracleManagerTest.java with 98% similarity]
src/test/com/cloudera/sqoop/manager/OracleUtils.java [moved from src/test/org/apache/hadoop/sqoop/manager/OracleUtils.java with 96% similarity]
src/test/com/cloudera/sqoop/manager/PostgresqlTest.java [moved from src/test/org/apache/hadoop/sqoop/manager/PostgresqlTest.java with 96% similarity]
src/test/com/cloudera/sqoop/manager/TestHsqldbManager.java [moved from src/test/org/apache/hadoop/sqoop/manager/TestHsqldbManager.java with 96% similarity]
src/test/com/cloudera/sqoop/manager/TestSqlManager.java [moved from src/test/org/apache/hadoop/sqoop/manager/TestSqlManager.java with 98% similarity]
src/test/com/cloudera/sqoop/mapreduce/MapreduceTests.java [moved from src/test/org/apache/hadoop/sqoop/mapreduce/MapreduceTests.java with 85% similarity]
src/test/com/cloudera/sqoop/mapreduce/TestImportJob.java [moved from src/test/org/apache/hadoop/sqoop/mapreduce/TestImportJob.java with 92% similarity]
src/test/com/cloudera/sqoop/orm/TestClassWriter.java [moved from src/test/org/apache/hadoop/sqoop/orm/TestClassWriter.java with 96% similarity]
src/test/com/cloudera/sqoop/orm/TestParseMethods.java [moved from src/test/org/apache/hadoop/sqoop/orm/TestParseMethods.java with 91% similarity]
src/test/com/cloudera/sqoop/testutil/BaseSqoopTestCase.java [moved from src/test/org/apache/hadoop/sqoop/testutil/BaseSqoopTestCase.java with 98% similarity]
src/test/com/cloudera/sqoop/testutil/CommonArgs.java [moved from src/test/org/apache/hadoop/sqoop/testutil/CommonArgs.java with 97% similarity]
src/test/com/cloudera/sqoop/testutil/DirUtil.java [moved from src/test/org/apache/hadoop/sqoop/testutil/DirUtil.java with 97% similarity]
src/test/com/cloudera/sqoop/testutil/ExportJobTestCase.java [moved from src/test/org/apache/hadoop/sqoop/testutil/ExportJobTestCase.java with 97% similarity]
src/test/com/cloudera/sqoop/testutil/HsqldbTestServer.java [moved from src/test/org/apache/hadoop/sqoop/testutil/HsqldbTestServer.java with 97% similarity]
src/test/com/cloudera/sqoop/testutil/ImportJobTestCase.java [moved from src/test/org/apache/hadoop/sqoop/testutil/ImportJobTestCase.java with 94% similarity]
src/test/com/cloudera/sqoop/testutil/InjectableConnManager.java [moved from src/test/org/apache/hadoop/sqoop/testutil/InjectableConnManager.java with 91% similarity]
src/test/com/cloudera/sqoop/testutil/InjectableManagerFactory.java [moved from src/test/org/apache/hadoop/sqoop/testutil/InjectableManagerFactory.java with 85% similarity]
src/test/com/cloudera/sqoop/testutil/ManagerCompatTestCase.java [moved from src/test/org/apache/hadoop/sqoop/testutil/ManagerCompatTestCase.java with 99% similarity]
src/test/com/cloudera/sqoop/testutil/MockResultSet.java [moved from src/test/org/apache/hadoop/sqoop/testutil/MockResultSet.java with 99% similarity]
src/test/com/cloudera/sqoop/testutil/ReparseMapper.java [moved from src/test/org/apache/hadoop/sqoop/testutil/ReparseMapper.java with 96% similarity]
src/test/com/cloudera/sqoop/testutil/SeqFileReader.java [moved from src/test/org/apache/hadoop/sqoop/testutil/SeqFileReader.java with 98% similarity]
src/test/com/cloudera/sqoop/util/TestDirectImportUtils.java [moved from src/test/org/apache/hadoop/sqoop/util/TestDirectImportUtils.java with 98% similarity]
src/test/findbugsExcludeFile.xml

index 8a8f011..d374d91 100755 (executable)
--- a/bin/sqoop
+++ b/bin/sqoop
@@ -21,4 +21,4 @@ bin=`cd ${bin} && pwd`
 
 source ${bin}/configure-sqoop
 ${HADOOP_HOME}/bin/hadoop jar ${SQOOP_JAR} \
-    org.apache.hadoop.sqoop.Sqoop "$@"
+    com.cloudera.sqoop.Sqoop "$@"
index cc512a9..f1e2989 100644 (file)
--- a/build.xml
+++ b/build.xml
       <arg value="+%Y" />
     </exec>
     <javadoc
-      packagenames="org.apache.hadoop.sqoop.*"
+      packagenames="com.cloudera.sqoop.*"
       destdir="${build.javadoc}"
       author="true"
       version="true"
index 444a90b..5355acd 100644 (file)
@@ -23,7 +23,7 @@
 
   <property>
     <name>sqoop.connection.factories</name>
-    <value>org.apache.hadoop.sqoop.manager.DefaultManagerFactory</value>
+    <value>com.cloudera.sqoop.manager.DefaultManagerFactory</value>
     <description>A comma-delimited list of ManagerFactory implementations
       which are consulted, in order, to instantiate ConnManager instances
       used to drive connections to databases.
index aef9a1c..8dfbf6e 100644 (file)
@@ -48,10 +48,10 @@ convenience methods:
 
 The full set of methods guaranteed to exist in an auto-generated class
 is specified in the abstract class
-+org.apache.hadoop.sqoop.lib.SqoopRecord+.
++com.cloudera.sqoop.lib.SqoopRecord+.
 
 Instances of +SqoopRecord+ may depend on Sqoop's public API. This is all classes
-in the +org.apache.hadoop.sqoop.lib+ package. These are briefly described below.
+in the +com.cloudera.sqoop.lib+ package. These are briefly described below.
 Clients of Sqoop should not need to directly interact with any of these classes,
 although classes generated by Sqoop will depend on them. Therefore, these APIs
 are considered public and care will be taken when forward-evolving them.
@@ -81,11 +81,11 @@ While Sqoop uses JDBC and +DataDrivenDBInputFormat+ to
 read from databases, differences in the SQL supported by different vendors as
 well as JDBC metadata necessitates vendor-specific codepaths for most databases.
 Sqoop's solution to this problem is by introducing the +ConnManager+ API
-(+org.apache.hadoop.sqoop.manager.ConnMananger+).
+(+com.cloudera.sqoop.manager.ConnMananger+).
 
 +ConnManager+ is an abstract class defining all methods that interact with the
 database itself. Most implementations of +ConnManager+ will extend the
-+org.apache.hadoop.sqoop.manager.SqlManager+ abstract class, which uses standard
++com.cloudera.sqoop.manager.SqlManager+ abstract class, which uses standard
 SQL to perform most actions. Subclasses are required to implement the
 +getConnection()+ method which returns the actual JDBC connection to the
 database. Subclasses are free to override all other methods as well. The
@@ -117,7 +117,7 @@ lightweight operation, and is done reasonably infrequently. Therefore,
 class +ManagerFactory+ (See
 http://issues.apache.org/jira/browse/MAPREDUCE-750[]). One
 +ManagerFactory+ implementation currently serves all of Sqoop:
-+org.apache.hadoop.sqoop.manager.DefaultManagerFactory+.  Extensions
++com.cloudera.sqoop.manager.DefaultManagerFactory+.  Extensions
 should not modify +DefaultManagerFactory+. Instead, an
 extension-specific +ManagerFactory+ implementation should be provided
 with the new +ConnManager+.  +ManagerFactory+ has a single method of
@@ -132,7 +132,7 @@ and +ConnManager+(s), and configure +sqoop-site.xml+ to use the new
 +ManagerFactory+.  The +DefaultManagerFactory+ principly discriminates between
 databases by parsing the connect string stored in +SqoopOptions+.
 
-Extension authors may make use of classes in the +org.apache.hadoop.sqoop.io+,
+Extension authors may make use of classes in the +com.cloudera.sqoop.io+,
 +mapreduce+, and +util+ packages to facilitate their implementations.
 These packages and classes are described in more detail in the following
 section.
@@ -143,7 +143,7 @@ Sqoop Internals
 
 This section describes the internal architecture of Sqoop.
 
-The Sqoop program is driven by the +org.apache.hadoop.sqoop.Sqoop+ main class.
+The Sqoop program is driven by the +com.cloudera.sqoop.Sqoop+ main class.
 A limited number of additional classes are in the same package; +SqoopOptions+
 (described earlier) and +ConnFactory+ (which manipulates +ManagerFactory+
 instances).
@@ -153,7 +153,7 @@ General program flow
 
 The general program flow is as follows:
 
-+org.apache.hadoop.sqoop.Sqoop+ is the main class and implements _Tool_. A new
++com.cloudera.sqoop.Sqoop+ is the main class and implements _Tool_. A new
 instance is launched with +ToolRunner+. The first argument to Sqoop is
 a string identifying the name of a +SqoopTool+ to run. The +SqoopTool+
 itself drives the execution of the user's requested operation (e.g.,
@@ -178,8 +178,8 @@ the +ConnManager.importTable()+ method is left to determine how best
 to run the import. Each main action is actually controlled by the
 +ConnMananger+, except for the generating of code, which is done by
 the +CompilationManager+ and +ClassWriter+. (Both in the
-+org.apache.hadoop.sqoop.orm+ package.) Importing into Hive is also
-taken care of via the +org.apache.hadoop.sqoop.hive.HiveImport+ class
++com.cloudera.sqoop.orm+ package.) Importing into Hive is also
+taken care of via the +com.cloudera.sqoop.hive.HiveImport+ class
 after the +importTable()+ has completed. This is done without concern
 for the +ConnManager+ implementation used.
 
@@ -195,7 +195,7 @@ related data.
 Subpackages
 ^^^^^^^^^^^
 
-The following subpackages under +org.apache.hadoop.sqoop+ exist:
+The following subpackages under +com.cloudera.sqoop+ exist:
 
 * +hive+ - Facilitates importing data to Hive.
 * +io+ - Implementations of +java.io.*+ interfaces (namely, _OutputStream_ and
@@ -252,7 +252,7 @@ more. Consequently, these must both be handled, and preferably asynchronously.
 
 In Sqoop parlance, an "async sink" is a thread that takes an +InputStream+ and
 reads it to completion. These are realized by +AsyncSink+ implementations. The
-+org.apache.hadoop.sqoop.util.AsyncSink+ abstract class defines the operations
++com.cloudera.sqoop.util.AsyncSink+ abstract class defines the operations
 this factory must perform. +processStream()+ will spawn another thread to
 immediately begin handling the data read from the +InputStream+ argument; it
 must read this stream to completion. The +join()+ method allows external threads
@@ -275,7 +275,7 @@ Sqoop schedules MapReduce jobs to effect imports and exports.
 Configuration and execution of MapReduce jobs follows a few common
 steps (configuring the +InputFormat+; configuring the +OutputFormat+;
 setting the +Mapper+ implementation; etc...). These steps are
-formalized in the +org.apache.hadoop.sqoop.mapreduce.JobBase+ class.
+formalized in the +com.cloudera.sqoop.mapreduce.JobBase+ class.
 The +JobBase+ allows a user to specify the +InputFormat+,
 +OutputFormat+, and +Mapper+ to use. 
 
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.manager.DefaultManagerFactory;
-import org.apache.hadoop.sqoop.manager.ManagerFactory;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.manager.DefaultManagerFactory;
+import com.cloudera.sqoop.manager.ManagerFactory;
 import org.apache.hadoop.util.ReflectionUtils;
 
 import java.io.IOException;
similarity index 96%
rename from src/java/org/apache/hadoop/sqoop/Sqoop.java
rename to src/java/com/cloudera/sqoop/Sqoop.java
index 653a253..83521db 100644 (file)
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import java.util.Arrays;
 
@@ -28,12 +28,12 @@ import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.util.Tool;
 import org.apache.hadoop.util.ToolRunner;
 
-import org.apache.hadoop.sqoop.tool.HelpTool;
-import org.apache.hadoop.sqoop.tool.SqoopTool;
+import com.cloudera.sqoop.tool.HelpTool;
+import com.cloudera.sqoop.tool.SqoopTool;
 
 /**
  * Main entry-point for Sqoop
- * Usage: hadoop jar (this_jar_name) org.apache.hadoop.sqoop.Sqoop (options)
+ * Usage: hadoop jar (this_jar_name) com.cloudera.sqoop.Sqoop (options)
  * See the SqoopOptions class for options.
  */
 public class Sqoop extends Configured implements Tool {
@@ -17,7 +17,7 @@
  */
 
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import java.io.File;
 import java.io.FileInputStream;
@@ -29,7 +29,7 @@ import java.util.Properties;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.lib.LargeObjectLoader;
+import com.cloudera.sqoop.lib.LargeObjectLoader;
 
 /**
  * Command-line arguments used by Sqoop.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.cli;
+package com.cloudera.sqoop.cli;
 
 import org.apache.commons.cli.Options;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.cli;
+package com.cloudera.sqoop.cli;
 
 import java.util.ListIterator;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.cli;
+package com.cloudera.sqoop.cli;
 
 import java.io.PrintWriter;
 import java.io.StringWriter;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.hive;
+package com.cloudera.sqoop.hive;
 
 import java.io.BufferedWriter;
 import java.io.File;
@@ -32,10 +32,10 @@ import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.util.Executor;
-import org.apache.hadoop.sqoop.util.LoggingAsyncSink;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.util.Executor;
+import com.cloudera.sqoop.util.LoggingAsyncSink;
 
 /**
  * Utility to import a table into the Hive metastore. Manages the connection
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.hive;
+package com.cloudera.sqoop.hive;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.hive;
+package com.cloudera.sqoop.hive;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
 
 import java.io.File;
 import java.io.IOException;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.util.Map;
 import java.util.Set;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.io.InputStream;
 import java.io.IOException;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.io.BufferedOutputStream;
 import java.io.Closeable;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.io.IOException;
 import java.util.Map;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.io.BufferedWriter;
 import java.io.OutputStreamWriter;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.io.OutputStream;
 import java.io.IOException;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.ByteArrayInputStream;
 import java.io.DataInput;
@@ -27,7 +27,7 @@ import java.util.Arrays;
 import java.util.regex.Matcher;
 
 import org.apache.hadoop.io.BytesWritable;
-import org.apache.hadoop.sqoop.io.LobFile;
+import com.cloudera.sqoop.io.LobFile;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -26,7 +26,7 @@ import java.io.StringReader;
 import java.util.regex.Matcher;
 
 import org.apache.hadoop.io.Text;
-import org.apache.hadoop.sqoop.io.LobFile;
+import com.cloudera.sqoop.io.LobFile;
 
 /**
  * ClobRef is a wrapper that holds a CLOB either directly, or a
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 
 /**
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import org.apache.hadoop.io.BytesWritable;
 import java.math.BigDecimal;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.Closeable;
 import java.io.File;
@@ -33,7 +33,7 @@ import java.sql.SQLException;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.sqoop.io.LobFile;
+import com.cloudera.sqoop.io.LobFile;
 
 /**
  * Contains a set of methods which can read db columns from a ResultSet into
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.Closeable;
 import java.io.DataInput;
@@ -32,8 +32,8 @@ import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.lib.input.FileSplit;
-import org.apache.hadoop.sqoop.io.LobFile;
-import org.apache.hadoop.sqoop.io.LobReaderCache;
+import com.cloudera.sqoop.io.LobFile;
+import com.cloudera.sqoop.io.LobReaderCache;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import org.apache.hadoop.conf.Configuration;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.IOException;
 import java.sql.Connection;
@@ -24,8 +24,8 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.Map;
 
-import org.apache.hadoop.sqoop.util.ExportException;
-import org.apache.hadoop.sqoop.util.ImportException;
+import com.cloudera.sqoop.util.ExportException;
+import com.cloudera.sqoop.util.ImportException;
 
 /**
  * Abstract interface that manages connections to a database.
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.IOException;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.mapreduce.MySQLDumpImportJob;
-import org.apache.hadoop.sqoop.mapreduce.MySQLExportJob;
-import org.apache.hadoop.sqoop.util.ImportException;
-import org.apache.hadoop.sqoop.util.ExportException;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.mapreduce.MySQLDumpImportJob;
+import com.cloudera.sqoop.mapreduce.MySQLExportJob;
+import com.cloudera.sqoop.util.ImportException;
+import com.cloudera.sqoop.util.ExportException;
 
 /**
  * Manages direct connections to MySQL databases
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;
@@ -32,17 +32,17 @@ import java.util.List;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.io.SplittableBufferedWriter;
-import org.apache.hadoop.sqoop.util.AsyncSink;
-import org.apache.hadoop.sqoop.util.DirectImportUtils;
-import org.apache.hadoop.sqoop.util.ErrorableAsyncSink;
-import org.apache.hadoop.sqoop.util.ErrorableThread;
-import org.apache.hadoop.sqoop.util.Executor;
-import org.apache.hadoop.sqoop.util.ImportException;
-import org.apache.hadoop.sqoop.util.JdbcUrl;
-import org.apache.hadoop.sqoop.util.LoggingAsyncSink;
-import org.apache.hadoop.sqoop.util.PerfCounters;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.io.SplittableBufferedWriter;
+import com.cloudera.sqoop.util.AsyncSink;
+import com.cloudera.sqoop.util.DirectImportUtils;
+import com.cloudera.sqoop.util.ErrorableAsyncSink;
+import com.cloudera.sqoop.util.ErrorableThread;
+import com.cloudera.sqoop.util.Executor;
+import com.cloudera.sqoop.util.ImportException;
+import com.cloudera.sqoop.util.JdbcUrl;
+import com.cloudera.sqoop.util.LoggingAsyncSink;
+import com.cloudera.sqoop.util.PerfCounters;
 
 /**
  * Manages direct dumps from Postgresql databases via psql COPY TO STDOUT
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 /**
  * A set of parameters describing an export operation; this is passed to
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -24,7 +24,7 @@ import java.sql.SQLException;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 /**
  * Database manager that is connects to a generic JDBC-compliant
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 /**
  * Manages connections to hsqldb databases.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import org.apache.hadoop.mapreduce.InputFormat;
 import org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat;
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 /**
  * A set of parameters describing an import operation; this is passed to
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 /**
  * Interface for factory classes for ConnManager implementations.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.IOException;
 import java.io.PrintWriter;
@@ -32,8 +32,8 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
 import org.apache.hadoop.util.StringUtils;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.util.ImportException;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.util.ImportException;
 
 /**
  * Manages connections to MySQL databases.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.BufferedWriter;
 import java.io.File;
@@ -27,8 +27,8 @@ import java.io.OutputStreamWriter;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.util.DirectImportUtils;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.util.DirectImportUtils;
 
 /**
  * Helper methods and constants for MySQL imports/exports.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.IOException;
 import java.sql.Connection;
@@ -32,11 +32,11 @@ import org.apache.commons.logging.LogFactory;
 
 import org.apache.hadoop.mapreduce.OutputFormat;
 import org.apache.hadoop.mapreduce.lib.db.OracleDataDrivenDBInputFormat;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.mapreduce.JdbcExportJob;
-import org.apache.hadoop.sqoop.shims.ShimLoader;
-import org.apache.hadoop.sqoop.util.ExportException;
-import org.apache.hadoop.sqoop.util.ImportException;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.mapreduce.JdbcExportJob;
+import com.cloudera.sqoop.shims.ShimLoader;
+import com.cloudera.sqoop.util.ExportException;
+import com.cloudera.sqoop.util.ImportException;
 
 /**
  * Manages connections to Oracle databases.
@@ -303,7 +303,7 @@ public class OracleManager extends GenericJdbcManager {
     try {
       JdbcExportJob exportJob = new JdbcExportJob(context, null, null,
           (Class<? extends OutputFormat>) ShimLoader.getShimClass(
-          "org.apache.hadoop.sqoop.mapreduce.OracleExportOutputFormat"));
+          "com.cloudera.sqoop.mapreduce.OracleExportOutputFormat"));
       exportJob.runExport();
     } catch (ClassNotFoundException cnfe) {
       throw new ExportException("Could not start export; could not find class",
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.IOException;
 import java.sql.PreparedStatement;
@@ -27,8 +27,8 @@ import java.sql.SQLException;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.util.ImportException;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.util.ImportException;
 
 /**
  * Manages connections to Postgresql databases.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
-
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.hive.HiveTypes;
-import org.apache.hadoop.sqoop.lib.BlobRef;
-import org.apache.hadoop.sqoop.lib.ClobRef;
-import org.apache.hadoop.sqoop.mapreduce.DataDrivenImportJob;
-import org.apache.hadoop.sqoop.mapreduce.JdbcExportJob;
-import org.apache.hadoop.sqoop.util.ExportException;
-import org.apache.hadoop.sqoop.util.ImportException;
-import org.apache.hadoop.sqoop.util.ResultSetPrinter;
+package com.cloudera.sqoop.manager;
+
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.hive.HiveTypes;
+import com.cloudera.sqoop.lib.BlobRef;
+import com.cloudera.sqoop.lib.ClobRef;
+import com.cloudera.sqoop.mapreduce.DataDrivenImportJob;
+import com.cloudera.sqoop.mapreduce.JdbcExportJob;
+import com.cloudera.sqoop.util.ExportException;
+import com.cloudera.sqoop.util.ImportException;
+import com.cloudera.sqoop.util.ResultSetPrinter;
 
 import java.io.IOException;
 import java.io.PrintWriter;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.SQLException;
@@ -35,12 +35,12 @@ import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
 import org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat;
 import org.apache.hadoop.mapreduce.lib.db.DBWritable;
 
-import org.apache.hadoop.sqoop.ConnFactory;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.lib.LargeObjectLoader;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.shims.ShimLoader;
+import com.cloudera.sqoop.ConnFactory;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.lib.LargeObjectLoader;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.shims.ShimLoader;
 
 /**
  * Actually runs a jdbc import job using the ORM files generated by the
@@ -90,7 +90,7 @@ public class DataDrivenImportJob extends ImportJobBase {
       throws ClassNotFoundException {
     if (options.getFileLayout() == SqoopOptions.FileLayout.TextFile) {
       return (Class<? extends OutputFormat>) ShimLoader.getShimClass(
-         "org.apache.hadoop.sqoop.mapreduce.RawKeyTextOutputFormat");
+         "com.cloudera.sqoop.mapreduce.RawKeyTextOutputFormat");
     } else if (options.getFileLayout() == SqoopOptions.FileLayout.SequenceFile) {
       return SequenceFileOutputFormat.class;
     }
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.FileNotFoundException;
 import java.io.IOException;
@@ -36,14 +36,14 @@ import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.OutputFormat;
 import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
-import org.apache.hadoop.sqoop.manager.ExportJobContext;
-import org.apache.hadoop.sqoop.orm.TableClassName;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.shims.ShimLoader;
-import org.apache.hadoop.sqoop.util.ExportException;
-import org.apache.hadoop.sqoop.util.PerfCounters;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.manager.ExportJobContext;
+import com.cloudera.sqoop.orm.TableClassName;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.shims.ShimLoader;
+import com.cloudera.sqoop.util.ExportException;
+import com.cloudera.sqoop.util.PerfCounters;
 
 /**
  * Base class for running an export MapReduce job.
@@ -174,7 +174,7 @@ public class ExportJobBase extends JobBase {
     Class<? extends InputFormat> configuredIF = super.getInputFormatClass();
     if (null == configuredIF) {
       return (Class<? extends InputFormat>) ShimLoader.getShimClass(
-          "org.apache.hadoop.sqoop.mapreduce.ExportInputFormat");
+          "com.cloudera.sqoop.mapreduce.ExportInputFormat");
     } else {
       return configuredIF;
     }
@@ -186,7 +186,7 @@ public class ExportJobBase extends JobBase {
     Class<? extends OutputFormat> configuredOF = super.getOutputFormatClass();
     if (null == configuredOF) {
       return (Class<? extends OutputFormat>) ShimLoader.getShimClass(
-          "org.apache.hadoop.sqoop.mapreduce.ExportOutputFormat");
+          "com.cloudera.sqoop.mapreduce.ExportOutputFormat");
     } else {
       return configuredOF;
     }
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 
@@ -35,11 +35,11 @@ import org.apache.hadoop.mapreduce.OutputFormat;
 import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
 import org.apache.hadoop.mapreduce.lib.output.SequenceFileOutputFormat;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.orm.TableClassName;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.util.ImportException;
-import org.apache.hadoop.sqoop.util.PerfCounters;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.orm.TableClassName;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.util.ImportException;
+import com.cloudera.sqoop.util.PerfCounters;
 
 /**
  * Base class for running an import MapReduce job.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.SQLException;
@@ -32,9 +32,9 @@ import org.apache.hadoop.mapreduce.OutputFormat;
 import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
 import org.apache.hadoop.mapreduce.lib.db.DBOutputFormat;
 
-import org.apache.hadoop.sqoop.ConnFactory;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.manager.ExportJobContext;
+import com.cloudera.sqoop.ConnFactory;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.manager.ExportJobContext;
 
 /**
  * Run an export using JDBC (JDBC-based ExportOutputFormat).
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 
@@ -29,9 +29,9 @@ import org.apache.hadoop.mapreduce.Job;
 import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.OutputFormat;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 /**
  * Base class for configuring and running a MapReduce job.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.SQLException;
@@ -33,11 +33,11 @@ import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
 import org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat;
 import org.apache.hadoop.mapreduce.lib.db.DBWritable;
 
-import org.apache.hadoop.sqoop.ConnFactory;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.manager.MySQLUtils;
-import org.apache.hadoop.sqoop.shims.ShimLoader;
+import com.cloudera.sqoop.ConnFactory;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.manager.MySQLUtils;
+import com.cloudera.sqoop.shims.ShimLoader;
 
 /**
  * Class that runs an import job using mysqldump in the mapper.
@@ -51,9 +51,9 @@ public class MySQLDumpImportJob extends ImportJobBase {
       throws ClassNotFoundException {
     super(opts, MySQLDumpMapper.class,
         (Class<? extends InputFormat>) ShimLoader.getShimClass(
-            "org.apache.hadoop.sqoop.mapreduce.MySQLDumpInputFormat"),
+            "com.cloudera.sqoop.mapreduce.MySQLDumpInputFormat"),
         (Class<? extends OutputFormat>) ShimLoader.getShimClass(
-            "org.apache.hadoop.sqoop.mapreduce.RawKeyTextOutputFormat"));
+            "com.cloudera.sqoop.mapreduce.RawKeyTextOutputFormat"));
   }
 
   /**
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.BufferedReader;
 import java.io.File;
@@ -32,15 +32,15 @@ import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.Mapper;
-import org.apache.hadoop.sqoop.lib.FieldFormatter;
-import org.apache.hadoop.sqoop.lib.RecordParser;
-import org.apache.hadoop.sqoop.manager.MySQLUtils;
-import org.apache.hadoop.sqoop.util.AsyncSink;
-import org.apache.hadoop.sqoop.util.ErrorableAsyncSink;
-import org.apache.hadoop.sqoop.util.ErrorableThread;
-import org.apache.hadoop.sqoop.util.JdbcUrl;
-import org.apache.hadoop.sqoop.util.LoggingAsyncSink;
-import org.apache.hadoop.sqoop.util.PerfCounters;
+import com.cloudera.sqoop.lib.FieldFormatter;
+import com.cloudera.sqoop.lib.RecordParser;
+import com.cloudera.sqoop.manager.MySQLUtils;
+import com.cloudera.sqoop.util.AsyncSink;
+import com.cloudera.sqoop.util.ErrorableAsyncSink;
+import com.cloudera.sqoop.util.ErrorableThread;
+import com.cloudera.sqoop.util.JdbcUrl;
+import com.cloudera.sqoop.util.LoggingAsyncSink;
+import com.cloudera.sqoop.util.PerfCounters;
 
 /**
  * Mapper that opens up a pipe to mysqldump and pulls data directly.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.SQLException;
@@ -32,10 +32,10 @@ import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
 import org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat;
 import org.apache.hadoop.mapreduce.lib.db.DBWritable;
 
-import org.apache.hadoop.sqoop.ConnFactory;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.manager.ExportJobContext;
-import org.apache.hadoop.sqoop.manager.MySQLUtils;
+import com.cloudera.sqoop.ConnFactory;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.manager.ExportJobContext;
+import com.cloudera.sqoop.manager.MySQLUtils;
 
 /**
  * Class that runs an export job using mysqlimport in the mapper.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.BufferedOutputStream;
 import java.io.File;
@@ -32,13 +32,13 @@ import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.util.Shell;
 import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
-import org.apache.hadoop.sqoop.lib.TaskId;
-import org.apache.hadoop.sqoop.manager.MySQLUtils;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.util.AsyncSink;
-import org.apache.hadoop.sqoop.util.JdbcUrl;
-import org.apache.hadoop.sqoop.util.LoggingAsyncSink;
-import org.apache.hadoop.sqoop.util.NullAsyncSink;
+import com.cloudera.sqoop.lib.TaskId;
+import com.cloudera.sqoop.manager.MySQLUtils;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.util.AsyncSink;
+import com.cloudera.sqoop.util.JdbcUrl;
+import com.cloudera.sqoop.util.LoggingAsyncSink;
+import com.cloudera.sqoop.util.NullAsyncSink;
 
 /**
  * Mapper that starts a 'mysqlimport' process and uses that to export rows from
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 
 import org.apache.hadoop.io.LongWritable;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 /**
  * mysqlimport-based exporter which accepts SqoopRecords (e.g., from
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 
 import org.apache.hadoop.io.LongWritable;
 import org.apache.hadoop.io.Text;
 
-import org.apache.hadoop.sqoop.manager.MySQLUtils;
+import com.cloudera.sqoop.manager.MySQLUtils;
 
 /**
  * mysqlimport-based exporter which accepts lines of text from files
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 
@@ -24,7 +24,7 @@ import org.apache.hadoop.io.LongWritable;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.Mapper.Context;
 
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 /**
  * Reads a SqoopRecord from the SequenceFile in which it's packed and emits
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.SQLException;
@@ -24,8 +24,8 @@ import java.sql.SQLException;
 import org.apache.hadoop.io.LongWritable;
 import org.apache.hadoop.mapreduce.Mapper.Context;
 import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
-import org.apache.hadoop.sqoop.lib.LargeObjectLoader;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.LargeObjectLoader;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 /**
  * Imports records by writing them to a SequenceFile.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 
@@ -27,8 +27,8 @@ import org.apache.hadoop.io.Text;
 import org.apache.hadoop.mapreduce.Mapper.Context;
 import org.apache.hadoop.util.ReflectionUtils;
 
-import org.apache.hadoop.sqoop.lib.RecordParser;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.RecordParser;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 /**
  * Converts an input record from a string representation to a parsed Sqoop
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.SQLException;
@@ -26,8 +26,8 @@ import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.mapreduce.Mapper.Context;
 import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
-import org.apache.hadoop.sqoop.lib.LargeObjectLoader;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.LargeObjectLoader;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 /**
  * Imports records by transforming them to strings for a plain-text flat file.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.orm;
+package com.cloudera.sqoop.orm;
 
 import org.apache.hadoop.io.BytesWritable;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.lib.BigDecimalSerializer;
-import org.apache.hadoop.sqoop.lib.FieldFormatter;
-import org.apache.hadoop.sqoop.lib.JdbcWritableBridge;
-import org.apache.hadoop.sqoop.lib.LargeObjectLoader;
-import org.apache.hadoop.sqoop.lib.LobSerializer;
-import org.apache.hadoop.sqoop.lib.RecordParser;
-import org.apache.hadoop.sqoop.lib.BlobRef;
-import org.apache.hadoop.sqoop.lib.ClobRef;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.lib.BigDecimalSerializer;
+import com.cloudera.sqoop.lib.FieldFormatter;
+import com.cloudera.sqoop.lib.JdbcWritableBridge;
+import com.cloudera.sqoop.lib.LargeObjectLoader;
+import com.cloudera.sqoop.lib.LobSerializer;
+import com.cloudera.sqoop.lib.RecordParser;
+import com.cloudera.sqoop.lib.BlobRef;
+import com.cloudera.sqoop.lib.ClobRef;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 import java.io.File;
 import java.io.FileOutputStream;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.orm;
+package com.cloudera.sqoop.orm;
 
 import java.io.File;
 import java.io.FileInputStream;
@@ -40,9 +40,9 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.mapred.JobConf;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.util.FileListing;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.util.FileListing;
+import com.cloudera.sqoop.shims.HadoopShim;
 
 /**
  * Manages the compilation of a bunch of .java files into .class files
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.orm;
+package com.cloudera.sqoop.orm;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hadoop.sqoop.shims;
+package com.cloudera.sqoop.shims;
 
 import java.io.IOException;
 
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hadoop.sqoop.shims;
+package com.cloudera.sqoop.shims;
 
 import java.io.File;
 import java.io.IOException;
@@ -27,7 +27,7 @@ import org.apache.commons.logging.LogFactory;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.util.VersionInfo;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 /**
  * Provides a service locator for the appropriate shim, dynamically chosen
@@ -70,29 +70,29 @@ public abstract class ShimLoader {
 
     // CDH3 (based on 0.20.2)
     HADOOP_SHIM_MATCHES.add("0.20.2-[cC][dD][hH]3.*");
-    HADOOP_SHIM_CLASSES.add("org.apache.hadoop.sqoop.shims.CDH3Shim");
+    HADOOP_SHIM_CLASSES.add("com.cloudera.sqoop.shims.CDH3Shim");
     HADOOP_SHIM_JARS.add("sqoop-.*-cloudera.jar");
 
     // Apache 0.22 trunk.
     // Version may have the form  "0.22-SNAPSHOT"
     HADOOP_SHIM_MATCHES.add("0.22-.*");
-    HADOOP_SHIM_CLASSES.add("org.apache.hadoop.sqoop.shims.Apache22HadoopShim");
+    HADOOP_SHIM_CLASSES.add("com.cloudera.sqoop.shims.Apache22HadoopShim");
     HADOOP_SHIM_JARS.add("sqoop-.*-apache.jar");
 
     // ... or "0.22.n-SNAPSHOT"
     HADOOP_SHIM_MATCHES.add("0.22.\\d+-.*");
-    HADOOP_SHIM_CLASSES.add("org.apache.hadoop.sqoop.shims.Apache22HadoopShim");
+    HADOOP_SHIM_CLASSES.add("com.cloudera.sqoop.shims.Apache22HadoopShim");
     HADOOP_SHIM_JARS.add("sqoop-.*-apache.jar");
 
     // Apache 0.22 trunk snapshots often compile with "Unknown" version,
     // so we default to guessing Apache in this case.
     HADOOP_SHIM_MATCHES.add("Unknown");
-    HADOOP_SHIM_CLASSES.add("org.apache.hadoop.sqoop.shims.Apache22HadoopShim");
+    HADOOP_SHIM_CLASSES.add("com.cloudera.sqoop.shims.Apache22HadoopShim");
     HADOOP_SHIM_JARS.add("sqoop-.*-apache.jar");
 
     // Apache 0.21 uses the same shim jars as 0.22
     HADOOP_SHIM_MATCHES.add("0.21.\\d+(-.*)?");
-    HADOOP_SHIM_CLASSES.add("org.apache.hadoop.sqoop.shims.Apache22HadoopShim");
+    HADOOP_SHIM_CLASSES.add("com.cloudera.sqoop.shims.Apache22HadoopShim");
     HADOOP_SHIM_JARS.add("sqoop-.*-apache.jar");
 
   }
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.sql.SQLException;
 import java.util.Arrays;
@@ -30,14 +30,14 @@ import org.apache.log4j.Category;
 import org.apache.log4j.Level;
 import org.apache.log4j.Logger;
 
-import org.apache.hadoop.sqoop.ConnFactory;
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.RelatedOptions;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.shims.ShimLoader;
+import com.cloudera.sqoop.ConnFactory;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.RelatedOptions;
+import com.cloudera.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.shims.ShimLoader;
 
 /**
  * Layer on top of SqoopTool that provides some basic common code
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -28,14 +28,14 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.util.StringUtils;
 
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.RelatedOptions;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
-import org.apache.hadoop.sqoop.hive.HiveImport;
-import org.apache.hadoop.sqoop.orm.ClassWriter;
-import org.apache.hadoop.sqoop.orm.CompilationManager;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.RelatedOptions;
+import com.cloudera.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.hive.HiveImport;
+import com.cloudera.sqoop.orm.ClassWriter;
+import com.cloudera.sqoop.orm.CompilationManager;
 
 /**
  * Tool that generates code from a database schema.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.io.IOException;
 
@@ -26,12 +26,12 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.util.StringUtils;
 
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.RelatedOptions;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
-import org.apache.hadoop.sqoop.hive.HiveImport;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.RelatedOptions;
+import com.cloudera.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.hive.HiveImport;
 
 /**
  * Tool that creates a Hive table definition.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.OptionBuilder;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.RelatedOptions;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.RelatedOptions;
+import com.cloudera.sqoop.cli.ToolOptions;
 
 /**
  * Tool that evaluates a SQL statement and displays the results.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.io.IOException;
 import java.util.List;
@@ -26,13 +26,13 @@ import org.apache.commons.cli.OptionBuilder;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.RelatedOptions;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
-import org.apache.hadoop.sqoop.manager.ExportJobContext;
-import org.apache.hadoop.sqoop.util.ExportException;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.RelatedOptions;
+import com.cloudera.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.manager.ExportJobContext;
+import com.cloudera.sqoop.util.ExportException;
 
 /**
  * Tool that performs HDFS exports to databases.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.util.Set;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.cli.ToolOptions;
 
 /**
  * Tool that explains the usage of Sqoop.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.io.IOException;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.hive.HiveImport;
-import org.apache.hadoop.sqoop.util.ImportException;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.hive.HiveImport;
+import com.cloudera.sqoop.util.ImportException;
 
 /**
  * Tool that performs database imports of all tables in a database to HDFS.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.io.IOException;
 import java.util.List;
@@ -26,14 +26,14 @@ import org.apache.commons.cli.OptionBuilder;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.RelatedOptions;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
-import org.apache.hadoop.sqoop.hive.HiveImport;
-import org.apache.hadoop.sqoop.manager.ImportJobContext;
-import org.apache.hadoop.sqoop.util.ImportException;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.RelatedOptions;
+import com.cloudera.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.hive.HiveImport;
+import com.cloudera.sqoop.manager.ImportJobContext;
+import com.cloudera.sqoop.util.ImportException;
 
 /**
  * Tool that performs database imports to HDFS.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.ToolOptions;
 
 /**
  * Tool that lists available databases on a server.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.ToolOptions;
 
 /**
  * Tool that lists available tables in a database.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
 import java.io.IOException;
 import java.util.Map;
@@ -32,11 +32,11 @@ import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.util.StringUtils;
 import org.apache.hadoop.util.ToolRunner;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.cli.SqoopParser;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
-import org.apache.hadoop.sqoop.shims.ShimLoader;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.cli.SqoopParser;
+import com.cloudera.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.shims.ShimLoader;
 
 /**
  * Base class for Sqoop subprograms (e.g., SqoopImport, SqoopExport, etc.)
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.tool;
+package com.cloudera.sqoop.tool;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopVersion;
-import org.apache.hadoop.sqoop.cli.ToolOptions;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopVersion;
+import com.cloudera.sqoop.cli.ToolOptions;
 
 /**
  * Tool that prints Sqoop's version.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.io.InputStream;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.io.File;
 import java.io.IOException;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.io.IOException;
 import java.io.File;
@@ -29,9 +29,9 @@ import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.io.SplittingOutputStream;
-import org.apache.hadoop.sqoop.io.SplittableBufferedWriter;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.io.SplittingOutputStream;
+import com.cloudera.sqoop.io.SplittableBufferedWriter;
 import org.apache.hadoop.util.Shell;
 
 /**
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 /**
  * Partial implementation of AsyncSink that relies on ErrorableThread to
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 /**
  * A thread which has an error bit which can be set from within the thread.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 /**
  * General error during export process.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.util.Arrays;
 import java.util.ArrayList;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 /**
  * General error during the import process.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.net.MalformedURLException;
 import java.net.URL;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.io.BufferedReader;
 import java.io.InputStream;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.io.BufferedReader;
 import java.io.InputStream;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.text.NumberFormat;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.io.IOException;
 import java.io.PrintWriter;
index a2a18fb..4d4e29e 100644 (file)
@@ -23,10 +23,10 @@ import org.apache.hadoop.fs.*;
 import org.apache.hadoop.conf.*;
 import org.apache.hadoop.util.*;
 
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.tool.ExportTool;
-import org.apache.hadoop.sqoop.tool.SqoopTool;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.tool.ExportTool;
+import com.cloudera.sqoop.tool.SqoopTool;
 
 /**
  * Stress test export procedure by running a large-scale export to MySQL.
index 28d16d4..63f387d 100644 (file)
@@ -19,7 +19,7 @@
 import java.io.*;
 import org.apache.hadoop.fs.*;
 import org.apache.hadoop.conf.*;
-import org.apache.hadoop.sqoop.io.*;
+import com.cloudera.sqoop.io.*;
 
 /**
  * A simple benchmark to performance test LobFile reader/writer speed.
index ee19728..b233019 100644 (file)
@@ -20,7 +20,7 @@ import java.io.*;
 import java.util.*;
 import org.apache.hadoop.fs.*;
 import org.apache.hadoop.conf.*;
-import org.apache.hadoop.sqoop.io.*;
+import com.cloudera.sqoop.io.*;
 
 /**
  * Stress test LobFiles by writing a bunch of different files and reading
index 651b309..e9ebd93 100755 (executable)
@@ -27,7 +27,7 @@
 buildroot=$1
 version=$2
 
-outputdir=${buildroot}/src/org/apache/hadoop/sqoop
+outputdir=${buildroot}/src/com.cloudera.sqoop
 outputfile=${outputdir}/SqoopVersion.java
 
 signature=`git log -1 --pretty=format:%H`
@@ -37,7 +37,7 @@ compiledate=`date`
 mkdir -p ${outputdir}
 cat > ${outputfile} <<EOF
 // generated by src/scripts/write-version-info.sh
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 public final class SqoopVersion {
   public SqoopVersion() {
   }
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hadoop.sqoop.shims;
+package com.cloudera.sqoop.shims;
 
 import java.io.IOException;
 
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hadoop.sqoop.shims;
+package com.cloudera.sqoop.shims;
 
 import java.io.IOException;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.Connection;
@@ -37,7 +37,7 @@ import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
 import org.apache.hadoop.util.StringUtils;
 
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 /**
  * Insert the emitted keys as records into a database table.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.IOException;
 import java.sql.SQLException;
@@ -24,7 +24,7 @@ import java.sql.SQLException;
 import org.apache.hadoop.mapreduce.RecordWriter;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.SqoopRecord;
 
 /**
  * Oracle-specific SQL formatting overrides default ExportOutputFormat's.
similarity index 86%
rename from src/test/org/apache/hadoop/sqoop/AllTests.java
rename to src/test/com/cloudera/sqoop/AllTests.java
index 2f28a9b..e79f745 100644 (file)
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import junit.framework.Test;
 import junit.framework.TestSuite;
 
 /**
- * All tests for Sqoop (org.apache.hadoop.sqoop).
+ * All tests for Sqoop (com.cloudera.sqoop).
  */
 public final class AllTests {
 
   private AllTests() { }
 
   public static Test suite() {
-    TestSuite suite = new TestSuite("All tests for org.apache.hadoop.sqoop");
+    TestSuite suite = new TestSuite("All tests for com.cloudera.sqoop");
 
     suite.addTest(SmokeTests.suite());
     suite.addTest(ThirdPartyTests.suite());
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
-import org.apache.hadoop.sqoop.hive.TestHiveImport;
-import org.apache.hadoop.sqoop.hive.TestTableDefWriter;
-import org.apache.hadoop.sqoop.io.TestLobFile;
-import org.apache.hadoop.sqoop.io.TestSplittableBufferedWriter;
-import org.apache.hadoop.sqoop.lib.TestFieldFormatter;
-import org.apache.hadoop.sqoop.lib.TestRecordParser;
-import org.apache.hadoop.sqoop.lib.TestBlobRef;
-import org.apache.hadoop.sqoop.lib.TestClobRef;
-import org.apache.hadoop.sqoop.lib.TestLargeObjectLoader;
-import org.apache.hadoop.sqoop.manager.TestHsqldbManager;
-import org.apache.hadoop.sqoop.manager.TestSqlManager;
-import org.apache.hadoop.sqoop.mapreduce.MapreduceTests;
-import org.apache.hadoop.sqoop.orm.TestClassWriter;
-import org.apache.hadoop.sqoop.orm.TestParseMethods;
-import org.apache.hadoop.sqoop.util.TestDirectImportUtils;
+import com.cloudera.sqoop.hive.TestHiveImport;
+import com.cloudera.sqoop.hive.TestTableDefWriter;
+import com.cloudera.sqoop.io.TestLobFile;
+import com.cloudera.sqoop.io.TestSplittableBufferedWriter;
+import com.cloudera.sqoop.lib.TestFieldFormatter;
+import com.cloudera.sqoop.lib.TestRecordParser;
+import com.cloudera.sqoop.lib.TestBlobRef;
+import com.cloudera.sqoop.lib.TestClobRef;
+import com.cloudera.sqoop.lib.TestLargeObjectLoader;
+import com.cloudera.sqoop.manager.TestHsqldbManager;
+import com.cloudera.sqoop.manager.TestSqlManager;
+import com.cloudera.sqoop.mapreduce.MapreduceTests;
+import com.cloudera.sqoop.orm.TestClassWriter;
+import com.cloudera.sqoop.orm.TestParseMethods;
+import com.cloudera.sqoop.util.TestDirectImportUtils;
 
 import junit.framework.Test;
 import junit.framework.TestSuite;
 
 /**
- * Smoke tests for Sqoop (org.apache.hadoop.sqoop).
+ * Smoke tests for Sqoop (com.cloudera.sqoop).
  */
 public final class SmokeTests {
 
   private SmokeTests() { }
 
   public static Test suite() {
-    TestSuite suite = new TestSuite("Smoke tests for org.apache.hadoop.sqoop");
+    TestSuite suite = new TestSuite("Smoke tests for com.cloudera.sqoop");
 
     suite.addTestSuite(TestAllTables.class);
     suite.addTestSuite(TestHsqldbManager.class);
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import java.io.BufferedReader;
 import java.io.File;
@@ -31,10 +31,10 @@ import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.IOUtils;
 import org.junit.Before;
 
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.tool.ImportAllTablesTool;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.tool.ImportAllTablesTool;
 
 /**
  * Test the --all-tables functionality that can import multiple tables.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.testutil.ManagerCompatTestCase;
+import com.cloudera.sqoop.testutil.ManagerCompatTestCase;
 
 /**
  * Test that each of the different SQL Column types that we support
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.manager.ImportJobContext;
-import org.apache.hadoop.sqoop.manager.ManagerFactory;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.manager.ImportJobContext;
+import com.cloudera.sqoop.manager.ManagerFactory;
 
 import junit.framework.TestCase;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;
@@ -43,11 +43,11 @@ import org.apache.hadoop.io.compress.CompressionCodecFactory;
 import org.apache.hadoop.io.compress.Decompressor;
 import org.apache.hadoop.util.ReflectionUtils;
 
-import org.apache.hadoop.sqoop.lib.RecordParser;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
-import org.apache.hadoop.sqoop.testutil.ExportJobTestCase;
-import org.apache.hadoop.sqoop.tool.CodeGenTool;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.lib.RecordParser;
+import com.cloudera.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.testutil.ExportJobTestCase;
+import com.cloudera.sqoop.tool.CodeGenTool;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 import org.junit.Before;
 
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
 
 /**
  * Test cases that import rows containing multiple columns,
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -32,14 +32,14 @@ import org.apache.hadoop.io.SequenceFile;
 import org.apache.hadoop.mapred.Utils;
 import org.apache.hadoop.util.ReflectionUtils;
 
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.orm.CompilationManager;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.testutil.SeqFileReader;
-import org.apache.hadoop.sqoop.tool.ImportTool;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.orm.CompilationManager;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.testutil.SeqFileReader;
+import com.cloudera.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 /**
  * Test that using multiple mapper splits works.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -27,14 +27,14 @@ import org.apache.hadoop.io.IOUtils;
 import org.apache.hadoop.io.SequenceFile;
 import org.apache.hadoop.util.ReflectionUtils;
 
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.orm.CompilationManager;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.testutil.SeqFileReader;
-import org.apache.hadoop.sqoop.tool.ImportTool;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.orm.CompilationManager;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.testutil.SeqFileReader;
+import com.cloudera.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 /**
  * Test that --split-by works.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import junit.framework.TestCase;
 
-import org.apache.hadoop.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.tool.ImportTool;
 
 
 /**
similarity index 92%
rename from src/test/org/apache/hadoop/sqoop/TestWhere.java
rename to src/test/com/cloudera/sqoop/TestWhere.java
index 8999b48..668a6f5 100644 (file)
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -27,14 +27,14 @@ import org.apache.hadoop.io.IOUtils;
 import org.apache.hadoop.io.SequenceFile;
 import org.apache.hadoop.util.ReflectionUtils;
 
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.orm.CompilationManager;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.testutil.SeqFileReader;
-import org.apache.hadoop.sqoop.tool.ImportTool;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.orm.CompilationManager;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.testutil.SeqFileReader;
+import com.cloudera.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 /**
  * Test that --where works in Sqoop.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop;
+package com.cloudera.sqoop;
 
 import junit.framework.Test;
 import junit.framework.TestCase;
 import junit.framework.TestSuite;
 
-import org.apache.hadoop.sqoop.manager.DirectMySQLTest;
-import org.apache.hadoop.sqoop.manager.DirectMySQLExportTest;
-import org.apache.hadoop.sqoop.manager.JdbcMySQLExportTest;
-import org.apache.hadoop.sqoop.manager.MySQLAuthTest;
-import org.apache.hadoop.sqoop.manager.MySQLCompatTest;
-import org.apache.hadoop.sqoop.manager.OracleExportTest;
-import org.apache.hadoop.sqoop.manager.OracleManagerTest;
-import org.apache.hadoop.sqoop.manager.OracleCompatTest;
-import org.apache.hadoop.sqoop.manager.PostgresqlTest;
+import com.cloudera.sqoop.manager.DirectMySQLTest;
+import com.cloudera.sqoop.manager.DirectMySQLExportTest;
+import com.cloudera.sqoop.manager.JdbcMySQLExportTest;
+import com.cloudera.sqoop.manager.MySQLAuthTest;
+import com.cloudera.sqoop.manager.MySQLCompatTest;
+import com.cloudera.sqoop.manager.OracleExportTest;
+import com.cloudera.sqoop.manager.OracleManagerTest;
+import com.cloudera.sqoop.manager.OracleCompatTest;
+import com.cloudera.sqoop.manager.PostgresqlTest;
 
 /**
  * Test battery including all tests of vendor-specific ConnManager
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.hive;
+package com.cloudera.sqoop.hive;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -28,14 +28,14 @@ import org.junit.Test;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.tool.CodeGenTool;
-import org.apache.hadoop.sqoop.tool.CreateHiveTableTool;
-import org.apache.hadoop.sqoop.tool.ImportTool;
-import org.apache.hadoop.sqoop.tool.SqoopTool;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.tool.CodeGenTool;
+import com.cloudera.sqoop.tool.CreateHiveTableTool;
+import com.cloudera.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.tool.SqoopTool;
 
 /**
  * Test HiveImport capability after an import to HDFS.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.hive;
+package com.cloudera.sqoop.hive;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -24,7 +24,7 @@ import java.util.Map;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 import junit.framework.TestCase;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.io.BufferedReader;
 import java.io.File;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.io;
+package com.cloudera.sqoop.io;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -34,7 +34,7 @@ import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
 
 import junit.framework.TestCase;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.*;
 
@@ -25,7 +25,7 @@ import junit.framework.TestCase;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.sqoop.io.LobFile;
+import com.cloudera.sqoop.io.LobFile;
 
 /**
  * Test that the BlobRef.parse() method does the right thing.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.*;
 
@@ -25,7 +25,7 @@ import junit.framework.TestCase;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.sqoop.io.LobFile;
+import com.cloudera.sqoop.io.LobFile;
 
 /**
  * Test parsing of ClobRef objects.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import junit.framework.TestCase;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.io.*;
 import java.sql.ResultSet;
@@ -29,8 +29,8 @@ import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.mapreduce.MapContext;
 import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.testutil.MockResultSet;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.testutil.MockResultSet;
 
 /**
  * Test deserialization of ClobRef and BlobRef fields.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.lib;
+package com.cloudera.sqoop.lib;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.IOException;
 import java.sql.Connection;
@@ -27,9 +27,9 @@ import org.apache.commons.logging.LogFactory;
 import org.junit.After;
 import org.junit.Before;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.TestExport;
-import org.apache.hadoop.sqoop.mapreduce.MySQLExportMapper;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.TestExport;
+import com.cloudera.sqoop.mapreduce.MySQLExportMapper;
 
 /**
  * Test the DirectMySQLManager implementation's exportJob() functionality.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -36,10 +36,10 @@ import org.junit.Test;
 
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.IOUtils;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.util.FileListing;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.util.FileListing;
 
 /**
  * Test the DirectMySQLManager implementation.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -27,8 +27,8 @@ import org.apache.hadoop.util.StringUtils;
 import org.junit.After;
 import org.junit.Before;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.TestExport;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.TestExport;
 
 /**
  * Test the MySQLManager implementation's exportJob() functionality.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -36,9 +36,9 @@ import org.junit.Test;
 
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.IOUtils;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
 
 /**
  * Test authentication and remote access to direct mysqldump-based imports.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.sql.Connection;
 import java.sql.PreparedStatement;
@@ -27,8 +27,8 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.testutil.ManagerCompatTestCase;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.testutil.ManagerCompatTestCase;
 
 /**
  * Test the basic mysql connection manager with the various column types.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.UnsupportedEncodingException;
 import java.sql.SQLException;
@@ -26,8 +26,8 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.testutil.ManagerCompatTestCase;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.testutil.ManagerCompatTestCase;
 
 /**
  * Test the basic Oracle connection manager with the various column types.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -27,8 +27,8 @@ import org.apache.hadoop.util.StringUtils;
 import org.junit.After;
 import org.junit.Before;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.TestExport;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.TestExport;
 
 /**
  * Test the OracleManager implementation's exportJob() functionality.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -44,10 +44,10 @@ import org.junit.Test;
 
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.IOUtils;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.util.FileListing;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.util.FileListing;
 
 /**
  * Test the OracleManager implementation.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -25,7 +25,7 @@ import java.sql.Statement;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions;
 
 /**
  * Helper methods for Oracle testing.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -35,10 +35,10 @@ import org.junit.Test;
 
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.IOUtils;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.util.FileListing;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.util.FileListing;
 
 /**
  * Test the PostgresqlManager and DirectPostgresqlManager implementations.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.sql.SQLException;
 
@@ -28,7 +28,7 @@ import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
 
 /**
  * Test HsqldbManager-specific functionality that overrides SqlManager
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.manager;
+package com.cloudera.sqoop.manager;
 
 import java.sql.Connection;
 import java.sql.PreparedStatement;
@@ -34,7 +34,7 @@ import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
 
 /**
  * Test methods of the generic SqlManager implementation.
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import junit.framework.Test;
 import junit.framework.TestSuite;
 
 /**
- * All tests for Sqoop new mapreduce-api (org.apache.hadoop.sqoop.mapreduce).
+ * All tests for Sqoop new mapreduce-api (com.cloudera.sqoop.mapreduce).
  */
 public final class MapreduceTests {
 
@@ -30,7 +30,7 @@ public final class MapreduceTests {
 
   public static Test suite() {
     TestSuite suite = new TestSuite(
-        "Tests for org.apache.hadoop.sqoop.mapreduce");
+        "Tests for com.cloudera.sqoop.mapreduce");
     suite.addTestSuite(TestImportJob.class);
     return suite;
   }
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.mapreduce;
+package com.cloudera.sqoop.mapreduce;
 
 import java.io.BufferedWriter;
 import java.io.IOException;
@@ -30,13 +30,13 @@ import org.apache.hadoop.io.Text;
 import org.apache.hadoop.mapreduce.Job;
 import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
-import org.apache.hadoop.sqoop.ConnFactory;
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.manager.ManagerFactory;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.testutil.InjectableManagerFactory;
-import org.apache.hadoop.sqoop.testutil.InjectableConnManager;
-import org.apache.hadoop.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.ConnFactory;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.manager.ManagerFactory;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.testutil.InjectableManagerFactory;
+import com.cloudera.sqoop.testutil.InjectableConnManager;
+import com.cloudera.sqoop.tool.ImportTool;
 
 /**
  * Test aspects of the DataDrivenImportJob class' failure reporting.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.orm;
+package com.cloudera.sqoop.orm;
 
 import java.io.File;
 import java.io.FileInputStream;
@@ -35,12 +35,12 @@ import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.testutil.DirUtil;
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.testutil.DirUtil;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.tool.ImportTool;
 
 /**
  * Test that the ClassWriter generates Java classes based on the given table,
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.orm;
+package com.cloudera.sqoop.orm;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -30,15 +30,15 @@ import org.apache.hadoop.mapred.FileOutputFormat;
 import org.apache.hadoop.mapred.JobClient;
 import org.apache.hadoop.mapred.JobConf;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.SqoopOptions.InvalidOptionsException;
-import org.apache.hadoop.sqoop.shims.HadoopShim;
-import org.apache.hadoop.sqoop.testutil.CommonArgs;
-import org.apache.hadoop.sqoop.testutil.HsqldbTestServer;
-import org.apache.hadoop.sqoop.testutil.ImportJobTestCase;
-import org.apache.hadoop.sqoop.testutil.ReparseMapper;
-import org.apache.hadoop.sqoop.tool.ImportTool;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.SqoopOptions.InvalidOptionsException;
+import com.cloudera.sqoop.shims.HadoopShim;
+import com.cloudera.sqoop.testutil.CommonArgs;
+import com.cloudera.sqoop.testutil.HsqldbTestServer;
+import com.cloudera.sqoop.testutil.ImportJobTestCase;
+import com.cloudera.sqoop.testutil.ReparseMapper;
+import com.cloudera.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 /**
  * Test that the parse() methods generated in user SqoopRecord implementations
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.File;
 import java.io.IOException;
@@ -35,10 +35,10 @@ import org.apache.log4j.BasicConfigurator;
 import org.junit.After;
 import org.junit.Before;
 
-import org.apache.hadoop.sqoop.ConnFactory;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.shims.ShimLoader;
+import com.cloudera.sqoop.ConnFactory;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.shims.ShimLoader;
 
 import junit.framework.TestCase;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.util.List;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.File;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.IOException;
 import java.sql.Connection;
@@ -30,9 +30,9 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.util.StringUtils;
 
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.mapreduce.ExportOutputFormat;
-import org.apache.hadoop.sqoop.tool.ExportTool;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.mapreduce.ExportOutputFormat;
+import com.cloudera.sqoop.tool.ExportTool;
 
 /**
  * Class that implements common methods required for tests which export data
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.util.Arrays;
 
@@ -29,9 +29,9 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.hsqldb.Server;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.manager.HsqldbManager;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.manager.HsqldbManager;
 
 /**
  * Create a simple hsqldb server and schema to use for testing.
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.File;
 import java.io.IOException;
@@ -27,12 +27,12 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.Sqoop;
-import org.apache.hadoop.sqoop.orm.CompilationManager;
-import org.apache.hadoop.sqoop.tool.SqoopTool;
-import org.apache.hadoop.sqoop.tool.ImportTool;
-import org.apache.hadoop.sqoop.util.ClassLoaderStack;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.Sqoop;
+import com.cloudera.sqoop.orm.CompilationManager;
+import com.cloudera.sqoop.tool.SqoopTool;
+import com.cloudera.sqoop.tool.ImportTool;
+import com.cloudera.sqoop.util.ClassLoaderStack;
 
 /**
  * Class that implements common methods required for tests which import data
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.IOException;
 
@@ -26,11 +26,11 @@ import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.OutputFormat;
 import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
 import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.HsqldbManager;
-import org.apache.hadoop.sqoop.manager.ImportJobContext;
-import org.apache.hadoop.sqoop.mapreduce.ImportJobBase;
-import org.apache.hadoop.sqoop.util.ImportException;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.HsqldbManager;
+import com.cloudera.sqoop.manager.ImportJobContext;
+import com.cloudera.sqoop.mapreduce.ImportJobBase;
+import com.cloudera.sqoop.util.ImportException;
 import org.apache.hadoop.util.ReflectionUtils;
 
 /**
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
-import org.apache.hadoop.sqoop.SqoopOptions;
-import org.apache.hadoop.sqoop.manager.ConnManager;
-import org.apache.hadoop.sqoop.manager.ManagerFactory;
+import com.cloudera.sqoop.SqoopOptions;
+import com.cloudera.sqoop.manager.ConnManager;
+import com.cloudera.sqoop.manager.ManagerFactory;
 
 /**
  * ManagerFactory that is used for testing; this accepts any
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.UnsupportedEncodingException;
 import java.sql.Blob;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.ByteArrayInputStream;
 import java.io.InputStream;
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.IOException;
 
@@ -32,8 +32,8 @@ import org.apache.hadoop.mapred.MapReduceBase;
 import org.apache.hadoop.mapred.Mapper;
 import org.apache.hadoop.mapred.OutputCollector;
 import org.apache.hadoop.mapred.Reporter;
-import org.apache.hadoop.sqoop.lib.RecordParser;
-import org.apache.hadoop.sqoop.lib.SqoopRecord;
+import com.cloudera.sqoop.lib.RecordParser;
+import com.cloudera.sqoop.lib.SqoopRecord;
 import org.apache.hadoop.util.ReflectionUtils;
 
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.testutil;
+package com.cloudera.sqoop.testutil;
 
 import java.io.IOException;
 
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.hadoop.sqoop.util;
+package com.cloudera.sqoop.util;
 
 import java.net.InetAddress;
 import java.net.UnknownHostException;
index f5cbdab..a5a8a7d 100644 (file)
 <FindBugsFilter>
   <Match>
     <!-- SQL db can return null for a boolean column; so can we. -->
-    <Class name="org.apache.hadoop.sqoop.lib.JdbcWritableBridge" />
+    <Class name="com.cloudera.sqoop.lib.JdbcWritableBridge" />
     <Method name="readBoolean" />
     <Bug pattern="NP_BOOLEAN_RETURN_NULL" />
   </Match>
   <Match>
     <!-- This mapper intentially triggers an NPE to cause an exception
          which the test case much catch. -->
-    <Class name="org.apache.hadoop.sqoop.mapreduce.TestImportJob$NullDereferenceMapper" />
+    <Class name="com.cloudera.sqoop.mapreduce.TestImportJob$NullDereferenceMapper" />
     <Method name="map" />
     <Bug pattern="NP_ALWAYS_NULL" />
   </Match>