实例介绍
【实例简介】
sqoop-1.4.6.bin__hadoop-2.0.4-alpha.tar.gz
【实例截图】
【核心代码】
5bfb55f4-d1d2-4026-9bfb-6a99bd448c43
└── sqoop-1.4.6.bin__hadoop-2.0.4-alpha
├── bin
│ ├── configure-sqoop
│ ├── configure-sqoop.cmd
│ ├── sqoop
│ ├── sqoop.cmd
│ ├── sqoop-codegen
│ ├── sqoop-create-hive-table
│ ├── sqoop-eval
│ ├── sqoop-export
│ ├── sqoop-help
│ ├── sqoop-import
│ ├── sqoop-import-all-tables
│ ├── sqoop-import-mainframe
│ ├── sqoop-job
│ ├── sqoop-list-databases
│ ├── sqoop-list-tables
│ ├── sqoop-merge
│ ├── sqoop-metastore
│ ├── sqoop-version
│ ├── start-metastore.sh
│ └── stop-metastore.sh
├── build.xml
├── CHANGELOG.txt
├── COMPILING.txt
├── conf
│ ├── oraoop-site-template.xml
│ ├── sqoop-env-template.cmd
│ ├── sqoop-env-template.sh
│ ├── sqoop-site-template.xml
│ └── sqoop-site.xml
├── docs
│ ├── api
│ │ ├── allclasses-frame.html
│ │ ├── allclasses-noframe.html
│ │ ├── com
│ │ │ └── cloudera
│ │ │ └── sqoop
│ │ │ └── lib
│ │ │ ├── BigDecimalSerializer.html
│ │ │ ├── BlobRef.html
│ │ │ ├── BooleanParser.html
│ │ │ ├── class-use
│ │ │ │ ├── BigDecimalSerializer.html
│ │ │ │ ├── BlobRef.html
│ │ │ │ ├── BooleanParser.html
│ │ │ │ ├── ClobRef.html
│ │ │ │ ├── DelimiterSet.html
│ │ │ │ ├── FieldFormatter.html
│ │ │ │ ├── FieldMappable.html
│ │ │ │ ├── FieldMapProcessor.html
│ │ │ │ ├── JdbcWritableBridge.html
│ │ │ │ ├── LargeObjectLoader.html
│ │ │ │ ├── LobRef.html
│ │ │ │ ├── LobSerializer.html
│ │ │ │ ├── ProcessingException.html
│ │ │ │ ├── RecordParser.html
│ │ │ │ ├── RecordParser.ParseError.html
│ │ │ │ └── SqoopRecord.html
│ │ │ ├── ClobRef.html
│ │ │ ├── DelimiterSet.html
│ │ │ ├── FieldFormatter.html
│ │ │ ├── FieldMappable.html
│ │ │ ├── FieldMapProcessor.html
│ │ │ ├── JdbcWritableBridge.html
│ │ │ ├── LargeObjectLoader.html
│ │ │ ├── LobRef.html
│ │ │ ├── LobSerializer.html
│ │ │ ├── package-frame.html
│ │ │ ├── package-summary.html
│ │ │ ├── package-tree.html
│ │ │ ├── package-use.html
│ │ │ ├── ProcessingException.html
│ │ │ ├── RecordParser.html
│ │ │ ├── RecordParser.ParseError.html
│ │ │ └── SqoopRecord.html
│ │ ├── constant-values.html
│ │ ├── deprecated-list.html
│ │ ├── help-doc.html
│ │ ├── index-all.html
│ │ ├── index.html
│ │ ├── org
│ │ │ └── apache
│ │ │ └── sqoop
│ │ │ └── lib
│ │ │ ├── BigDecimalSerializer.html
│ │ │ ├── BlobRef.html
│ │ │ ├── BooleanParser.html
│ │ │ ├── class-use
│ │ │ │ ├── BigDecimalSerializer.html
│ │ │ │ ├── BlobRef.html
│ │ │ │ ├── BooleanParser.html
│ │ │ │ ├── ClobRef.html
│ │ │ │ ├── DelimiterSet.html
│ │ │ │ ├── FieldFormatter.html
│ │ │ │ ├── FieldMappable.html
│ │ │ │ ├── FieldMapProcessor.html
│ │ │ │ ├── JdbcWritableBridge.html
│ │ │ │ ├── LargeObjectLoader.html
│ │ │ │ ├── LobRef.html
│ │ │ │ ├── LobSerializer.html
│ │ │ │ ├── ProcessingException.html
│ │ │ │ ├── RecordParser.html
│ │ │ │ ├── RecordParser.ParseError.html
│ │ │ │ └── SqoopRecord.html
│ │ │ ├── ClobRef.html
│ │ │ ├── DelimiterSet.html
│ │ │ ├── FieldFormatter.html
│ │ │ ├── FieldMappable.html
│ │ │ ├── FieldMapProcessor.html
│ │ │ ├── JdbcWritableBridge.html
│ │ │ ├── LargeObjectLoader.html
│ │ │ ├── LobRef.html
│ │ │ ├── LobSerializer.html
│ │ │ ├── package-frame.html
│ │ │ ├── package-summary.html
│ │ │ ├── package-tree.html
│ │ │ ├── package-use.html
│ │ │ ├── ProcessingException.html
│ │ │ ├── RecordParser.html
│ │ │ ├── RecordParser.ParseError.html
│ │ │ └── SqoopRecord.html
│ │ ├── overview-frame.html
│ │ ├── overview-summary.html
│ │ ├── overview-tree.html
│ │ ├── serialized-form.html
│ │ └── stylesheet.css
│ ├── docbook.css
│ ├── images
│ │ ├── callouts
│ │ │ ├── 10.png
│ │ │ ├── 11.png
│ │ │ ├── 12.png
│ │ │ ├── 13.png
│ │ │ ├── 14.png
│ │ │ ├── 15.png
│ │ │ ├── 1.png
│ │ │ ├── 2.png
│ │ │ ├── 3.png
│ │ │ ├── 4.png
│ │ │ ├── 5.png
│ │ │ ├── 6.png
│ │ │ ├── 7.png
│ │ │ ├── 8.png
│ │ │ └── 9.png
│ │ ├── caution.png
│ │ ├── example.png
│ │ ├── home.png
│ │ ├── important.png
│ │ ├── next.png
│ │ ├── note.png
│ │ ├── prev.png
│ │ ├── README
│ │ ├── tip.png
│ │ ├── up.png
│ │ └── warning.png
│ ├── index.html
│ ├── man
│ │ ├── sqoop.1.gz
│ │ ├── sqoop-codegen.1.gz
│ │ ├── sqoop-create-hive-table.1.gz
│ │ ├── sqoop-eval.1.gz
│ │ ├── sqoop-export.1.gz
│ │ ├── sqoop-help.1.gz
│ │ ├── sqoop-import.1.gz
│ │ ├── sqoop-import-all-tables.1.gz
│ │ ├── sqoop-import-mainframe.1.gz
│ │ ├── sqoop-job.1.gz
│ │ ├── sqoop-list-databases.1.gz
│ │ ├── sqoop-list-tables.1.gz
│ │ ├── sqoop-merge.1.gz
│ │ ├── sqoop-metastore.1.gz
│ │ └── sqoop-version.1.gz
│ ├── sqoop-1.4.6.releasenotes.html
│ ├── SqoopDevGuide.html
│ └── SqoopUserGuide.html
├── ivy
│ ├── ivysettings.xml
│ ├── libraries.properties
│ ├── sqoop-test.xml
│ └── sqoop.xml
├── ivy.xml
├── lib
│ ├── ant-contrib-1.0b3.jar
│ ├── ant-eclipse-1.0-jvm1.2.jar
│ ├── avro-1.7.5.jar
│ ├── avro-mapred-1.7.5-hadoop2.jar
│ ├── commons-codec-1.4.jar
│ ├── commons-compress-1.4.1.jar
│ ├── commons-io-1.4.jar
│ ├── commons-jexl-2.1.1.jar
│ ├── commons-logging-1.1.1.jar
│ ├── hsqldb-1.8.0.10.jar
│ ├── jackson-annotations-2.3.0.jar
│ ├── jackson-core-2.3.1.jar
│ ├── jackson-core-asl-1.9.13.jar
│ ├── jackson-databind-2.3.1.jar
│ ├── jackson-mapper-asl-1.9.13.jar
│ ├── kite-data-core-1.0.0.jar
│ ├── kite-data-hive-1.0.0.jar
│ ├── kite-data-mapreduce-1.0.0.jar
│ ├── kite-hadoop-compatibility-1.0.0.jar
│ ├── opencsv-2.3.jar
│ ├── paranamer-2.3.jar
│ ├── parquet-avro-1.4.1.jar
│ ├── parquet-column-1.4.1.jar
│ ├── parquet-common-1.4.1.jar
│ ├── parquet-encoding-1.4.1.jar
│ ├── parquet-format-2.0.0.jar
│ ├── parquet-generator-1.4.1.jar
│ ├── parquet-hadoop-1.4.1.jar
│ ├── parquet-jackson-1.4.1.jar
│ ├── slf4j-api-1.6.1.jar
│ ├── snappy-java-1.0.5.jar
│ └── xz-1.0.jar
├── LICENSE.txt
├── NOTICE.txt
├── pom-old.xml
├── README.txt
├── sqoop-1.4.6.jar
├── sqoop-patch-review.py
├── sqoop-test-1.4.6.jar
├── src
│ ├── docs
│ │ ├── dev
│ │ │ ├── api-reference.txt
│ │ │ ├── compiling.txt
│ │ │ ├── intro.txt
│ │ │ ├── preface.txt
│ │ │ └── SqoopDevGuide.txt
│ │ ├── Makefile
│ │ ├── man
│ │ │ ├── codegen-args.txt
│ │ │ ├── common-args.txt
│ │ │ ├── database-independent-args.txt
│ │ │ ├── hbase-args.txt
│ │ │ ├── hive-args.txt
│ │ │ ├── import-args.txt
│ │ │ ├── import-common-args.txt
│ │ │ ├── input-args.txt
│ │ │ ├── mainframe-connection-args.txt
│ │ │ ├── output-args.txt
│ │ │ ├── sqoop-codegen.txt
│ │ │ ├── sqoop-create-hive-table.txt
│ │ │ ├── sqoop-eval.txt
│ │ │ ├── sqoop-export.txt
│ │ │ ├── sqoop-help.txt
│ │ │ ├── sqoop-import-all-tables.txt
│ │ │ ├── sqoop-import-mainframe.txt
│ │ │ ├── sqoop-import.txt
│ │ │ ├── sqoop-job.txt
│ │ │ ├── sqoop-list-databases.txt
│ │ │ ├── sqoop-list-tables.txt
│ │ │ ├── sqoop-merge.txt
│ │ │ ├── sqoop-metastore.txt
│ │ │ ├── sqoop.txt
│ │ │ └── sqoop-version.txt
│ │ ├── sip
│ │ │ ├── INDEX.txt
│ │ │ ├── README.txt
│ │ │ ├── sip-1.txt
│ │ │ ├── sip-2.txt
│ │ │ ├── sip-3.txt
│ │ │ ├── sip-4.txt
│ │ │ └── sip-6.txt
│ │ ├── user
│ │ │ ├── accumulo-args.txt
│ │ │ ├── accumulo.txt
│ │ │ ├── basics.txt
│ │ │ ├── codegen-args.txt
│ │ │ ├── codegen-purpose.txt
│ │ │ ├── codegen.txt
│ │ │ ├── common-args.txt
│ │ │ ├── compatibility.txt
│ │ │ ├── connecting-to-mainframe.txt
│ │ │ ├── connecting.txt
│ │ │ ├── connectors.txt
│ │ │ ├── controlling-input-format.txt
│ │ │ ├── controlling-output-format.txt
│ │ │ ├── create-hive-table-purpose.txt
│ │ │ ├── create-hive-table.txt
│ │ │ ├── distributed-cache.txt
│ │ │ ├── eval-purpose.txt
│ │ │ ├── eval.txt
│ │ │ ├── export-purpose.txt
│ │ │ ├── export.txt
│ │ │ ├── hbase-args.txt
│ │ │ ├── hbase.txt
│ │ │ ├── hcatalog.txt
│ │ │ ├── help.txt
│ │ │ ├── hive-args.txt
│ │ │ ├── hive-notes.txt
│ │ │ ├── hive.txt
│ │ │ ├── import-all-tables-purpose.txt
│ │ │ ├── import-all-tables.txt
│ │ │ ├── import-mainframe-purpose.txt
│ │ │ ├── import-mainframe.txt
│ │ │ ├── import-purpose.txt
│ │ │ ├── import.txt
│ │ │ ├── input-args.txt
│ │ │ ├── input-formatting-args.txt
│ │ │ ├── input-formatting.txt
│ │ │ ├── intro.txt
│ │ │ ├── job-purpose.txt
│ │ │ ├── list-databases.txt
│ │ │ ├── list-tables.txt
│ │ │ ├── mainframe-common-args.txt
│ │ │ ├── merge-purpose.txt
│ │ │ ├── metastore-purpose.txt
│ │ │ ├── output-args.txt
│ │ │ ├── output-formatting-args.txt
│ │ │ ├── output-formatting.txt
│ │ │ ├── preface.txt
│ │ │ ├── saved-jobs.txt
│ │ │ ├── SqoopUserGuide.txt
│ │ │ ├── support.txt
│ │ │ ├── tools.txt
│ │ │ ├── troubleshooting.txt
│ │ │ ├── validation-args.txt
│ │ │ ├── validation.txt
│ │ │ └── version.txt
│ │ └── web
│ │ ├── breadcrumbs.xsl
│ │ ├── docbook.css
│ │ ├── footer.xsl
│ │ ├── header.xsl
│ │ ├── html.xsl
│ │ ├── images
│ │ │ ├── callouts
│ │ │ │ ├── 10.png
│ │ │ │ ├── 11.png
│ │ │ │ ├── 12.png
│ │ │ │ ├── 13.png
│ │ │ │ ├── 14.png
│ │ │ │ ├── 15.png
│ │ │ │ ├── 1.png
│ │ │ │ ├── 2.png
│ │ │ │ ├── 3.png
│ │ │ │ ├── 4.png
│ │ │ │ ├── 5.png
│ │ │ │ ├── 6.png
│ │ │ │ ├── 7.png
│ │ │ │ ├── 8.png
│ │ │ │ └── 9.png
│ │ │ ├── caution.png
│ │ │ ├── example.png
│ │ │ ├── home.png
│ │ │ ├── important.png
│ │ │ ├── next.png
│ │ │ ├── note.png
│ │ │ ├── prev.png
│ │ │ ├── README
│ │ │ ├── tip.png
│ │ │ ├── up.png
│ │ │ └── warning.png
│ │ └── index.txt
│ ├── java
│ │ ├── com
│ │ │ └── cloudera
│ │ │ └── sqoop
│ │ │ ├── cli
│ │ │ │ ├── RelatedOptions.java
│ │ │ │ ├── SqoopParser.java
│ │ │ │ └── ToolOptions.java
│ │ │ ├── config
│ │ │ │ ├── ConfigurationConstants.java
│ │ │ │ └── ConfigurationHelper.java
│ │ │ ├── ConnFactory.java
│ │ │ ├── hbase
│ │ │ │ ├── HBasePutProcessor.java
│ │ │ │ ├── HBaseUtil.java
│ │ │ │ ├── PutTransformer.java
│ │ │ │ └── ToStringPutTransformer.java
│ │ │ ├── hive
│ │ │ │ ├── HiveImport.java
│ │ │ │ ├── HiveTypes.java
│ │ │ │ └── TableDefWriter.java
│ │ │ ├── io
│ │ │ │ ├── CodecMap.java
│ │ │ │ ├── FixedLengthInputStream.java
│ │ │ │ ├── LobFile.java
│ │ │ │ ├── LobReaderCache.java
│ │ │ │ ├── NamedFifo.java
│ │ │ │ ├── SplittableBufferedWriter.java
│ │ │ │ ├── SplittingOutputStream.java
│ │ │ │ └── UnsupportedCodecException.java
│ │ │ ├── lib
│ │ │ │ ├── BigDecimalSerializer.java
│ │ │ │ ├── BlobRef.java
│ │ │ │ ├── BooleanParser.java
│ │ │ │ ├── ClobRef.java
│ │ │ │ ├── DelimiterSet.java
│ │ │ │ ├── FieldFormatter.java
│ │ │ │ ├── FieldMappable.java
│ │ │ │ ├── FieldMapProcessor.java
│ │ │ │ ├── JdbcWritableBridge.java
│ │ │ │ ├── LargeObjectLoader.java
│ │ │ │ ├── LobRef.java
│ │ │ │ ├── LobSerializer.java
│ │ │ │ ├── ProcessingException.java
│ │ │ │ ├── RecordParser.java
│ │ │ │ └── SqoopRecord.java
│ │ │ ├── manager
│ │ │ │ ├── CatalogQueryManager.java
│ │ │ │ ├── ConnManager.java
│ │ │ │ ├── Db2Manager.java
│ │ │ │ ├── DefaultManagerFactory.java
│ │ │ │ ├── DirectMySQLManager.java
│ │ │ │ ├── DirectPostgresqlManager.java
│ │ │ │ ├── ExportJobContext.java
│ │ │ │ ├── GenericJdbcManager.java
│ │ │ │ ├── HsqldbManager.java
│ │ │ │ ├── ImportJobContext.java
│ │ │ │ ├── InformationSchemaManager.java
│ │ │ │ ├── ManagerFactory.java
│ │ │ │ ├── MySQLManager.java
│ │ │ │ ├── MySQLUtils.java
│ │ │ │ ├── OracleManager.java
│ │ │ │ ├── PostgresqlManager.java
│ │ │ │ ├── SqlManager.java
│ │ │ │ └── SQLServerManager.java
│ │ │ ├── mapreduce
│ │ │ │ ├── AsyncSqlOutputFormat.java
│ │ │ │ ├── AsyncSqlRecordWriter.java
│ │ │ │ ├── AutoProgressMapper.java
│ │ │ │ ├── AvroExportMapper.java
│ │ │ │ ├── AvroImportMapper.java
│ │ │ │ ├── AvroInputFormat.java
│ │ │ │ ├── AvroJob.java
│ │ │ │ ├── AvroOutputFormat.java
│ │ │ │ ├── AvroRecordReader.java
│ │ │ │ ├── CombineShimRecordReader.java
│ │ │ │ ├── DataDrivenImportJob.java
│ │ │ │ ├── db
│ │ │ │ │ ├── BigDecimalSplitter.java
│ │ │ │ │ ├── BooleanSplitter.java
│ │ │ │ │ ├── DataDrivenDBInputFormat.java
│ │ │ │ │ ├── DataDrivenDBRecordReader.java
│ │ │ │ │ ├── DateSplitter.java
│ │ │ │ │ ├── DBConfiguration.java
│ │ │ │ │ ├── DBInputFormat.java
│ │ │ │ │ ├── DBOutputFormat.java
│ │ │ │ │ ├── DBRecordReader.java
│ │ │ │ │ ├── DBSplitter.java
│ │ │ │ │ ├── FloatSplitter.java
│ │ │ │ │ ├── IntegerSplitter.java
│ │ │ │ │ ├── OracleDataDrivenDBInputFormat.java
│ │ │ │ │ ├── OracleDataDrivenDBRecordReader.java
│ │ │ │ │ ├── OracleDateSplitter.java
│ │ │ │ │ ├── OracleDBRecordReader.java
│ │ │ │ │ └── TextSplitter.java
│ │ │ │ ├── DelegatingOutputFormat.java
│ │ │ │ ├── ExportBatchOutputFormat.java
│ │ │ │ ├── ExportInputFormat.java
│ │ │ │ ├── ExportJobBase.java
│ │ │ │ ├── ExportOutputFormat.java
│ │ │ │ ├── HBaseImportJob.java
│ │ │ │ ├── HBaseImportMapper.java
│ │ │ │ ├── ImportJobBase.java
│ │ │ │ ├── JdbcExportJob.java
│ │ │ │ ├── JdbcUpdateExportJob.java
│ │ │ │ ├── JdbcUpsertExportJob.java
│ │ │ │ ├── JobBase.java
│ │ │ │ ├── MergeJob.java
│ │ │ │ ├── MergeMapperBase.java
│ │ │ │ ├── MergeRecord.java
│ │ │ │ ├── MergeRecordMapper.java
│ │ │ │ ├── MergeReducer.java
│ │ │ │ ├── MergeTextMapper.java
│ │ │ │ ├── MySQLDumpImportJob.java
│ │ │ │ ├── MySQLDumpInputFormat.java
│ │ │ │ ├── MySQLDumpMapper.java
│ │ │ │ ├── MySQLExportJob.java
│ │ │ │ ├── MySQLExportMapper.java
│ │ │ │ ├── MySQLRecordExportMapper.java
│ │ │ │ ├── MySQLTextExportMapper.java
│ │ │ │ ├── NullOutputCommitter.java
│ │ │ │ ├── OracleExportOutputFormat.java
│ │ │ │ ├── OracleUpsertOutputFormat.java
│ │ │ │ ├── RawKeyTextOutputFormat.java
│ │ │ │ ├── SequenceFileExportMapper.java
│ │ │ │ ├── SequenceFileImportMapper.java
│ │ │ │ ├── SQLServerExportOutputFormat.java
│ │ │ │ ├── TextExportMapper.java
│ │ │ │ ├── TextImportMapper.java
│ │ │ │ └── UpdateOutputFormat.java
│ │ │ ├── metastore
│ │ │ │ ├── hsqldb
│ │ │ │ │ ├── AutoHsqldbStorage.java
│ │ │ │ │ ├── HsqldbJobStorage.java
│ │ │ │ │ └── HsqldbMetaStore.java
│ │ │ │ ├── JobData.java
│ │ │ │ ├── JobStorageFactory.java
│ │ │ │ └── JobStorage.java
│ │ │ ├── orm
│ │ │ │ ├── AvroSchemaGenerator.java
│ │ │ │ ├── ClassWriter.java
│ │ │ │ ├── CompilationManager.java
│ │ │ │ └── TableClassName.java
│ │ │ ├── Sqoop.java
│ │ │ ├── SqoopOptions.java
│ │ │ ├── tool
│ │ │ │ ├── BaseSqoopTool.java
│ │ │ │ ├── CodeGenTool.java
│ │ │ │ ├── CreateHiveTableTool.java
│ │ │ │ ├── EvalSqlTool.java
│ │ │ │ ├── ExportTool.java
│ │ │ │ ├── HelpTool.java
│ │ │ │ ├── ImportAllTablesTool.java
│ │ │ │ ├── ImportTool.java
│ │ │ │ ├── JobTool.java
│ │ │ │ ├── ListDatabasesTool.java
│ │ │ │ ├── ListTablesTool.java
│ │ │ │ ├── MergeTool.java
│ │ │ │ ├── MetastoreTool.java
│ │ │ │ ├── SqoopTool.java
│ │ │ │ ├── ToolDesc.java
│ │ │ │ ├── ToolPlugin.java
│ │ │ │ └── VersionTool.java
│ │ │ └── util
│ │ │ ├── AppendUtils.java
│ │ │ ├── AsyncSink.java
│ │ │ ├── ClassLoaderStack.java
│ │ │ ├── DirectImportUtils.java
│ │ │ ├── ErrorableAsyncSink.java
│ │ │ ├── ErrorableThread.java
│ │ │ ├── Executor.java
│ │ │ ├── ExitSecurityException.java
│ │ │ ├── ExportException.java
│ │ │ ├── FileListing.java
│ │ │ ├── ImportException.java
│ │ │ ├── Jars.java
│ │ │ ├── JdbcUrl.java
│ │ │ ├── LoggingAsyncSink.java
│ │ │ ├── LoggingUtils.java
│ │ │ ├── NullAsyncSink.java
│ │ │ ├── OptionsFileUtil.java
│ │ │ ├── PerfCounters.java
│ │ │ ├── RandomHash.java
│ │ │ ├── ResultSetPrinter.java
│ │ │ ├── StoredAsProperty.java
│ │ │ ├── SubprocessSecurityManager.java
│ │ │ └── TaskId.java
│ │ └── org
│ │ └── apache
│ │ └── sqoop
│ │ ├── accumulo
│ │ │ ├── AccumuloConstants.java
│ │ │ ├── AccumuloMutationProcessor.java
│ │ │ ├── AccumuloUtil.java
│ │ │ ├── MutationTransformer.java
│ │ │ └── ToStringMutationTransformer.java
│ │ ├── avro
│ │ │ └── AvroUtil.java
│ │ ├── cli
│ │ │ ├── RelatedOptions.java
│ │ │ ├── SqoopParser.java
│ │ │ └── ToolOptions.java
│ │ ├── config
│ │ │ ├── ConfigurationConstants.java
│ │ │ └── ConfigurationHelper.java
│ │ ├── ConnFactory.java
│ │ ├── hbase
│ │ │ ├── HBasePutProcessor.java
│ │ │ ├── HBaseUtil.java
│ │ │ ├── PutTransformer.java
│ │ │ └── ToStringPutTransformer.java
│ │ ├── hive
│ │ │ ├── HiveImport.java
│ │ │ ├── HiveTypes.java
│ │ │ └── TableDefWriter.java
│ │ ├── io
│ │ │ ├── CodecMap.java
│ │ │ ├── FixedLengthInputStream.java
│ │ │ ├── LobFile.java
│ │ │ ├── LobReaderCache.java
│ │ │ ├── NamedFifo.java
│ │ │ ├── SplittableBufferedWriter.java
│ │ │ ├── SplittingOutputStream.java
│ │ │ └── UnsupportedCodecException.java
│ │ ├── lib
│ │ │ ├── BigDecimalSerializer.java
│ │ │ ├── BlobRef.java
│ │ │ ├── BooleanParser.java
│ │ │ ├── ClobRef.java
│ │ │ ├── DelimiterSet.java
│ │ │ ├── FieldFormatter.java
│ │ │ ├── FieldMappable.java
│ │ │ ├── FieldMapProcessor.java
│ │ │ ├── JdbcWritableBridge.java
│ │ │ ├── LargeObjectLoader.java
│ │ │ ├── LobRef.java
│ │ │ ├── LobSerializer.java
│ │ │ ├── ProcessingException.java
│ │ │ ├── RecordParser.java
│ │ │ └── SqoopRecord.java
│ │ ├── manager
│ │ │ ├── CatalogQueryManager.java
│ │ │ ├── ConnManager.java
│ │ │ ├── CubridManager.java
│ │ │ ├── Db2Manager.java
│ │ │ ├── DefaultManagerFactory.java
│ │ │ ├── DirectMySQLManager.java
│ │ │ ├── DirectNetezzaManager.java
│ │ │ ├── DirectPostgresqlManager.java
│ │ │ ├── ExportJobContext.java
│ │ │ ├── GenericJdbcManager.java
│ │ │ ├── HsqldbManager.java
│ │ │ ├── ImportJobContext.java
│ │ │ ├── InformationSchemaManager.java
│ │ │ ├── MainframeManager.java
│ │ │ ├── ManagerFactory.java
│ │ │ ├── MySQLManager.java
│ │ │ ├── MySQLUtils.java
│ │ │ ├── NetezzaManager.java
│ │ │ ├── oracle
│ │ │ │ ├── OracleActiveInstance.java
│ │ │ │ ├── OracleConnectionFactory.java
│ │ │ │ ├── OracleTableColumn.java
│ │ │ │ ├── OracleTableColumns.java
│ │ │ │ ├── OracleTable.java
│ │ │ │ ├── OracleTablePartition.java
│ │ │ │ ├── OracleTablePartitions.java
│ │ │ │ ├── OracleVersion.java
│ │ │ │ ├── OraOopConnManager.java
│ │ │ │ ├── OraOopConstants.java
│ │ │ │ ├── OraOopDataDrivenDBInputFormat.java
│ │ │ │ ├── OraOopDBInputSplit.java
│ │ │ │ ├── OraOopDBRecordReader.java
│ │ │ │ ├── OraOopGenerics.java
│ │ │ │ ├── OraOopJdbcUrl.java
│ │ │ │ ├── OraOopLogFactory.java
│ │ │ │ ├── OraOopLog.java
│ │ │ │ ├── OraOopLogMessage.java
│ │ │ │ ├── OraOopManagerFactory.java
│ │ │ │ ├── OraOopOracleDataChunkExtent.java
│ │ │ │ ├── OraOopOracleDataChunk.java
│ │ │ │ ├── OraOopOracleDataChunkPartition.java
│ │ │ │ ├── OraOopOracleQueries.java
│ │ │ │ ├── OraOopOutputFormatBase.java
│ │ │ │ ├── OraOopOutputFormatInsert.java
│ │ │ │ ├── OraOopOutputFormatUpdate.java
│ │ │ │ └── OraOopUtilities.java
│ │ │ ├── OracleManager.java
│ │ │ ├── PGBulkloadManager.java
│ │ │ ├── PostgresqlManager.java
│ │ │ ├── SqlManager.java
│ │ │ └── SQLServerManager.java
│ │ ├── mapreduce
│ │ │ ├── AccumuloImportJob.java
│ │ │ ├── AccumuloImportMapper.java
│ │ │ ├── AsyncSqlOutputFormat.java
│ │ │ ├── AsyncSqlRecordWriter.java
│ │ │ ├── AutoProgressMapper.java
│ │ │ ├── AutoProgressReducer.java
│ │ │ ├── AvroExportMapper.java
│ │ │ ├── AvroImportMapper.java
│ │ │ ├── AvroInputFormat.java
│ │ │ ├── AvroJob.java
│ │ │ ├── AvroOutputFormat.java
│ │ │ ├── AvroRecordReader.java
│ │ │ ├── CombineFileInputFormat.java
│ │ │ ├── CombineFileRecordReader.java
│ │ │ ├── CombineFileSplit.java
│ │ │ ├── CombineShimRecordReader.java
│ │ │ ├── cubrid
│ │ │ │ └── CubridUpsertOutputFormat.java
│ │ │ ├── DataDrivenImportJob.java
│ │ │ ├── db
│ │ │ │ ├── BasicRetrySQLFailureHandler.java
│ │ │ │ ├── BigDecimalSplitter.java
│ │ │ │ ├── BooleanSplitter.java
│ │ │ │ ├── DataDrivenDBInputFormat.java
│ │ │ │ ├── DataDrivenDBRecordReader.java
│ │ │ │ ├── DateSplitter.java
│ │ │ │ ├── Db2DataDrivenDBInputFormat.java
│ │ │ │ ├── Db2DataDrivenDBRecordReader.java
│ │ │ │ ├── Db2DBRecordReader.java
│ │ │ │ ├── DBConfiguration.java
│ │ │ │ ├── DBInputFormat.java
│ │ │ │ ├── DBOutputFormat.java
│ │ │ │ ├── DBRecordReader.java
│ │ │ │ ├── DBSplitter.java
│ │ │ │ ├── FloatSplitter.java
│ │ │ │ ├── IntegerSplitter.java
│ │ │ │ ├── netezza
│ │ │ │ │ ├── NetezzaDBDataSliceSplitter.java
│ │ │ │ │ ├── NetezzaExternalTableExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableHCatExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableHCatImportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableImportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableRecordExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableTextExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableTextImportMapper.java
│ │ │ │ │ └── NetezzaJDBCStatementRunner.java
│ │ │ │ ├── NTextSplitter.java
│ │ │ │ ├── OracleDataDrivenDBInputFormat.java
│ │ │ │ ├── OracleDataDrivenDBRecordReader.java
│ │ │ │ ├── OracleDateSplitter.java
│ │ │ │ ├── OracleDBRecordReader.java
│ │ │ │ ├── SQLFailureHandler.java
│ │ │ │ ├── SQLServerConnectionFailureHandler.java
│ │ │ │ ├── SQLServerDBInputFormat.java
│ │ │ │ ├── SQLServerDBRecordReader.java
│ │ │ │ └── TextSplitter.java
│ │ │ ├── DBWritable.java
│ │ │ ├── DelegatingOutputFormat.java
│ │ │ ├── ExportBatchOutputFormat.java
│ │ │ ├── ExportCallOutputFormat.java
│ │ │ ├── ExportInputFormat.java
│ │ │ ├── ExportJobBase.java
│ │ │ ├── ExportOutputFormat.java
│ │ │ ├── GenericRecordExportMapper.java
│ │ │ ├── HBaseBulkImportJob.java
│ │ │ ├── HBaseBulkImportMapper.java
│ │ │ ├── HBaseImportJob.java
│ │ │ ├── HBaseImportMapper.java
│ │ │ ├── hcat
│ │ │ │ ├── SqoopHCatExportFormat.java
│ │ │ │ ├── SqoopHCatExportHelper.java
│ │ │ │ ├── SqoopHCatExportMapper.java
│ │ │ │ ├── SqoopHCatImportHelper.java
│ │ │ │ ├── SqoopHCatImportMapper.java
│ │ │ │ ├── SqoopHCatInputSplit.java
│ │ │ │ ├── SqoopHCatRecordReader.java
│ │ │ │ └── SqoopHCatUtilities.java
│ │ │ ├── ImportJobBase.java
│ │ │ ├── JdbcCallExportJob.java
│ │ │ ├── JdbcExportJob.java
│ │ │ ├── JdbcUpdateExportJob.java
│ │ │ ├── JdbcUpsertExportJob.java
│ │ │ ├── JobBase.java
│ │ │ ├── mainframe
│ │ │ │ ├── MainframeConfiguration.java
│ │ │ │ ├── MainframeDatasetFTPRecordReader.java
│ │ │ │ ├── MainframeDatasetImportMapper.java
│ │ │ │ ├── MainframeDatasetInputFormat.java
│ │ │ │ ├── MainframeDatasetInputSplit.java
│ │ │ │ ├── MainframeDatasetRecordReader.java
│ │ │ │ └── MainframeImportJob.java
│ │ │ ├── MergeJob.java
│ │ │ ├── MergeMapperBase.java
│ │ │ ├── MergeRecord.java
│ │ │ ├── MergeRecordMapper.java
│ │ │ ├── MergeReducer.java
│ │ │ ├── MergeTextMapper.java
│ │ │ ├── mysql
│ │ │ │ └── MySQLUpsertOutputFormat.java
│ │ │ ├── MySQLDumpImportJob.java
│ │ │ ├── MySQLDumpInputFormat.java
│ │ │ ├── MySQLDumpMapper.java
│ │ │ ├── MySQLExportJob.java
│ │ │ ├── MySQLExportMapper.java
│ │ │ ├── MySQLRecordExportMapper.java
│ │ │ ├── MySQLTextExportMapper.java
│ │ │ ├── netezza
│ │ │ │ ├── NetezzaDataDrivenDBInputFormat.java
│ │ │ │ ├── NetezzaExternalTableExportJob.java
│ │ │ │ ├── NetezzaExternalTableImportJob.java
│ │ │ │ ├── NetezzaExternalTableInputFormat.java
│ │ │ │ └── NetezzaExternalTableInputSplit.java
│ │ │ ├── NullOutputCommitter.java
│ │ │ ├── OracleExportOutputFormat.java
│ │ │ ├── OracleUpsertOutputFormat.java
│ │ │ ├── ParquetExportMapper.java
│ │ │ ├── ParquetImportMapper.java
│ │ │ ├── ParquetJob.java
│ │ │ ├── postgresql
│ │ │ │ ├── PGBulkloadExportJob.java
│ │ │ │ ├── PGBulkloadExportMapper.java
│ │ │ │ ├── PGBulkloadExportReducer.java
│ │ │ │ ├── PostgreSQLCopyExportJob.java
│ │ │ │ └── PostgreSQLCopyExportMapper.java
│ │ │ ├── ProgressThread.java
│ │ │ ├── RawKeyTextOutputFormat.java
│ │ │ ├── SequenceFileExportMapper.java
│ │ │ ├── SequenceFileImportMapper.java
│ │ │ ├── sqlserver
│ │ │ │ ├── SqlServerExportBatchOutputFormat.java
│ │ │ │ ├── SqlServerInputFormat.java
│ │ │ │ ├── SqlServerRecordReader.java
│ │ │ │ └── SqlServerUpsertOutputFormat.java
│ │ │ ├── SQLServerAsyncDBExecThread.java
│ │ │ ├── SQLServerExportDBExecThread.java
│ │ │ ├── SQLServerExportOutputFormat.java
│ │ │ ├── SQLServerResilientExportOutputFormat.java
│ │ │ ├── SQLServerResilientUpdateOutputFormat.java
│ │ │ ├── SQLServerUpdateDBExecThread.java
│ │ │ ├── SqoopMapper.java
│ │ │ ├── SqoopReducer.java
│ │ │ ├── TextExportMapper.java
│ │ │ ├── TextImportMapper.java
│ │ │ └── UpdateOutputFormat.java
│ │ ├── metastore
│ │ │ ├── hsqldb
│ │ │ │ ├── AutoHsqldbStorage.java
│ │ │ │ ├── HsqldbJobStorage.java
│ │ │ │ └── HsqldbMetaStore.java
│ │ │ ├── JobData.java
│ │ │ ├── JobStorageFactory.java
│ │ │ └── JobStorage.java
│ │ ├── orm
│ │ │ ├── AvroSchemaGenerator.java
│ │ │ ├── ClassWriter.java
│ │ │ ├── CompilationManager.java
│ │ │ └── TableClassName.java
│ │ ├── Sqoop.java
│ │ ├── SqoopOptions.java
│ │ ├── tool
│ │ │ ├── BaseSqoopTool.java
│ │ │ ├── CodeGenTool.java
│ │ │ ├── CreateHiveTableTool.java
│ │ │ ├── EvalSqlTool.java
│ │ │ ├── ExportTool.java
│ │ │ ├── HelpTool.java
│ │ │ ├── ImportAllTablesTool.java
│ │ │ ├── ImportTool.java
│ │ │ ├── JobTool.java
│ │ │ ├── ListDatabasesTool.java
│ │ │ ├── ListTablesTool.java
│ │ │ ├── MainframeImportTool.java
│ │ │ ├── MergeTool.java
│ │ │ ├── MetastoreTool.java
│ │ │ ├── SqoopTool.java
│ │ │ ├── ToolDesc.java
│ │ │ ├── ToolPlugin.java
│ │ │ └── VersionTool.java
│ │ ├── util
│ │ │ ├── AppendUtils.java
│ │ │ ├── AsyncSink.java
│ │ │ ├── ClassLoaderStack.java
│ │ │ ├── CredentialsUtil.java
│ │ │ ├── DirectImportUtils.java
│ │ │ ├── ErrorableAsyncSink.java
│ │ │ ├── ErrorableThread.java
│ │ │ ├── Executor.java
│ │ │ ├── ExitSecurityException.java
│ │ │ ├── ExportException.java
│ │ │ ├── FileListing.java
│ │ │ ├── FileUploader.java
│ │ │ ├── ImportException.java
│ │ │ ├── Jars.java
│ │ │ ├── JdbcUrl.java
│ │ │ ├── LoggingAsyncSink.java
│ │ │ ├── LoggingUtils.java
│ │ │ ├── MainframeFTPClientUtils.java
│ │ │ ├── NullAsyncSink.java
│ │ │ ├── OptionsFileUtil.java
│ │ │ ├── password
│ │ │ │ ├── CredentialProviderHelper.java
│ │ │ │ ├── CredentialProviderPasswordLoader.java
│ │ │ │ ├── CryptoFileLoader.java
│ │ │ │ ├── FilePasswordLoader.java
│ │ │ │ └── PasswordLoader.java
│ │ │ ├── PerfCounters.java
│ │ │ ├── PostgreSQLUtils.java
│ │ │ ├── RandomHash.java
│ │ │ ├── ResultSetPrinter.java
│ │ │ ├── SqlTypeMap.java
│ │ │ ├── StoredAsProperty.java
│ │ │ ├── SubprocessSecurityManager.java
│ │ │ ├── SubstitutionUtils.java
│ │ │ └── TaskId.java
│ │ └── validation
│ │ ├── AbortOnFailureHandler.java
│ │ ├── AbsoluteValidationThreshold.java
│ │ ├── LogOnFailureHandler.java
│ │ ├── RowCountValidator.java
│ │ ├── ValidationContext.java
│ │ ├── ValidationException.java
│ │ ├── ValidationFailureHandler.java
│ │ ├── ValidationThreshold.java
│ │ └── Validator.java
│ ├── perftest
│ │ ├── ExportStressTest.java
│ │ ├── ExtConnFactoryTest.java
│ │ ├── ExtFactory.java
│ │ ├── LobFilePerfTest.java
│ │ ├── LobFileStressTest.java
│ │ └── README-perftest.txt
│ ├── scripts
│ │ ├── create-tool-scripts.cmd
│ │ ├── create-tool-scripts.sh
│ │ ├── hudson
│ │ │ ├── run-code-quality.sh
│ │ │ ├── run-tests.sh
│ │ │ └── test-config.sh
│ │ ├── rat-violations.sh
│ │ ├── relnotes.py
│ │ ├── run-perftest.sh
│ │ ├── tool-script.cmd.template
│ │ ├── tool-script.sh.template
│ │ ├── write-version-info.cmd
│ │ └── write-version-info.sh
│ └── test
│ ├── aop
│ │ ├── build
│ │ │ └── aop.xml
│ │ └── org
│ │ └── apache
│ │ └── sqoop
│ │ ├── fi
│ │ │ ├── FiConfig.java
│ │ │ └── ProbabilityModel.java
│ │ └── mapreduce
│ │ ├── db
│ │ │ └── SqlServerImportAspect.aj
│ │ └── SqlServerExportAspect.aj
│ ├── checkstyle-java-header.txt
│ ├── checkstyle-noframes.xsl
│ ├── checkstyle.xml
│ ├── com
│ │ └── cloudera
│ │ └── sqoop
│ │ ├── AllTests.java
│ │ ├── hbase
│ │ │ ├── HBaseImportAddRowKeyTest.java
│ │ │ ├── HBaseImportNullTest.java
│ │ │ ├── HBaseImportTest.java
│ │ │ ├── HBaseImportTypesTest.java
│ │ │ ├── HBaseQueryImportTest.java
│ │ │ ├── HBaseTestCase.java
│ │ │ └── HBaseUtilTest.java
│ │ ├── hive
│ │ │ ├── TestHiveImport.java
│ │ │ └── TestTableDefWriter.java
│ │ ├── io
│ │ │ ├── TestCodecMap.java
│ │ │ ├── TestLobFile.java
│ │ │ ├── TestNamedFifo.java
│ │ │ └── TestSplittableBufferedWriter.java
│ │ ├── lib
│ │ │ ├── TestBlobRef.java
│ │ │ ├── TestBooleanParser.java
│ │ │ ├── TestClobRef.java
│ │ │ ├── TestFieldFormatter.java
│ │ │ ├── TestLargeObjectLoader.java
│ │ │ └── TestRecordParser.java
│ │ ├── manager
│ │ │ ├── CubridManagerExportTest.java
│ │ │ ├── CubridManagerImportTest.java
│ │ │ ├── DB2ManagerImportManualTest.java
│ │ │ ├── DirectMySQLExportTest.java
│ │ │ ├── DirectMySQLTest.java
│ │ │ ├── DirectPostgreSQLExportManualTest.java
│ │ │ ├── JdbcMySQLExportTest.java
│ │ │ ├── ManualMySQLTests.java
│ │ │ ├── MySQLAllTablesTest.java
│ │ │ ├── MySQLAuthTest.java
│ │ │ ├── MySQLCompatTest.java
│ │ │ ├── MySQLFreeFormQueryTest.java
│ │ │ ├── MySQLLobAvroImportTest.java
│ │ │ ├── MySQLTestUtils.java
│ │ │ ├── OracleCompatTest.java
│ │ │ ├── OracleExportTest.java
│ │ │ ├── OracleFreeFormQueryTest.java
│ │ │ ├── OracleLobAvroImportTest.java
│ │ │ ├── OracleManagerTest.java
│ │ │ ├── OracleUtils.java
│ │ │ ├── PGBulkloadManagerManualTest.java
│ │ │ ├── PostgresqlExportTest.java
│ │ │ ├── PostgresqlImportTest.java
│ │ │ ├── SQLServerManagerExportManualTest.java
│ │ │ ├── SQLServerManagerImportManualTest.java
│ │ │ ├── TestHsqldbManager.java
│ │ │ └── TestSqlManager.java
│ │ ├── mapreduce
│ │ │ ├── db
│ │ │ │ ├── TestDataDrivenDBInputFormat.java
│ │ │ │ ├── TestIntegerSplitter.java
│ │ │ │ └── TestTextSplitter.java
│ │ │ ├── MapreduceTests.java
│ │ │ └── TestImportJob.java
│ │ ├── metastore
│ │ │ └── TestSavedJobs.java
│ │ ├── orm
│ │ │ ├── TestClassWriter.java
│ │ │ └── TestParseMethods.java
│ │ ├── SmokeTests.java
│ │ ├── TestAllTables.java
│ │ ├── TestAppendUtils.java
│ │ ├── TestAvroExport.java
│ │ ├── TestAvroImportExportRoundtrip.java
│ │ ├── TestAvroImport.java
│ │ ├── TestBoundaryQuery.java
│ │ ├── TestColumnTypes.java
│ │ ├── TestCompression.java
│ │ ├── TestConnFactory.java
│ │ ├── TestExport.java
│ │ ├── TestExportUpdate.java
│ │ ├── TestFreeFormQueryImport.java
│ │ ├── TestIncrementalImport.java
│ │ ├── TestMerge.java
│ │ ├── TestMultiCols.java
│ │ ├── TestMultiMaps.java
│ │ ├── TestParquetExport.java
│ │ ├── TestParquetImport.java
│ │ ├── TestQuery.java
│ │ ├── TestSplitBy.java
│ │ ├── TestSqoopOptions.java
│ │ ├── TestTargetDir.java
│ │ ├── testutil
│ │ │ ├── BaseSqoopTestCase.java
│ │ │ ├── CommonArgs.java
│ │ │ ├── DirUtil.java
│ │ │ ├── ExplicitSetMapper.java
│ │ │ ├── ExportJobTestCase.java
│ │ │ ├── HsqldbTestServer.java
│ │ │ ├── ImportJobTestCase.java
│ │ │ ├── InjectableConnManager.java
│ │ │ ├── InjectableManagerFactory.java
│ │ │ ├── LobAvroImportTestCase.java
│ │ │ ├── ManagerCompatTestCase.java
│ │ │ ├── MockResultSet.java
│ │ │ ├── ReparseMapper.java
│ │ │ └── SeqFileReader.java
│ │ ├── TestWhere.java
│ │ ├── ThirdPartyTests.java
│ │ ├── tool
│ │ │ └── TestToolPlugin.java
│ │ └── util
│ │ ├── TestOptionsFileExpansion.java
│ │ └── TestSubstitutionUtils.java
│ ├── findbugsExcludeFile.xml
│ ├── fi-site.xml
│ ├── oraoop
│ │ ├── create_users.sql
│ │ ├── pkg_tst_product_gen.pbk
│ │ ├── pkg_tst_product_gen.psk
│ │ ├── table_tst_product_part_iot.xml
│ │ ├── table_tst_product_part.xml
│ │ ├── table_tst_product_special_chars.xml
│ │ ├── table_tst_product_subpart.xml
│ │ └── table_tst_product.xml
│ └── org
│ └── apache
│ └── sqoop
│ ├── accumulo
│ │ ├── AccumuloTestCase.java
│ │ ├── TestAccumuloImport.java
│ │ ├── TestAccumuloQueryImport.java
│ │ └── TestAccumuloUtil.java
│ ├── credentials
│ │ └── TestPassingSecurePassword.java
│ ├── hcat
│ │ ├── HCatalogExportTest.java
│ │ ├── HCatalogImportTest.java
│ │ ├── HCatalogTestUtils.java
│ │ └── TestHCatalogBasic.java
│ ├── manager
│ │ ├── cubrid
│ │ │ ├── CubridAuthTest.java
│ │ │ ├── CubridCompatTest.java
│ │ │ └── CubridTestUtils.java
│ │ ├── mysql
│ │ │ └── MySqlCallExportTest.java
│ │ ├── netezza
│ │ │ ├── DirectNetezzaExportManualTest.java
│ │ │ ├── DirectNetezzaHCatExportManualTest.java
│ │ │ ├── DirectNetezzaHCatImportManualTest.java
│ │ │ ├── NetezzaExportManualTest.java
│ │ │ ├── NetezzaImportManualTest.java
│ │ │ └── NetezzaTestUtils.java
│ │ ├── oracle
│ │ │ ├── ExportTest.java
│ │ │ ├── ImportTest.java
│ │ │ ├── OracleCallExportTest.java
│ │ │ ├── OracleConnectionFactoryTest.java
│ │ │ ├── OracleIncrementalImportTest.java
│ │ │ ├── OraOopOracleQueriesTest.java
│ │ │ ├── OraOopTestCase.java
│ │ │ ├── OraOopTestConstants.java
│ │ │ ├── SystemImportTest.java
│ │ │ ├── TestOracleTable.java
│ │ │ ├── TestOraOopDataDrivenDBInputFormat.java
│ │ │ ├── TestOraOopJdbcUrl.java
│ │ │ ├── TestOraOopUtilities.java
│ │ │ ├── TimestampDataTest.java
│ │ │ └── util
│ │ │ ├── BigDecimalGenerator.java
│ │ │ ├── BinaryDoubleGenerator.java
│ │ │ ├── BinaryFloatGenerator.java
│ │ │ ├── BlobGenerator.java
│ │ │ ├── BytesGenerator.java
│ │ │ ├── CharGenerator.java
│ │ │ ├── FloatGenerator.java
│ │ │ ├── HadoopFiles.java
│ │ │ ├── IntervalDaySecondGenerator.java
│ │ │ ├── IntervalYearMonthGenerator.java
│ │ │ ├── NCharGenerator.java
│ │ │ ├── OracleDataDefinition.java
│ │ │ ├── OracleData.java
│ │ │ ├── OracleTableDefinition.java
│ │ │ ├── OraOopTestDataGenerator.java
│ │ │ ├── OraOopTestUtils.java
│ │ │ ├── RowIdGenerator.java
│ │ │ ├── TimestampGenerator.java
│ │ │ └── URIGenerator.java
│ │ ├── sqlserver
│ │ │ ├── ManagerCompatExport.java
│ │ │ ├── MSSQLTestDataFileParser.java
│ │ │ ├── MSSQLTestData.java
│ │ │ ├── MSSQLTestUtils.java
│ │ │ ├── SQLServerDatatypeExportDelimitedFileManualTest.java
│ │ │ ├── SQLServerDatatypeExportSequenceFileManualTest.java
│ │ │ ├── SQLServerDatatypeImportDelimitedFileManualTest.java
│ │ │ ├── SQLServerDatatypeImportSequenceFileManualTest.java
│ │ │ ├── SQLServerHiveImportManualTest.java
│ │ │ ├── SQLServerManagerManualTest.java
│ │ │ ├── SQLServerMultiColsManualTest.java
│ │ │ ├── SQLServerMultiMapsManualTest.java
│ │ │ ├── SQLServerParseMethodsManualTest.java
│ │ │ ├── SQLServerQueryManualTest.java
│ │ │ ├── SQLServerSplitByManualTest.java
│ │ │ └── SQLServerWhereManualTest.java
│ │ └── TestMainframeManager.java
│ ├── mapreduce
│ │ ├── db
│ │ │ ├── TestBigDecimalSplitter.java
│ │ │ ├── TestDBConfiguration.java
│ │ │ ├── TestIntegerSplitter.java
│ │ │ └── TestTextSplitter.java
│ │ ├── mainframe
│ │ │ ├── TestMainframeDatasetFTPRecordReader.java
│ │ │ ├── TestMainframeDatasetInputFormat.java
│ │ │ ├── TestMainframeDatasetInputSplit.java
│ │ │ └── TestMainframeImportJob.java
│ │ └── sqlserver
│ │ └── SqlServerUpsertOutputFormatTest.java
│ ├── TestAutoResetMapper.java
│ ├── TestBigDecimalExport.java
│ ├── TestBigDecimalImport.java
│ ├── TestExportUsingProcedure.java
│ ├── tool
│ │ └── TestMainframeImportTool.java
│ ├── util
│ │ └── TestMainframeFTPClientUtils.java
│ └── validation
│ ├── AbortOnFailureHandlerTest.java
│ ├── AbsoluteValidationThresholdTest.java
│ └── RowCountValidatorImportTest.java
└── testdata
├── DatatypeTestData-export-lite.txt
├── DatatypeTestData-import-lite.txt
├── hcatalog
│ └── conf
│ ├── hive-log4j.properties
│ ├── hive-site.xml
│ └── log4j.properties
└── hive
├── bin
│ ├── hive
│ └── hive.cmd
└── scripts
├── createOnlyImport.q
├── createOverwriteImport.q
├── customDelimImport.q
├── dateImport.q
├── failingImport.q
├── fieldWithNewlineImport.q
├── fieldWithNewlineReplacementImport.q
├── normalImportAsParquet.q
├── normalImport.q
├── numericImport.q
└── partitionImport.q
131 directories, 1034 files
sqoop-1.4.6.bin__hadoop-2.0.4-alpha.tar.gz
【实例截图】
【核心代码】
5bfb55f4-d1d2-4026-9bfb-6a99bd448c43
└── sqoop-1.4.6.bin__hadoop-2.0.4-alpha
├── bin
│ ├── configure-sqoop
│ ├── configure-sqoop.cmd
│ ├── sqoop
│ ├── sqoop.cmd
│ ├── sqoop-codegen
│ ├── sqoop-create-hive-table
│ ├── sqoop-eval
│ ├── sqoop-export
│ ├── sqoop-help
│ ├── sqoop-import
│ ├── sqoop-import-all-tables
│ ├── sqoop-import-mainframe
│ ├── sqoop-job
│ ├── sqoop-list-databases
│ ├── sqoop-list-tables
│ ├── sqoop-merge
│ ├── sqoop-metastore
│ ├── sqoop-version
│ ├── start-metastore.sh
│ └── stop-metastore.sh
├── build.xml
├── CHANGELOG.txt
├── COMPILING.txt
├── conf
│ ├── oraoop-site-template.xml
│ ├── sqoop-env-template.cmd
│ ├── sqoop-env-template.sh
│ ├── sqoop-site-template.xml
│ └── sqoop-site.xml
├── docs
│ ├── api
│ │ ├── allclasses-frame.html
│ │ ├── allclasses-noframe.html
│ │ ├── com
│ │ │ └── cloudera
│ │ │ └── sqoop
│ │ │ └── lib
│ │ │ ├── BigDecimalSerializer.html
│ │ │ ├── BlobRef.html
│ │ │ ├── BooleanParser.html
│ │ │ ├── class-use
│ │ │ │ ├── BigDecimalSerializer.html
│ │ │ │ ├── BlobRef.html
│ │ │ │ ├── BooleanParser.html
│ │ │ │ ├── ClobRef.html
│ │ │ │ ├── DelimiterSet.html
│ │ │ │ ├── FieldFormatter.html
│ │ │ │ ├── FieldMappable.html
│ │ │ │ ├── FieldMapProcessor.html
│ │ │ │ ├── JdbcWritableBridge.html
│ │ │ │ ├── LargeObjectLoader.html
│ │ │ │ ├── LobRef.html
│ │ │ │ ├── LobSerializer.html
│ │ │ │ ├── ProcessingException.html
│ │ │ │ ├── RecordParser.html
│ │ │ │ ├── RecordParser.ParseError.html
│ │ │ │ └── SqoopRecord.html
│ │ │ ├── ClobRef.html
│ │ │ ├── DelimiterSet.html
│ │ │ ├── FieldFormatter.html
│ │ │ ├── FieldMappable.html
│ │ │ ├── FieldMapProcessor.html
│ │ │ ├── JdbcWritableBridge.html
│ │ │ ├── LargeObjectLoader.html
│ │ │ ├── LobRef.html
│ │ │ ├── LobSerializer.html
│ │ │ ├── package-frame.html
│ │ │ ├── package-summary.html
│ │ │ ├── package-tree.html
│ │ │ ├── package-use.html
│ │ │ ├── ProcessingException.html
│ │ │ ├── RecordParser.html
│ │ │ ├── RecordParser.ParseError.html
│ │ │ └── SqoopRecord.html
│ │ ├── constant-values.html
│ │ ├── deprecated-list.html
│ │ ├── help-doc.html
│ │ ├── index-all.html
│ │ ├── index.html
│ │ ├── org
│ │ │ └── apache
│ │ │ └── sqoop
│ │ │ └── lib
│ │ │ ├── BigDecimalSerializer.html
│ │ │ ├── BlobRef.html
│ │ │ ├── BooleanParser.html
│ │ │ ├── class-use
│ │ │ │ ├── BigDecimalSerializer.html
│ │ │ │ ├── BlobRef.html
│ │ │ │ ├── BooleanParser.html
│ │ │ │ ├── ClobRef.html
│ │ │ │ ├── DelimiterSet.html
│ │ │ │ ├── FieldFormatter.html
│ │ │ │ ├── FieldMappable.html
│ │ │ │ ├── FieldMapProcessor.html
│ │ │ │ ├── JdbcWritableBridge.html
│ │ │ │ ├── LargeObjectLoader.html
│ │ │ │ ├── LobRef.html
│ │ │ │ ├── LobSerializer.html
│ │ │ │ ├── ProcessingException.html
│ │ │ │ ├── RecordParser.html
│ │ │ │ ├── RecordParser.ParseError.html
│ │ │ │ └── SqoopRecord.html
│ │ │ ├── ClobRef.html
│ │ │ ├── DelimiterSet.html
│ │ │ ├── FieldFormatter.html
│ │ │ ├── FieldMappable.html
│ │ │ ├── FieldMapProcessor.html
│ │ │ ├── JdbcWritableBridge.html
│ │ │ ├── LargeObjectLoader.html
│ │ │ ├── LobRef.html
│ │ │ ├── LobSerializer.html
│ │ │ ├── package-frame.html
│ │ │ ├── package-summary.html
│ │ │ ├── package-tree.html
│ │ │ ├── package-use.html
│ │ │ ├── ProcessingException.html
│ │ │ ├── RecordParser.html
│ │ │ ├── RecordParser.ParseError.html
│ │ │ └── SqoopRecord.html
│ │ ├── overview-frame.html
│ │ ├── overview-summary.html
│ │ ├── overview-tree.html
│ │ ├── serialized-form.html
│ │ └── stylesheet.css
│ ├── docbook.css
│ ├── images
│ │ ├── callouts
│ │ │ ├── 10.png
│ │ │ ├── 11.png
│ │ │ ├── 12.png
│ │ │ ├── 13.png
│ │ │ ├── 14.png
│ │ │ ├── 15.png
│ │ │ ├── 1.png
│ │ │ ├── 2.png
│ │ │ ├── 3.png
│ │ │ ├── 4.png
│ │ │ ├── 5.png
│ │ │ ├── 6.png
│ │ │ ├── 7.png
│ │ │ ├── 8.png
│ │ │ └── 9.png
│ │ ├── caution.png
│ │ ├── example.png
│ │ ├── home.png
│ │ ├── important.png
│ │ ├── next.png
│ │ ├── note.png
│ │ ├── prev.png
│ │ ├── README
│ │ ├── tip.png
│ │ ├── up.png
│ │ └── warning.png
│ ├── index.html
│ ├── man
│ │ ├── sqoop.1.gz
│ │ ├── sqoop-codegen.1.gz
│ │ ├── sqoop-create-hive-table.1.gz
│ │ ├── sqoop-eval.1.gz
│ │ ├── sqoop-export.1.gz
│ │ ├── sqoop-help.1.gz
│ │ ├── sqoop-import.1.gz
│ │ ├── sqoop-import-all-tables.1.gz
│ │ ├── sqoop-import-mainframe.1.gz
│ │ ├── sqoop-job.1.gz
│ │ ├── sqoop-list-databases.1.gz
│ │ ├── sqoop-list-tables.1.gz
│ │ ├── sqoop-merge.1.gz
│ │ ├── sqoop-metastore.1.gz
│ │ └── sqoop-version.1.gz
│ ├── sqoop-1.4.6.releasenotes.html
│ ├── SqoopDevGuide.html
│ └── SqoopUserGuide.html
├── ivy
│ ├── ivysettings.xml
│ ├── libraries.properties
│ ├── sqoop-test.xml
│ └── sqoop.xml
├── ivy.xml
├── lib
│ ├── ant-contrib-1.0b3.jar
│ ├── ant-eclipse-1.0-jvm1.2.jar
│ ├── avro-1.7.5.jar
│ ├── avro-mapred-1.7.5-hadoop2.jar
│ ├── commons-codec-1.4.jar
│ ├── commons-compress-1.4.1.jar
│ ├── commons-io-1.4.jar
│ ├── commons-jexl-2.1.1.jar
│ ├── commons-logging-1.1.1.jar
│ ├── hsqldb-1.8.0.10.jar
│ ├── jackson-annotations-2.3.0.jar
│ ├── jackson-core-2.3.1.jar
│ ├── jackson-core-asl-1.9.13.jar
│ ├── jackson-databind-2.3.1.jar
│ ├── jackson-mapper-asl-1.9.13.jar
│ ├── kite-data-core-1.0.0.jar
│ ├── kite-data-hive-1.0.0.jar
│ ├── kite-data-mapreduce-1.0.0.jar
│ ├── kite-hadoop-compatibility-1.0.0.jar
│ ├── opencsv-2.3.jar
│ ├── paranamer-2.3.jar
│ ├── parquet-avro-1.4.1.jar
│ ├── parquet-column-1.4.1.jar
│ ├── parquet-common-1.4.1.jar
│ ├── parquet-encoding-1.4.1.jar
│ ├── parquet-format-2.0.0.jar
│ ├── parquet-generator-1.4.1.jar
│ ├── parquet-hadoop-1.4.1.jar
│ ├── parquet-jackson-1.4.1.jar
│ ├── slf4j-api-1.6.1.jar
│ ├── snappy-java-1.0.5.jar
│ └── xz-1.0.jar
├── LICENSE.txt
├── NOTICE.txt
├── pom-old.xml
├── README.txt
├── sqoop-1.4.6.jar
├── sqoop-patch-review.py
├── sqoop-test-1.4.6.jar
├── src
│ ├── docs
│ │ ├── dev
│ │ │ ├── api-reference.txt
│ │ │ ├── compiling.txt
│ │ │ ├── intro.txt
│ │ │ ├── preface.txt
│ │ │ └── SqoopDevGuide.txt
│ │ ├── Makefile
│ │ ├── man
│ │ │ ├── codegen-args.txt
│ │ │ ├── common-args.txt
│ │ │ ├── database-independent-args.txt
│ │ │ ├── hbase-args.txt
│ │ │ ├── hive-args.txt
│ │ │ ├── import-args.txt
│ │ │ ├── import-common-args.txt
│ │ │ ├── input-args.txt
│ │ │ ├── mainframe-connection-args.txt
│ │ │ ├── output-args.txt
│ │ │ ├── sqoop-codegen.txt
│ │ │ ├── sqoop-create-hive-table.txt
│ │ │ ├── sqoop-eval.txt
│ │ │ ├── sqoop-export.txt
│ │ │ ├── sqoop-help.txt
│ │ │ ├── sqoop-import-all-tables.txt
│ │ │ ├── sqoop-import-mainframe.txt
│ │ │ ├── sqoop-import.txt
│ │ │ ├── sqoop-job.txt
│ │ │ ├── sqoop-list-databases.txt
│ │ │ ├── sqoop-list-tables.txt
│ │ │ ├── sqoop-merge.txt
│ │ │ ├── sqoop-metastore.txt
│ │ │ ├── sqoop.txt
│ │ │ └── sqoop-version.txt
│ │ ├── sip
│ │ │ ├── INDEX.txt
│ │ │ ├── README.txt
│ │ │ ├── sip-1.txt
│ │ │ ├── sip-2.txt
│ │ │ ├── sip-3.txt
│ │ │ ├── sip-4.txt
│ │ │ └── sip-6.txt
│ │ ├── user
│ │ │ ├── accumulo-args.txt
│ │ │ ├── accumulo.txt
│ │ │ ├── basics.txt
│ │ │ ├── codegen-args.txt
│ │ │ ├── codegen-purpose.txt
│ │ │ ├── codegen.txt
│ │ │ ├── common-args.txt
│ │ │ ├── compatibility.txt
│ │ │ ├── connecting-to-mainframe.txt
│ │ │ ├── connecting.txt
│ │ │ ├── connectors.txt
│ │ │ ├── controlling-input-format.txt
│ │ │ ├── controlling-output-format.txt
│ │ │ ├── create-hive-table-purpose.txt
│ │ │ ├── create-hive-table.txt
│ │ │ ├── distributed-cache.txt
│ │ │ ├── eval-purpose.txt
│ │ │ ├── eval.txt
│ │ │ ├── export-purpose.txt
│ │ │ ├── export.txt
│ │ │ ├── hbase-args.txt
│ │ │ ├── hbase.txt
│ │ │ ├── hcatalog.txt
│ │ │ ├── help.txt
│ │ │ ├── hive-args.txt
│ │ │ ├── hive-notes.txt
│ │ │ ├── hive.txt
│ │ │ ├── import-all-tables-purpose.txt
│ │ │ ├── import-all-tables.txt
│ │ │ ├── import-mainframe-purpose.txt
│ │ │ ├── import-mainframe.txt
│ │ │ ├── import-purpose.txt
│ │ │ ├── import.txt
│ │ │ ├── input-args.txt
│ │ │ ├── input-formatting-args.txt
│ │ │ ├── input-formatting.txt
│ │ │ ├── intro.txt
│ │ │ ├── job-purpose.txt
│ │ │ ├── list-databases.txt
│ │ │ ├── list-tables.txt
│ │ │ ├── mainframe-common-args.txt
│ │ │ ├── merge-purpose.txt
│ │ │ ├── metastore-purpose.txt
│ │ │ ├── output-args.txt
│ │ │ ├── output-formatting-args.txt
│ │ │ ├── output-formatting.txt
│ │ │ ├── preface.txt
│ │ │ ├── saved-jobs.txt
│ │ │ ├── SqoopUserGuide.txt
│ │ │ ├── support.txt
│ │ │ ├── tools.txt
│ │ │ ├── troubleshooting.txt
│ │ │ ├── validation-args.txt
│ │ │ ├── validation.txt
│ │ │ └── version.txt
│ │ └── web
│ │ ├── breadcrumbs.xsl
│ │ ├── docbook.css
│ │ ├── footer.xsl
│ │ ├── header.xsl
│ │ ├── html.xsl
│ │ ├── images
│ │ │ ├── callouts
│ │ │ │ ├── 10.png
│ │ │ │ ├── 11.png
│ │ │ │ ├── 12.png
│ │ │ │ ├── 13.png
│ │ │ │ ├── 14.png
│ │ │ │ ├── 15.png
│ │ │ │ ├── 1.png
│ │ │ │ ├── 2.png
│ │ │ │ ├── 3.png
│ │ │ │ ├── 4.png
│ │ │ │ ├── 5.png
│ │ │ │ ├── 6.png
│ │ │ │ ├── 7.png
│ │ │ │ ├── 8.png
│ │ │ │ └── 9.png
│ │ │ ├── caution.png
│ │ │ ├── example.png
│ │ │ ├── home.png
│ │ │ ├── important.png
│ │ │ ├── next.png
│ │ │ ├── note.png
│ │ │ ├── prev.png
│ │ │ ├── README
│ │ │ ├── tip.png
│ │ │ ├── up.png
│ │ │ └── warning.png
│ │ └── index.txt
│ ├── java
│ │ ├── com
│ │ │ └── cloudera
│ │ │ └── sqoop
│ │ │ ├── cli
│ │ │ │ ├── RelatedOptions.java
│ │ │ │ ├── SqoopParser.java
│ │ │ │ └── ToolOptions.java
│ │ │ ├── config
│ │ │ │ ├── ConfigurationConstants.java
│ │ │ │ └── ConfigurationHelper.java
│ │ │ ├── ConnFactory.java
│ │ │ ├── hbase
│ │ │ │ ├── HBasePutProcessor.java
│ │ │ │ ├── HBaseUtil.java
│ │ │ │ ├── PutTransformer.java
│ │ │ │ └── ToStringPutTransformer.java
│ │ │ ├── hive
│ │ │ │ ├── HiveImport.java
│ │ │ │ ├── HiveTypes.java
│ │ │ │ └── TableDefWriter.java
│ │ │ ├── io
│ │ │ │ ├── CodecMap.java
│ │ │ │ ├── FixedLengthInputStream.java
│ │ │ │ ├── LobFile.java
│ │ │ │ ├── LobReaderCache.java
│ │ │ │ ├── NamedFifo.java
│ │ │ │ ├── SplittableBufferedWriter.java
│ │ │ │ ├── SplittingOutputStream.java
│ │ │ │ └── UnsupportedCodecException.java
│ │ │ ├── lib
│ │ │ │ ├── BigDecimalSerializer.java
│ │ │ │ ├── BlobRef.java
│ │ │ │ ├── BooleanParser.java
│ │ │ │ ├── ClobRef.java
│ │ │ │ ├── DelimiterSet.java
│ │ │ │ ├── FieldFormatter.java
│ │ │ │ ├── FieldMappable.java
│ │ │ │ ├── FieldMapProcessor.java
│ │ │ │ ├── JdbcWritableBridge.java
│ │ │ │ ├── LargeObjectLoader.java
│ │ │ │ ├── LobRef.java
│ │ │ │ ├── LobSerializer.java
│ │ │ │ ├── ProcessingException.java
│ │ │ │ ├── RecordParser.java
│ │ │ │ └── SqoopRecord.java
│ │ │ ├── manager
│ │ │ │ ├── CatalogQueryManager.java
│ │ │ │ ├── ConnManager.java
│ │ │ │ ├── Db2Manager.java
│ │ │ │ ├── DefaultManagerFactory.java
│ │ │ │ ├── DirectMySQLManager.java
│ │ │ │ ├── DirectPostgresqlManager.java
│ │ │ │ ├── ExportJobContext.java
│ │ │ │ ├── GenericJdbcManager.java
│ │ │ │ ├── HsqldbManager.java
│ │ │ │ ├── ImportJobContext.java
│ │ │ │ ├── InformationSchemaManager.java
│ │ │ │ ├── ManagerFactory.java
│ │ │ │ ├── MySQLManager.java
│ │ │ │ ├── MySQLUtils.java
│ │ │ │ ├── OracleManager.java
│ │ │ │ ├── PostgresqlManager.java
│ │ │ │ ├── SqlManager.java
│ │ │ │ └── SQLServerManager.java
│ │ │ ├── mapreduce
│ │ │ │ ├── AsyncSqlOutputFormat.java
│ │ │ │ ├── AsyncSqlRecordWriter.java
│ │ │ │ ├── AutoProgressMapper.java
│ │ │ │ ├── AvroExportMapper.java
│ │ │ │ ├── AvroImportMapper.java
│ │ │ │ ├── AvroInputFormat.java
│ │ │ │ ├── AvroJob.java
│ │ │ │ ├── AvroOutputFormat.java
│ │ │ │ ├── AvroRecordReader.java
│ │ │ │ ├── CombineShimRecordReader.java
│ │ │ │ ├── DataDrivenImportJob.java
│ │ │ │ ├── db
│ │ │ │ │ ├── BigDecimalSplitter.java
│ │ │ │ │ ├── BooleanSplitter.java
│ │ │ │ │ ├── DataDrivenDBInputFormat.java
│ │ │ │ │ ├── DataDrivenDBRecordReader.java
│ │ │ │ │ ├── DateSplitter.java
│ │ │ │ │ ├── DBConfiguration.java
│ │ │ │ │ ├── DBInputFormat.java
│ │ │ │ │ ├── DBOutputFormat.java
│ │ │ │ │ ├── DBRecordReader.java
│ │ │ │ │ ├── DBSplitter.java
│ │ │ │ │ ├── FloatSplitter.java
│ │ │ │ │ ├── IntegerSplitter.java
│ │ │ │ │ ├── OracleDataDrivenDBInputFormat.java
│ │ │ │ │ ├── OracleDataDrivenDBRecordReader.java
│ │ │ │ │ ├── OracleDateSplitter.java
│ │ │ │ │ ├── OracleDBRecordReader.java
│ │ │ │ │ └── TextSplitter.java
│ │ │ │ ├── DelegatingOutputFormat.java
│ │ │ │ ├── ExportBatchOutputFormat.java
│ │ │ │ ├── ExportInputFormat.java
│ │ │ │ ├── ExportJobBase.java
│ │ │ │ ├── ExportOutputFormat.java
│ │ │ │ ├── HBaseImportJob.java
│ │ │ │ ├── HBaseImportMapper.java
│ │ │ │ ├── ImportJobBase.java
│ │ │ │ ├── JdbcExportJob.java
│ │ │ │ ├── JdbcUpdateExportJob.java
│ │ │ │ ├── JdbcUpsertExportJob.java
│ │ │ │ ├── JobBase.java
│ │ │ │ ├── MergeJob.java
│ │ │ │ ├── MergeMapperBase.java
│ │ │ │ ├── MergeRecord.java
│ │ │ │ ├── MergeRecordMapper.java
│ │ │ │ ├── MergeReducer.java
│ │ │ │ ├── MergeTextMapper.java
│ │ │ │ ├── MySQLDumpImportJob.java
│ │ │ │ ├── MySQLDumpInputFormat.java
│ │ │ │ ├── MySQLDumpMapper.java
│ │ │ │ ├── MySQLExportJob.java
│ │ │ │ ├── MySQLExportMapper.java
│ │ │ │ ├── MySQLRecordExportMapper.java
│ │ │ │ ├── MySQLTextExportMapper.java
│ │ │ │ ├── NullOutputCommitter.java
│ │ │ │ ├── OracleExportOutputFormat.java
│ │ │ │ ├── OracleUpsertOutputFormat.java
│ │ │ │ ├── RawKeyTextOutputFormat.java
│ │ │ │ ├── SequenceFileExportMapper.java
│ │ │ │ ├── SequenceFileImportMapper.java
│ │ │ │ ├── SQLServerExportOutputFormat.java
│ │ │ │ ├── TextExportMapper.java
│ │ │ │ ├── TextImportMapper.java
│ │ │ │ └── UpdateOutputFormat.java
│ │ │ ├── metastore
│ │ │ │ ├── hsqldb
│ │ │ │ │ ├── AutoHsqldbStorage.java
│ │ │ │ │ ├── HsqldbJobStorage.java
│ │ │ │ │ └── HsqldbMetaStore.java
│ │ │ │ ├── JobData.java
│ │ │ │ ├── JobStorageFactory.java
│ │ │ │ └── JobStorage.java
│ │ │ ├── orm
│ │ │ │ ├── AvroSchemaGenerator.java
│ │ │ │ ├── ClassWriter.java
│ │ │ │ ├── CompilationManager.java
│ │ │ │ └── TableClassName.java
│ │ │ ├── Sqoop.java
│ │ │ ├── SqoopOptions.java
│ │ │ ├── tool
│ │ │ │ ├── BaseSqoopTool.java
│ │ │ │ ├── CodeGenTool.java
│ │ │ │ ├── CreateHiveTableTool.java
│ │ │ │ ├── EvalSqlTool.java
│ │ │ │ ├── ExportTool.java
│ │ │ │ ├── HelpTool.java
│ │ │ │ ├── ImportAllTablesTool.java
│ │ │ │ ├── ImportTool.java
│ │ │ │ ├── JobTool.java
│ │ │ │ ├── ListDatabasesTool.java
│ │ │ │ ├── ListTablesTool.java
│ │ │ │ ├── MergeTool.java
│ │ │ │ ├── MetastoreTool.java
│ │ │ │ ├── SqoopTool.java
│ │ │ │ ├── ToolDesc.java
│ │ │ │ ├── ToolPlugin.java
│ │ │ │ └── VersionTool.java
│ │ │ └── util
│ │ │ ├── AppendUtils.java
│ │ │ ├── AsyncSink.java
│ │ │ ├── ClassLoaderStack.java
│ │ │ ├── DirectImportUtils.java
│ │ │ ├── ErrorableAsyncSink.java
│ │ │ ├── ErrorableThread.java
│ │ │ ├── Executor.java
│ │ │ ├── ExitSecurityException.java
│ │ │ ├── ExportException.java
│ │ │ ├── FileListing.java
│ │ │ ├── ImportException.java
│ │ │ ├── Jars.java
│ │ │ ├── JdbcUrl.java
│ │ │ ├── LoggingAsyncSink.java
│ │ │ ├── LoggingUtils.java
│ │ │ ├── NullAsyncSink.java
│ │ │ ├── OptionsFileUtil.java
│ │ │ ├── PerfCounters.java
│ │ │ ├── RandomHash.java
│ │ │ ├── ResultSetPrinter.java
│ │ │ ├── StoredAsProperty.java
│ │ │ ├── SubprocessSecurityManager.java
│ │ │ └── TaskId.java
│ │ └── org
│ │ └── apache
│ │ └── sqoop
│ │ ├── accumulo
│ │ │ ├── AccumuloConstants.java
│ │ │ ├── AccumuloMutationProcessor.java
│ │ │ ├── AccumuloUtil.java
│ │ │ ├── MutationTransformer.java
│ │ │ └── ToStringMutationTransformer.java
│ │ ├── avro
│ │ │ └── AvroUtil.java
│ │ ├── cli
│ │ │ ├── RelatedOptions.java
│ │ │ ├── SqoopParser.java
│ │ │ └── ToolOptions.java
│ │ ├── config
│ │ │ ├── ConfigurationConstants.java
│ │ │ └── ConfigurationHelper.java
│ │ ├── ConnFactory.java
│ │ ├── hbase
│ │ │ ├── HBasePutProcessor.java
│ │ │ ├── HBaseUtil.java
│ │ │ ├── PutTransformer.java
│ │ │ └── ToStringPutTransformer.java
│ │ ├── hive
│ │ │ ├── HiveImport.java
│ │ │ ├── HiveTypes.java
│ │ │ └── TableDefWriter.java
│ │ ├── io
│ │ │ ├── CodecMap.java
│ │ │ ├── FixedLengthInputStream.java
│ │ │ ├── LobFile.java
│ │ │ ├── LobReaderCache.java
│ │ │ ├── NamedFifo.java
│ │ │ ├── SplittableBufferedWriter.java
│ │ │ ├── SplittingOutputStream.java
│ │ │ └── UnsupportedCodecException.java
│ │ ├── lib
│ │ │ ├── BigDecimalSerializer.java
│ │ │ ├── BlobRef.java
│ │ │ ├── BooleanParser.java
│ │ │ ├── ClobRef.java
│ │ │ ├── DelimiterSet.java
│ │ │ ├── FieldFormatter.java
│ │ │ ├── FieldMappable.java
│ │ │ ├── FieldMapProcessor.java
│ │ │ ├── JdbcWritableBridge.java
│ │ │ ├── LargeObjectLoader.java
│ │ │ ├── LobRef.java
│ │ │ ├── LobSerializer.java
│ │ │ ├── ProcessingException.java
│ │ │ ├── RecordParser.java
│ │ │ └── SqoopRecord.java
│ │ ├── manager
│ │ │ ├── CatalogQueryManager.java
│ │ │ ├── ConnManager.java
│ │ │ ├── CubridManager.java
│ │ │ ├── Db2Manager.java
│ │ │ ├── DefaultManagerFactory.java
│ │ │ ├── DirectMySQLManager.java
│ │ │ ├── DirectNetezzaManager.java
│ │ │ ├── DirectPostgresqlManager.java
│ │ │ ├── ExportJobContext.java
│ │ │ ├── GenericJdbcManager.java
│ │ │ ├── HsqldbManager.java
│ │ │ ├── ImportJobContext.java
│ │ │ ├── InformationSchemaManager.java
│ │ │ ├── MainframeManager.java
│ │ │ ├── ManagerFactory.java
│ │ │ ├── MySQLManager.java
│ │ │ ├── MySQLUtils.java
│ │ │ ├── NetezzaManager.java
│ │ │ ├── oracle
│ │ │ │ ├── OracleActiveInstance.java
│ │ │ │ ├── OracleConnectionFactory.java
│ │ │ │ ├── OracleTableColumn.java
│ │ │ │ ├── OracleTableColumns.java
│ │ │ │ ├── OracleTable.java
│ │ │ │ ├── OracleTablePartition.java
│ │ │ │ ├── OracleTablePartitions.java
│ │ │ │ ├── OracleVersion.java
│ │ │ │ ├── OraOopConnManager.java
│ │ │ │ ├── OraOopConstants.java
│ │ │ │ ├── OraOopDataDrivenDBInputFormat.java
│ │ │ │ ├── OraOopDBInputSplit.java
│ │ │ │ ├── OraOopDBRecordReader.java
│ │ │ │ ├── OraOopGenerics.java
│ │ │ │ ├── OraOopJdbcUrl.java
│ │ │ │ ├── OraOopLogFactory.java
│ │ │ │ ├── OraOopLog.java
│ │ │ │ ├── OraOopLogMessage.java
│ │ │ │ ├── OraOopManagerFactory.java
│ │ │ │ ├── OraOopOracleDataChunkExtent.java
│ │ │ │ ├── OraOopOracleDataChunk.java
│ │ │ │ ├── OraOopOracleDataChunkPartition.java
│ │ │ │ ├── OraOopOracleQueries.java
│ │ │ │ ├── OraOopOutputFormatBase.java
│ │ │ │ ├── OraOopOutputFormatInsert.java
│ │ │ │ ├── OraOopOutputFormatUpdate.java
│ │ │ │ └── OraOopUtilities.java
│ │ │ ├── OracleManager.java
│ │ │ ├── PGBulkloadManager.java
│ │ │ ├── PostgresqlManager.java
│ │ │ ├── SqlManager.java
│ │ │ └── SQLServerManager.java
│ │ ├── mapreduce
│ │ │ ├── AccumuloImportJob.java
│ │ │ ├── AccumuloImportMapper.java
│ │ │ ├── AsyncSqlOutputFormat.java
│ │ │ ├── AsyncSqlRecordWriter.java
│ │ │ ├── AutoProgressMapper.java
│ │ │ ├── AutoProgressReducer.java
│ │ │ ├── AvroExportMapper.java
│ │ │ ├── AvroImportMapper.java
│ │ │ ├── AvroInputFormat.java
│ │ │ ├── AvroJob.java
│ │ │ ├── AvroOutputFormat.java
│ │ │ ├── AvroRecordReader.java
│ │ │ ├── CombineFileInputFormat.java
│ │ │ ├── CombineFileRecordReader.java
│ │ │ ├── CombineFileSplit.java
│ │ │ ├── CombineShimRecordReader.java
│ │ │ ├── cubrid
│ │ │ │ └── CubridUpsertOutputFormat.java
│ │ │ ├── DataDrivenImportJob.java
│ │ │ ├── db
│ │ │ │ ├── BasicRetrySQLFailureHandler.java
│ │ │ │ ├── BigDecimalSplitter.java
│ │ │ │ ├── BooleanSplitter.java
│ │ │ │ ├── DataDrivenDBInputFormat.java
│ │ │ │ ├── DataDrivenDBRecordReader.java
│ │ │ │ ├── DateSplitter.java
│ │ │ │ ├── Db2DataDrivenDBInputFormat.java
│ │ │ │ ├── Db2DataDrivenDBRecordReader.java
│ │ │ │ ├── Db2DBRecordReader.java
│ │ │ │ ├── DBConfiguration.java
│ │ │ │ ├── DBInputFormat.java
│ │ │ │ ├── DBOutputFormat.java
│ │ │ │ ├── DBRecordReader.java
│ │ │ │ ├── DBSplitter.java
│ │ │ │ ├── FloatSplitter.java
│ │ │ │ ├── IntegerSplitter.java
│ │ │ │ ├── netezza
│ │ │ │ │ ├── NetezzaDBDataSliceSplitter.java
│ │ │ │ │ ├── NetezzaExternalTableExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableHCatExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableHCatImportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableImportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableRecordExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableTextExportMapper.java
│ │ │ │ │ ├── NetezzaExternalTableTextImportMapper.java
│ │ │ │ │ └── NetezzaJDBCStatementRunner.java
│ │ │ │ ├── NTextSplitter.java
│ │ │ │ ├── OracleDataDrivenDBInputFormat.java
│ │ │ │ ├── OracleDataDrivenDBRecordReader.java
│ │ │ │ ├── OracleDateSplitter.java
│ │ │ │ ├── OracleDBRecordReader.java
│ │ │ │ ├── SQLFailureHandler.java
│ │ │ │ ├── SQLServerConnectionFailureHandler.java
│ │ │ │ ├── SQLServerDBInputFormat.java
│ │ │ │ ├── SQLServerDBRecordReader.java
│ │ │ │ └── TextSplitter.java
│ │ │ ├── DBWritable.java
│ │ │ ├── DelegatingOutputFormat.java
│ │ │ ├── ExportBatchOutputFormat.java
│ │ │ ├── ExportCallOutputFormat.java
│ │ │ ├── ExportInputFormat.java
│ │ │ ├── ExportJobBase.java
│ │ │ ├── ExportOutputFormat.java
│ │ │ ├── GenericRecordExportMapper.java
│ │ │ ├── HBaseBulkImportJob.java
│ │ │ ├── HBaseBulkImportMapper.java
│ │ │ ├── HBaseImportJob.java
│ │ │ ├── HBaseImportMapper.java
│ │ │ ├── hcat
│ │ │ │ ├── SqoopHCatExportFormat.java
│ │ │ │ ├── SqoopHCatExportHelper.java
│ │ │ │ ├── SqoopHCatExportMapper.java
│ │ │ │ ├── SqoopHCatImportHelper.java
│ │ │ │ ├── SqoopHCatImportMapper.java
│ │ │ │ ├── SqoopHCatInputSplit.java
│ │ │ │ ├── SqoopHCatRecordReader.java
│ │ │ │ └── SqoopHCatUtilities.java
│ │ │ ├── ImportJobBase.java
│ │ │ ├── JdbcCallExportJob.java
│ │ │ ├── JdbcExportJob.java
│ │ │ ├── JdbcUpdateExportJob.java
│ │ │ ├── JdbcUpsertExportJob.java
│ │ │ ├── JobBase.java
│ │ │ ├── mainframe
│ │ │ │ ├── MainframeConfiguration.java
│ │ │ │ ├── MainframeDatasetFTPRecordReader.java
│ │ │ │ ├── MainframeDatasetImportMapper.java
│ │ │ │ ├── MainframeDatasetInputFormat.java
│ │ │ │ ├── MainframeDatasetInputSplit.java
│ │ │ │ ├── MainframeDatasetRecordReader.java
│ │ │ │ └── MainframeImportJob.java
│ │ │ ├── MergeJob.java
│ │ │ ├── MergeMapperBase.java
│ │ │ ├── MergeRecord.java
│ │ │ ├── MergeRecordMapper.java
│ │ │ ├── MergeReducer.java
│ │ │ ├── MergeTextMapper.java
│ │ │ ├── mysql
│ │ │ │ └── MySQLUpsertOutputFormat.java
│ │ │ ├── MySQLDumpImportJob.java
│ │ │ ├── MySQLDumpInputFormat.java
│ │ │ ├── MySQLDumpMapper.java
│ │ │ ├── MySQLExportJob.java
│ │ │ ├── MySQLExportMapper.java
│ │ │ ├── MySQLRecordExportMapper.java
│ │ │ ├── MySQLTextExportMapper.java
│ │ │ ├── netezza
│ │ │ │ ├── NetezzaDataDrivenDBInputFormat.java
│ │ │ │ ├── NetezzaExternalTableExportJob.java
│ │ │ │ ├── NetezzaExternalTableImportJob.java
│ │ │ │ ├── NetezzaExternalTableInputFormat.java
│ │ │ │ └── NetezzaExternalTableInputSplit.java
│ │ │ ├── NullOutputCommitter.java
│ │ │ ├── OracleExportOutputFormat.java
│ │ │ ├── OracleUpsertOutputFormat.java
│ │ │ ├── ParquetExportMapper.java
│ │ │ ├── ParquetImportMapper.java
│ │ │ ├── ParquetJob.java
│ │ │ ├── postgresql
│ │ │ │ ├── PGBulkloadExportJob.java
│ │ │ │ ├── PGBulkloadExportMapper.java
│ │ │ │ ├── PGBulkloadExportReducer.java
│ │ │ │ ├── PostgreSQLCopyExportJob.java
│ │ │ │ └── PostgreSQLCopyExportMapper.java
│ │ │ ├── ProgressThread.java
│ │ │ ├── RawKeyTextOutputFormat.java
│ │ │ ├── SequenceFileExportMapper.java
│ │ │ ├── SequenceFileImportMapper.java
│ │ │ ├── sqlserver
│ │ │ │ ├── SqlServerExportBatchOutputFormat.java
│ │ │ │ ├── SqlServerInputFormat.java
│ │ │ │ ├── SqlServerRecordReader.java
│ │ │ │ └── SqlServerUpsertOutputFormat.java
│ │ │ ├── SQLServerAsyncDBExecThread.java
│ │ │ ├── SQLServerExportDBExecThread.java
│ │ │ ├── SQLServerExportOutputFormat.java
│ │ │ ├── SQLServerResilientExportOutputFormat.java
│ │ │ ├── SQLServerResilientUpdateOutputFormat.java
│ │ │ ├── SQLServerUpdateDBExecThread.java
│ │ │ ├── SqoopMapper.java
│ │ │ ├── SqoopReducer.java
│ │ │ ├── TextExportMapper.java
│ │ │ ├── TextImportMapper.java
│ │ │ └── UpdateOutputFormat.java
│ │ ├── metastore
│ │ │ ├── hsqldb
│ │ │ │ ├── AutoHsqldbStorage.java
│ │ │ │ ├── HsqldbJobStorage.java
│ │ │ │ └── HsqldbMetaStore.java
│ │ │ ├── JobData.java
│ │ │ ├── JobStorageFactory.java
│ │ │ └── JobStorage.java
│ │ ├── orm
│ │ │ ├── AvroSchemaGenerator.java
│ │ │ ├── ClassWriter.java
│ │ │ ├── CompilationManager.java
│ │ │ └── TableClassName.java
│ │ ├── Sqoop.java
│ │ ├── SqoopOptions.java
│ │ ├── tool
│ │ │ ├── BaseSqoopTool.java
│ │ │ ├── CodeGenTool.java
│ │ │ ├── CreateHiveTableTool.java
│ │ │ ├── EvalSqlTool.java
│ │ │ ├── ExportTool.java
│ │ │ ├── HelpTool.java
│ │ │ ├── ImportAllTablesTool.java
│ │ │ ├── ImportTool.java
│ │ │ ├── JobTool.java
│ │ │ ├── ListDatabasesTool.java
│ │ │ ├── ListTablesTool.java
│ │ │ ├── MainframeImportTool.java
│ │ │ ├── MergeTool.java
│ │ │ ├── MetastoreTool.java
│ │ │ ├── SqoopTool.java
│ │ │ ├── ToolDesc.java
│ │ │ ├── ToolPlugin.java
│ │ │ └── VersionTool.java
│ │ ├── util
│ │ │ ├── AppendUtils.java
│ │ │ ├── AsyncSink.java
│ │ │ ├── ClassLoaderStack.java
│ │ │ ├── CredentialsUtil.java
│ │ │ ├── DirectImportUtils.java
│ │ │ ├── ErrorableAsyncSink.java
│ │ │ ├── ErrorableThread.java
│ │ │ ├── Executor.java
│ │ │ ├── ExitSecurityException.java
│ │ │ ├── ExportException.java
│ │ │ ├── FileListing.java
│ │ │ ├── FileUploader.java
│ │ │ ├── ImportException.java
│ │ │ ├── Jars.java
│ │ │ ├── JdbcUrl.java
│ │ │ ├── LoggingAsyncSink.java
│ │ │ ├── LoggingUtils.java
│ │ │ ├── MainframeFTPClientUtils.java
│ │ │ ├── NullAsyncSink.java
│ │ │ ├── OptionsFileUtil.java
│ │ │ ├── password
│ │ │ │ ├── CredentialProviderHelper.java
│ │ │ │ ├── CredentialProviderPasswordLoader.java
│ │ │ │ ├── CryptoFileLoader.java
│ │ │ │ ├── FilePasswordLoader.java
│ │ │ │ └── PasswordLoader.java
│ │ │ ├── PerfCounters.java
│ │ │ ├── PostgreSQLUtils.java
│ │ │ ├── RandomHash.java
│ │ │ ├── ResultSetPrinter.java
│ │ │ ├── SqlTypeMap.java
│ │ │ ├── StoredAsProperty.java
│ │ │ ├── SubprocessSecurityManager.java
│ │ │ ├── SubstitutionUtils.java
│ │ │ └── TaskId.java
│ │ └── validation
│ │ ├── AbortOnFailureHandler.java
│ │ ├── AbsoluteValidationThreshold.java
│ │ ├── LogOnFailureHandler.java
│ │ ├── RowCountValidator.java
│ │ ├── ValidationContext.java
│ │ ├── ValidationException.java
│ │ ├── ValidationFailureHandler.java
│ │ ├── ValidationThreshold.java
│ │ └── Validator.java
│ ├── perftest
│ │ ├── ExportStressTest.java
│ │ ├── ExtConnFactoryTest.java
│ │ ├── ExtFactory.java
│ │ ├── LobFilePerfTest.java
│ │ ├── LobFileStressTest.java
│ │ └── README-perftest.txt
│ ├── scripts
│ │ ├── create-tool-scripts.cmd
│ │ ├── create-tool-scripts.sh
│ │ ├── hudson
│ │ │ ├── run-code-quality.sh
│ │ │ ├── run-tests.sh
│ │ │ └── test-config.sh
│ │ ├── rat-violations.sh
│ │ ├── relnotes.py
│ │ ├── run-perftest.sh
│ │ ├── tool-script.cmd.template
│ │ ├── tool-script.sh.template
│ │ ├── write-version-info.cmd
│ │ └── write-version-info.sh
│ └── test
│ ├── aop
│ │ ├── build
│ │ │ └── aop.xml
│ │ └── org
│ │ └── apache
│ │ └── sqoop
│ │ ├── fi
│ │ │ ├── FiConfig.java
│ │ │ └── ProbabilityModel.java
│ │ └── mapreduce
│ │ ├── db
│ │ │ └── SqlServerImportAspect.aj
│ │ └── SqlServerExportAspect.aj
│ ├── checkstyle-java-header.txt
│ ├── checkstyle-noframes.xsl
│ ├── checkstyle.xml
│ ├── com
│ │ └── cloudera
│ │ └── sqoop
│ │ ├── AllTests.java
│ │ ├── hbase
│ │ │ ├── HBaseImportAddRowKeyTest.java
│ │ │ ├── HBaseImportNullTest.java
│ │ │ ├── HBaseImportTest.java
│ │ │ ├── HBaseImportTypesTest.java
│ │ │ ├── HBaseQueryImportTest.java
│ │ │ ├── HBaseTestCase.java
│ │ │ └── HBaseUtilTest.java
│ │ ├── hive
│ │ │ ├── TestHiveImport.java
│ │ │ └── TestTableDefWriter.java
│ │ ├── io
│ │ │ ├── TestCodecMap.java
│ │ │ ├── TestLobFile.java
│ │ │ ├── TestNamedFifo.java
│ │ │ └── TestSplittableBufferedWriter.java
│ │ ├── lib
│ │ │ ├── TestBlobRef.java
│ │ │ ├── TestBooleanParser.java
│ │ │ ├── TestClobRef.java
│ │ │ ├── TestFieldFormatter.java
│ │ │ ├── TestLargeObjectLoader.java
│ │ │ └── TestRecordParser.java
│ │ ├── manager
│ │ │ ├── CubridManagerExportTest.java
│ │ │ ├── CubridManagerImportTest.java
│ │ │ ├── DB2ManagerImportManualTest.java
│ │ │ ├── DirectMySQLExportTest.java
│ │ │ ├── DirectMySQLTest.java
│ │ │ ├── DirectPostgreSQLExportManualTest.java
│ │ │ ├── JdbcMySQLExportTest.java
│ │ │ ├── ManualMySQLTests.java
│ │ │ ├── MySQLAllTablesTest.java
│ │ │ ├── MySQLAuthTest.java
│ │ │ ├── MySQLCompatTest.java
│ │ │ ├── MySQLFreeFormQueryTest.java
│ │ │ ├── MySQLLobAvroImportTest.java
│ │ │ ├── MySQLTestUtils.java
│ │ │ ├── OracleCompatTest.java
│ │ │ ├── OracleExportTest.java
│ │ │ ├── OracleFreeFormQueryTest.java
│ │ │ ├── OracleLobAvroImportTest.java
│ │ │ ├── OracleManagerTest.java
│ │ │ ├── OracleUtils.java
│ │ │ ├── PGBulkloadManagerManualTest.java
│ │ │ ├── PostgresqlExportTest.java
│ │ │ ├── PostgresqlImportTest.java
│ │ │ ├── SQLServerManagerExportManualTest.java
│ │ │ ├── SQLServerManagerImportManualTest.java
│ │ │ ├── TestHsqldbManager.java
│ │ │ └── TestSqlManager.java
│ │ ├── mapreduce
│ │ │ ├── db
│ │ │ │ ├── TestDataDrivenDBInputFormat.java
│ │ │ │ ├── TestIntegerSplitter.java
│ │ │ │ └── TestTextSplitter.java
│ │ │ ├── MapreduceTests.java
│ │ │ └── TestImportJob.java
│ │ ├── metastore
│ │ │ └── TestSavedJobs.java
│ │ ├── orm
│ │ │ ├── TestClassWriter.java
│ │ │ └── TestParseMethods.java
│ │ ├── SmokeTests.java
│ │ ├── TestAllTables.java
│ │ ├── TestAppendUtils.java
│ │ ├── TestAvroExport.java
│ │ ├── TestAvroImportExportRoundtrip.java
│ │ ├── TestAvroImport.java
│ │ ├── TestBoundaryQuery.java
│ │ ├── TestColumnTypes.java
│ │ ├── TestCompression.java
│ │ ├── TestConnFactory.java
│ │ ├── TestExport.java
│ │ ├── TestExportUpdate.java
│ │ ├── TestFreeFormQueryImport.java
│ │ ├── TestIncrementalImport.java
│ │ ├── TestMerge.java
│ │ ├── TestMultiCols.java
│ │ ├── TestMultiMaps.java
│ │ ├── TestParquetExport.java
│ │ ├── TestParquetImport.java
│ │ ├── TestQuery.java
│ │ ├── TestSplitBy.java
│ │ ├── TestSqoopOptions.java
│ │ ├── TestTargetDir.java
│ │ ├── testutil
│ │ │ ├── BaseSqoopTestCase.java
│ │ │ ├── CommonArgs.java
│ │ │ ├── DirUtil.java
│ │ │ ├── ExplicitSetMapper.java
│ │ │ ├── ExportJobTestCase.java
│ │ │ ├── HsqldbTestServer.java
│ │ │ ├── ImportJobTestCase.java
│ │ │ ├── InjectableConnManager.java
│ │ │ ├── InjectableManagerFactory.java
│ │ │ ├── LobAvroImportTestCase.java
│ │ │ ├── ManagerCompatTestCase.java
│ │ │ ├── MockResultSet.java
│ │ │ ├── ReparseMapper.java
│ │ │ └── SeqFileReader.java
│ │ ├── TestWhere.java
│ │ ├── ThirdPartyTests.java
│ │ ├── tool
│ │ │ └── TestToolPlugin.java
│ │ └── util
│ │ ├── TestOptionsFileExpansion.java
│ │ └── TestSubstitutionUtils.java
│ ├── findbugsExcludeFile.xml
│ ├── fi-site.xml
│ ├── oraoop
│ │ ├── create_users.sql
│ │ ├── pkg_tst_product_gen.pbk
│ │ ├── pkg_tst_product_gen.psk
│ │ ├── table_tst_product_part_iot.xml
│ │ ├── table_tst_product_part.xml
│ │ ├── table_tst_product_special_chars.xml
│ │ ├── table_tst_product_subpart.xml
│ │ └── table_tst_product.xml
│ └── org
│ └── apache
│ └── sqoop
│ ├── accumulo
│ │ ├── AccumuloTestCase.java
│ │ ├── TestAccumuloImport.java
│ │ ├── TestAccumuloQueryImport.java
│ │ └── TestAccumuloUtil.java
│ ├── credentials
│ │ └── TestPassingSecurePassword.java
│ ├── hcat
│ │ ├── HCatalogExportTest.java
│ │ ├── HCatalogImportTest.java
│ │ ├── HCatalogTestUtils.java
│ │ └── TestHCatalogBasic.java
│ ├── manager
│ │ ├── cubrid
│ │ │ ├── CubridAuthTest.java
│ │ │ ├── CubridCompatTest.java
│ │ │ └── CubridTestUtils.java
│ │ ├── mysql
│ │ │ └── MySqlCallExportTest.java
│ │ ├── netezza
│ │ │ ├── DirectNetezzaExportManualTest.java
│ │ │ ├── DirectNetezzaHCatExportManualTest.java
│ │ │ ├── DirectNetezzaHCatImportManualTest.java
│ │ │ ├── NetezzaExportManualTest.java
│ │ │ ├── NetezzaImportManualTest.java
│ │ │ └── NetezzaTestUtils.java
│ │ ├── oracle
│ │ │ ├── ExportTest.java
│ │ │ ├── ImportTest.java
│ │ │ ├── OracleCallExportTest.java
│ │ │ ├── OracleConnectionFactoryTest.java
│ │ │ ├── OracleIncrementalImportTest.java
│ │ │ ├── OraOopOracleQueriesTest.java
│ │ │ ├── OraOopTestCase.java
│ │ │ ├── OraOopTestConstants.java
│ │ │ ├── SystemImportTest.java
│ │ │ ├── TestOracleTable.java
│ │ │ ├── TestOraOopDataDrivenDBInputFormat.java
│ │ │ ├── TestOraOopJdbcUrl.java
│ │ │ ├── TestOraOopUtilities.java
│ │ │ ├── TimestampDataTest.java
│ │ │ └── util
│ │ │ ├── BigDecimalGenerator.java
│ │ │ ├── BinaryDoubleGenerator.java
│ │ │ ├── BinaryFloatGenerator.java
│ │ │ ├── BlobGenerator.java
│ │ │ ├── BytesGenerator.java
│ │ │ ├── CharGenerator.java
│ │ │ ├── FloatGenerator.java
│ │ │ ├── HadoopFiles.java
│ │ │ ├── IntervalDaySecondGenerator.java
│ │ │ ├── IntervalYearMonthGenerator.java
│ │ │ ├── NCharGenerator.java
│ │ │ ├── OracleDataDefinition.java
│ │ │ ├── OracleData.java
│ │ │ ├── OracleTableDefinition.java
│ │ │ ├── OraOopTestDataGenerator.java
│ │ │ ├── OraOopTestUtils.java
│ │ │ ├── RowIdGenerator.java
│ │ │ ├── TimestampGenerator.java
│ │ │ └── URIGenerator.java
│ │ ├── sqlserver
│ │ │ ├── ManagerCompatExport.java
│ │ │ ├── MSSQLTestDataFileParser.java
│ │ │ ├── MSSQLTestData.java
│ │ │ ├── MSSQLTestUtils.java
│ │ │ ├── SQLServerDatatypeExportDelimitedFileManualTest.java
│ │ │ ├── SQLServerDatatypeExportSequenceFileManualTest.java
│ │ │ ├── SQLServerDatatypeImportDelimitedFileManualTest.java
│ │ │ ├── SQLServerDatatypeImportSequenceFileManualTest.java
│ │ │ ├── SQLServerHiveImportManualTest.java
│ │ │ ├── SQLServerManagerManualTest.java
│ │ │ ├── SQLServerMultiColsManualTest.java
│ │ │ ├── SQLServerMultiMapsManualTest.java
│ │ │ ├── SQLServerParseMethodsManualTest.java
│ │ │ ├── SQLServerQueryManualTest.java
│ │ │ ├── SQLServerSplitByManualTest.java
│ │ │ └── SQLServerWhereManualTest.java
│ │ └── TestMainframeManager.java
│ ├── mapreduce
│ │ ├── db
│ │ │ ├── TestBigDecimalSplitter.java
│ │ │ ├── TestDBConfiguration.java
│ │ │ ├── TestIntegerSplitter.java
│ │ │ └── TestTextSplitter.java
│ │ ├── mainframe
│ │ │ ├── TestMainframeDatasetFTPRecordReader.java
│ │ │ ├── TestMainframeDatasetInputFormat.java
│ │ │ ├── TestMainframeDatasetInputSplit.java
│ │ │ └── TestMainframeImportJob.java
│ │ └── sqlserver
│ │ └── SqlServerUpsertOutputFormatTest.java
│ ├── TestAutoResetMapper.java
│ ├── TestBigDecimalExport.java
│ ├── TestBigDecimalImport.java
│ ├── TestExportUsingProcedure.java
│ ├── tool
│ │ └── TestMainframeImportTool.java
│ ├── util
│ │ └── TestMainframeFTPClientUtils.java
│ └── validation
│ ├── AbortOnFailureHandlerTest.java
│ ├── AbsoluteValidationThresholdTest.java
│ └── RowCountValidatorImportTest.java
└── testdata
├── DatatypeTestData-export-lite.txt
├── DatatypeTestData-import-lite.txt
├── hcatalog
│ └── conf
│ ├── hive-log4j.properties
│ ├── hive-site.xml
│ └── log4j.properties
└── hive
├── bin
│ ├── hive
│ └── hive.cmd
└── scripts
├── createOnlyImport.q
├── createOverwriteImport.q
├── customDelimImport.q
├── dateImport.q
├── failingImport.q
├── fieldWithNewlineImport.q
├── fieldWithNewlineReplacementImport.q
├── normalImportAsParquet.q
├── normalImport.q
├── numericImport.q
└── partitionImport.q
131 directories, 1034 files
标签：
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论