Path	Lines of Code
common/src/main/java/maxcompute/data/collectors/common/datahub/DatahubUtil.java	44
common/src/main/java/maxcompute/data/collectors/common/datahub/RecordUtil.java	62
common/src/main/java/maxcompute/data/collectors/common/maxcompute/MaxcomputeUtil.java	105
common/src/main/java/maxcompute/data/collectors/common/maxcompute/RecordUtil.java	172
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/Attribute.java	16
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/InputSplit.java	61
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/PartitionSpecWithBucketFilter.java	27
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/ReadCapabilities.java	22
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/RequiredSchema.java	27
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/SplitReader.java	9
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/SplitReaderBuilder.java	30
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/TableReadSession.java	78
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/TableReadSessionBuilder.java	175
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/filter/FilterExpression.java	247
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/filter/FilterType.java	18
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/function/FunctionCall.java	32
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/function/GetJsonObject.java	9
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/Builder.java	10
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/OdpsConf.java	85
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/Options.java	110
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/Platform.java	156
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/ProviderRegistry.java	24
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/Schema.java	30
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/TableProvider.java	57
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/TableUtils.java	62
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/util/Validator.java	105
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/vectorized/ColDataBatch.java	26
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/vectorized/ColDataVector.java	196
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/BucketFileInfo.java	27
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/FileWriter.java	20
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/FileWriterBuilder.java	70
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/TableWriteSession.java	48
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/TableWriteSessionBuilder.java	72
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/WriteCapabilities.java	23
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/WriteSessionInfo.java	74
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/WriterCommitMessage.java	3
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/adaptor/ColDataRowWriter.java	290
cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/writer/adaptor/Row.java	24
flink-connector-odps/src/main/java/org/apache/flink/odps/FlinkOdpsException.java	12
flink-connector-odps/src/main/java/org/apache/flink/odps/catalog/OdpsCatalog.java	650
flink-connector-odps/src/main/java/org/apache/flink/odps/catalog/factories/OdpsCatalogFactory.java	47
flink-connector-odps/src/main/java/org/apache/flink/odps/catalog/factories/OdpsCatalogFactoryOptions.java	19
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsInputFormat.java	433
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsInputSplit.java	16
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsLookupFunction.java	128
flink-connector-odps/src/main/java/org/apache/flink/odps/input/OdpsLookupOptions.java	45
flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/CupidBatchIterator.java	87
flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/NextIterator.java	90
flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/RecordIterator.java	94
flink-connector-odps/src/main/java/org/apache/flink/odps/output/OdpsOutputFormat.java	230
flink-connector-odps/src/main/java/org/apache/flink/odps/output/OdpsSinkFunction.java	265
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/DateTimePartitionAssigner.java	63
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/DefaultSinkPolicy.java	91
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/PartitionAssigner.java	13
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/PartitionComputer.java	70
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/SinkPolicy.java	10
flink-connector-odps/src/main/java/org/apache/flink/odps/output/stream/TablePartitionAssigner.java	16
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsStreamWrite.java	7
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsTableWrite.java	203
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWrite.java	11
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWriteFactory.java	69
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWriteOptions.java	147
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/OdpsWriterInfo.java	56
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/WriterContext.java	39
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/BlockWriter.java	11
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/ColumnarBlockWriter.java	51
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/RowBlockWriter.java	122
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/file/StaticOdpsPartitionWrite.java	122
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/DynamicOdpsPartitionStreamWrite.java	129
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/GroupedOdpsPartitionStreamWrite.java	63
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/RowStreamWriter.java	69
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/StaticOdpsPartitionStreamWrite.java	98
flink-connector-odps/src/main/java/org/apache/flink/odps/output/writer/stream/StreamWriter.java	8
flink-connector-odps/src/main/java/org/apache/flink/odps/schema/OdpsColumn.java	54
flink-connector-odps/src/main/java/org/apache/flink/odps/schema/OdpsTableSchema.java	61
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsDynamicTableSink.java	263
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsDynamicTableSource.java	201
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsOptions.java	117
flink-connector-odps/src/main/java/org/apache/flink/odps/table/OdpsTablePath.java	73
flink-connector-odps/src/main/java/org/apache/flink/odps/table/factories/OdpsDynamicTableFactory.java	181
flink-connector-odps/src/main/java/org/apache/flink/odps/util/Constants.java	39
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsConf.java	133
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsMetaDataProvider.java	162
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsTableUtil.java	40
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsTypeConverter.java	790
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsTypeUtil.java	214
flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsUtils.java	248
flink-connector-odps/src/main/java/org/apache/flink/odps/util/PartitionPath.java	52
flink-connector-odps/src/main/java/org/apache/flink/odps/vectorized/ColDataRowImpl.java	136
flink-connector-odps/src/main/java/org/apache/flink/odps/vectorized/ColumnarReadBatch.java	40
flink-connector-odps/src/main/java/org/apache/flink/odps/vectorized/MutableColumnarRow.java	97
flume-plugin/package.xml	27
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/Configure.java	279
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/DatahubConfigConstants.java	28
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/DatahubReader.java	86
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/DatahubSink.java	233
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/DatahubSource.java	175
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/DatahubWriter.java	262
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/serializer/DelimitedTextSerializer.java	105
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/serializer/EventSerializer.java	13
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/serializer/JsonTextSerializer.java	93
flume-plugin/src/main/java/com/aliyun/datahub/flume/sink/serializer/RegexEventSerializer.java	84
hive_data_transfer_udtf/src/main/java/odps/data/dump/MaxComputeDataTransferUDTF.java	160
hive_data_transfer_udtf/src/main/java/odps/data/dump/MaxComputeDataTransferUDTFMultiPart.java	199
hive_data_transfer_udtf/src/main/java/odps/data/dump/OdpsConfig.java	79
kettle-plugin/package.xml	27
kettle-plugin/src/main/java/com/aliyun/odps/OdpsField.java	25
kettle-plugin/src/main/java/com/aliyun/pentaho/di/trans/steps/odps/OdpsMeta.java	179
kettle-plugin/src/main/java/com/aliyun/pentaho/di/trans/steps/odpsinput/OdpsInput.java	148
kettle-plugin/src/main/java/com/aliyun/pentaho/di/trans/steps/odpsinput/OdpsInputData.java	12
kettle-plugin/src/main/java/com/aliyun/pentaho/di/trans/steps/odpsinput/OdpsInputMeta.java	42
kettle-plugin/src/main/java/com/aliyun/pentaho/di/trans/steps/odpsoutput/OdpsOutput.java	173
kettle-plugin/src/main/java/com/aliyun/pentaho/di/trans/steps/odpsoutput/OdpsOutputData.java	14
kettle-plugin/src/main/java/com/aliyun/pentaho/di/trans/steps/odpsoutput/OdpsOutputMeta.java	113
kettle-plugin/src/main/java/com/aliyun/pentaho/di/ui/trans/steps/odpsinput/OdpsInputDialog.java	366
kettle-plugin/src/main/java/com/aliyun/pentaho/di/ui/trans/steps/odpsoutput/OdpsOutputDialog.java	448
odps-data-carrier/data-carrier-commons/src/main/java/com/aliyun/odps/datacarrier/commons/Constants.java	16
odps-data-carrier/data-carrier-commons/src/main/java/com/aliyun/odps/datacarrier/commons/DirUtils.java	52
odps-data-carrier/data-carrier-commons/src/main/java/com/aliyun/odps/datacarrier/commons/GeneratedStatement.java	30
odps-data-carrier/data-carrier-commons/src/main/java/com/aliyun/odps/datacarrier/commons/IntermediateDataManager.java	74
odps-data-carrier/data-carrier-commons/src/main/java/com/aliyun/odps/datacarrier/commons/MetaManager.java	149
odps-data-carrier/data-carrier-commons/src/main/java/com/aliyun/odps/datacarrier/commons/risk/Risk.java	36
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/FlexibleOdpsDataTransferUDTF.java	53
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/OdpsConfig.java	31
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/OdpsDataTransferUDTF.java	159
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/AbstractHiveObjectConverter.java	6
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveBinaryObjectConverter.java	12
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveBooleanObjectConverter.java	10
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveByteObjectConverter.java	10
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveCharObjectConverter.java	12
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveDateObjectConverter.java	11
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveDecimalObjectConverter.java	12
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveDoubleObjectConverter.java	10
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveFloatObjectConverter.java	10
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveIntegerObjectConverter.java	10
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveListObjectConverter.java	21
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveLongObjectConverter.java	10
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveMapObjectConverter.java	25
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveObjectConverter.java	68
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveShortObjectConverter.java	10
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveStringObjectConverter.java	11
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveStructObjectConverter.java	27
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveTimeStampObjectConverter.java	11
odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveVarCharObjectConverter.java	14
odps-data-carrier/meta-carrier/src/main/java/com/aliyun/odps/datacarrier/metacarrier/HiveMetaCarrier.java	119
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/HiveTypeTransformer.java	156
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/MetaProcessor.java	273
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/TypeTransformResult.java	31
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/TypeTransformer.java	20
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/report/HiveDatabaseDivision.java	76
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/report/HiveTableDivision.java	53
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/report/ReportBuilder.java	50
odps-data-carrier/meta-processor/src/main/java/com/aliyun/odps/datacarrier/metaprocessor/report/SummaryDivision.java	62
odps-data-carrier/network-measurement-tool/src/main/java/com/aliyun/odps/datacarrier/network/Endpoint.java	23
odps-data-carrier/network-measurement-tool/src/main/java/com/aliyun/odps/datacarrier/network/Endpoints.java	1
odps-data-carrier/network-measurement-tool/src/main/java/com/aliyun/odps/datacarrier/network/main.java	5
odps-data-carrier/resources/style.css	42
odps-sqoop/conf/oraoop-site-template.xml	33
odps-sqoop/conf/sqoop-env-template.cmd	29
odps-sqoop/conf/sqoop-site-template.xml	4
odps-sqoop/ivy.xml	272
odps-sqoop/ivy/ivysettings.xml	53
odps-sqoop/ivy/sqoop-test.xml	31
odps-sqoop/ivy/sqoop.xml	35
odps-sqoop/package.xml	41
odps-sqoop/pom-old.xml	548
odps-sqoop/sqoop-patch-review.py	128
odps-sqoop/src/java/com/cloudera/sqoop/ConnFactory.java	12
odps-sqoop/src/java/com/cloudera/sqoop/Sqoop.java	37
odps-sqoop/src/java/com/cloudera/sqoop/SqoopOptions.java	54
odps-sqoop/src/java/com/cloudera/sqoop/cli/RelatedOptions.java	10
odps-sqoop/src/java/com/cloudera/sqoop/cli/SqoopParser.java	4
odps-sqoop/src/java/com/cloudera/sqoop/cli/ToolOptions.java	4
odps-sqoop/src/java/com/cloudera/sqoop/config/ConfigurationConstants.java	27
odps-sqoop/src/java/com/cloudera/sqoop/config/ConfigurationHelper.java	70
odps-sqoop/src/java/com/cloudera/sqoop/hbase/HBasePutProcessor.java	12
odps-sqoop/src/java/com/cloudera/sqoop/hbase/HBaseUtil.java	10
odps-sqoop/src/java/com/cloudera/sqoop/hbase/PutTransformer.java	4
odps-sqoop/src/java/com/cloudera/sqoop/hbase/ToStringPutTransformer.java	4
odps-sqoop/src/java/com/cloudera/sqoop/hive/HiveImport.java	11
odps-sqoop/src/java/com/cloudera/sqoop/hive/HiveTypes.java	10
odps-sqoop/src/java/com/cloudera/sqoop/hive/TableDefWriter.java	15
odps-sqoop/src/java/com/cloudera/sqoop/io/CodecMap.java	28
odps-sqoop/src/java/com/cloudera/sqoop/io/FixedLengthInputStream.java	8
odps-sqoop/src/java/com/cloudera/sqoop/io/LobFile.java	45
odps-sqoop/src/java/com/cloudera/sqoop/io/LobReaderCache.java	19
odps-sqoop/src/java/com/cloudera/sqoop/io/NamedFifo.java	10
odps-sqoop/src/java/com/cloudera/sqoop/io/SplittableBufferedWriter.java	12
odps-sqoop/src/java/com/cloudera/sqoop/io/SplittingOutputStream.java	15
odps-sqoop/src/java/com/cloudera/sqoop/io/UnsupportedCodecException.java	13
odps-sqoop/src/java/com/cloudera/sqoop/lib/BigDecimalSerializer.java	19
odps-sqoop/src/java/com/cloudera/sqoop/lib/BlobRef.java	17
odps-sqoop/src/java/com/cloudera/sqoop/lib/BooleanParser.java	8
odps-sqoop/src/java/com/cloudera/sqoop/lib/ClobRef.java	15
odps-sqoop/src/java/com/cloudera/sqoop/lib/DelimiterSet.java	29
odps-sqoop/src/java/com/cloudera/sqoop/lib/FieldFormatter.java	18
odps-sqoop/src/java/com/cloudera/sqoop/lib/FieldMapProcessor.java	4
odps-sqoop/src/java/com/cloudera/sqoop/lib/FieldMappable.java	3
odps-sqoop/src/java/com/cloudera/sqoop/lib/JdbcWritableBridge.java	128
odps-sqoop/src/java/com/cloudera/sqoop/lib/LargeObjectLoader.java	14
odps-sqoop/src/java/com/cloudera/sqoop/lib/LobRef.java	18
odps-sqoop/src/java/com/cloudera/sqoop/lib/LobSerializer.java	21
odps-sqoop/src/java/com/cloudera/sqoop/lib/ProcessingException.java	17
odps-sqoop/src/java/com/cloudera/sqoop/lib/RecordParser.java	23
odps-sqoop/src/java/com/cloudera/sqoop/lib/SqoopRecord.java	5
odps-sqoop/src/java/com/cloudera/sqoop/manager/CatalogQueryManager.java	9
odps-sqoop/src/java/com/cloudera/sqoop/manager/ConnManager.java	4
odps-sqoop/src/java/com/cloudera/sqoop/manager/Db2Manager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/DefaultManagerFactory.java	4
odps-sqoop/src/java/com/cloudera/sqoop/manager/DirectMySQLManager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/DirectPostgresqlManager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/ExportJobContext.java	15
odps-sqoop/src/java/com/cloudera/sqoop/manager/GenericJdbcManager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/HsqldbManager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/ImportJobContext.java	16
odps-sqoop/src/java/com/cloudera/sqoop/manager/InformationSchemaManager.java	9
odps-sqoop/src/java/com/cloudera/sqoop/manager/ManagerFactory.java	4
odps-sqoop/src/java/com/cloudera/sqoop/manager/MySQLManager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/MySQLUtils.java	40
odps-sqoop/src/java/com/cloudera/sqoop/manager/OracleManager.java	20
odps-sqoop/src/java/com/cloudera/sqoop/manager/PostgresqlManager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/SQLServerManager.java	8
odps-sqoop/src/java/com/cloudera/sqoop/manager/SqlManager.java	10
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AsyncSqlOutputFormat.java	41
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AsyncSqlRecordWriter.java	11
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AutoProgressMapper.java	17
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AvroExportMapper.java	6
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AvroImportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AvroInputFormat.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AvroJob.java	14
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AvroOutputFormat.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/AvroRecordReader.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/CombineShimRecordReader.java	12
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/DataDrivenImportJob.java	15
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/DelegatingOutputFormat.java	7
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/ExportBatchOutputFormat.java	6
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/ExportInputFormat.java	13
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/ExportJobBase.java	34
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java	14
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/HBaseImportJob.java	14
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/HBaseImportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/ImportJobBase.java	22
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/JdbcExportJob.java	17
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/JdbcUpdateExportJob.java	19
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/JdbcUpsertExportJob.java	12
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/JobBase.java	64
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MergeJob.java	16
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MergeMapperBase.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MergeRecord.java	11
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MergeRecordMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MergeReducer.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MergeTextMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MySQLDumpImportJob.java	10
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MySQLDumpInputFormat.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MySQLDumpMapper.java	20
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MySQLExportJob.java	8
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MySQLExportMapper.java	8
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MySQLRecordExportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/MySQLTextExportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/NullOutputCommitter.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/OracleExportOutputFormat.java	5
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/OracleUpsertOutputFormat.java	5
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/RawKeyTextOutputFormat.java	12
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/SQLServerExportOutputFormat.java	5
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/SequenceFileExportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/SequenceFileImportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/TextExportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/TextImportMapper.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/UpdateOutputFormat.java	5
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/BigDecimalSplitter.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/BooleanSplitter.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DBConfiguration.java	60
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DBInputFormat.java	17
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DBOutputFormat.java	18
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DBRecordReader.java	14
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DBSplitter.java	3
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DataDrivenDBInputFormat.java	35
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DataDrivenDBRecordReader.java	15
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DateSplitter.java	3
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/FloatSplitter.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/IntegerSplitter.java	7
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/OracleDBRecordReader.java	21
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/OracleDataDrivenDBInputFormat.java	5
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/OracleDataDrivenDBRecordReader.java	14
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/OracleDateSplitter.java	4
odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/TextSplitter.java	3
odps-sqoop/src/java/com/cloudera/sqoop/metastore/JobData.java	12
odps-sqoop/src/java/com/cloudera/sqoop/metastore/JobStorage.java	4
odps-sqoop/src/java/com/cloudera/sqoop/metastore/JobStorageFactory.java	10
odps-sqoop/src/java/com/cloudera/sqoop/metastore/hsqldb/AutoHsqldbStorage.java	16
odps-sqoop/src/java/com/cloudera/sqoop/metastore/hsqldb/HsqldbJobStorage.java	12
odps-sqoop/src/java/com/cloudera/sqoop/metastore/hsqldb/HsqldbMetaStore.java	14
odps-sqoop/src/java/com/cloudera/sqoop/orm/AvroSchemaGenerator.java	10
odps-sqoop/src/java/com/cloudera/sqoop/orm/ClassWriter.java	79
odps-sqoop/src/java/com/cloudera/sqoop/orm/CompilationManager.java	10
odps-sqoop/src/java/com/cloudera/sqoop/orm/TableClassName.java	8
odps-sqoop/src/java/com/cloudera/sqoop/tool/BaseSqoopTool.java	183
odps-sqoop/src/java/com/cloudera/sqoop/tool/CodeGenTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/CreateHiveTableTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/EvalSqlTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/ExportTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/HelpTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/ImportAllTablesTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/ImportTool.java	10
odps-sqoop/src/java/com/cloudera/sqoop/tool/JobTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/ListDatabasesTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/ListTablesTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/MergeTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/MetastoreTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/SqoopTool.java	22
odps-sqoop/src/java/com/cloudera/sqoop/tool/ToolDesc.java	7
odps-sqoop/src/java/com/cloudera/sqoop/tool/ToolPlugin.java	4
odps-sqoop/src/java/com/cloudera/sqoop/tool/VersionTool.java	4
odps-sqoop/src/java/com/cloudera/sqoop/util/AppendUtils.java	8
odps-sqoop/src/java/com/cloudera/sqoop/util/AsyncSink.java	4
odps-sqoop/src/java/com/cloudera/sqoop/util/ClassLoaderStack.java	13
odps-sqoop/src/java/com/cloudera/sqoop/util/DirectImportUtils.java	22
odps-sqoop/src/java/com/cloudera/sqoop/util/ErrorableAsyncSink.java	4
odps-sqoop/src/java/com/cloudera/sqoop/util/ErrorableThread.java	4
odps-sqoop/src/java/com/cloudera/sqoop/util/Executor.java	21
odps-sqoop/src/java/com/cloudera/sqoop/util/ExitSecurityException.java	14
odps-sqoop/src/java/com/cloudera/sqoop/util/ExportException.java	17
odps-sqoop/src/java/com/cloudera/sqoop/util/FileListing.java	18
odps-sqoop/src/java/com/cloudera/sqoop/util/ImportException.java	17
odps-sqoop/src/java/com/cloudera/sqoop/util/Jars.java	14
odps-sqoop/src/java/com/cloudera/sqoop/util/JdbcUrl.java	13
odps-sqoop/src/java/com/cloudera/sqoop/util/LoggingAsyncSink.java	8
odps-sqoop/src/java/com/cloudera/sqoop/util/LoggingUtils.java	9
odps-sqoop/src/java/com/cloudera/sqoop/util/NullAsyncSink.java	4
odps-sqoop/src/java/com/cloudera/sqoop/util/OptionsFileUtil.java	10
odps-sqoop/src/java/com/cloudera/sqoop/util/PerfCounters.java	7
odps-sqoop/src/java/com/cloudera/sqoop/util/RandomHash.java	10
odps-sqoop/src/java/com/cloudera/sqoop/util/ResultSetPrinter.java	4
odps-sqoop/src/java/com/cloudera/sqoop/util/StoredAsProperty.java	12
odps-sqoop/src/java/com/cloudera/sqoop/util/SubprocessSecurityManager.java	7
odps-sqoop/src/java/com/cloudera/sqoop/util/TaskId.java	13
odps-sqoop/src/java/org/apache/sqoop/ConnFactory.java	195
odps-sqoop/src/java/org/apache/sqoop/Sqoop.java	116
odps-sqoop/src/java/org/apache/sqoop/SqoopOptions.java	1741
odps-sqoop/src/java/org/apache/sqoop/accumulo/AccumuloConstants.java	30
odps-sqoop/src/java/org/apache/sqoop/accumulo/AccumuloMutationProcessor.java	112
odps-sqoop/src/java/org/apache/sqoop/accumulo/AccumuloUtil.java	120
odps-sqoop/src/java/org/apache/sqoop/accumulo/MutationTransformer.java	29
odps-sqoop/src/java/org/apache/sqoop/accumulo/ToStringMutationTransformer.java	50
odps-sqoop/src/java/org/apache/sqoop/avro/AvroUtil.java	174
odps-sqoop/src/java/org/apache/sqoop/cli/RelatedOptions.java	19
odps-sqoop/src/java/org/apache/sqoop/cli/SqoopParser.java	58
odps-sqoop/src/java/org/apache/sqoop/cli/ToolOptions.java	71
odps-sqoop/src/java/org/apache/sqoop/config/ConfigurationConstants.java	26
odps-sqoop/src/java/org/apache/sqoop/config/ConfigurationHelper.java	119
odps-sqoop/src/java/org/apache/sqoop/hbase/HBasePutProcessor.java	100
odps-sqoop/src/java/org/apache/sqoop/hbase/HBaseUtil.java	20
odps-sqoop/src/java/org/apache/sqoop/hbase/PutTransformer.java	23
odps-sqoop/src/java/org/apache/sqoop/hbase/ToStringPutTransformer.java	115
odps-sqoop/src/java/org/apache/sqoop/hive/HiveConfig.java	30
odps-sqoop/src/java/org/apache/sqoop/hive/HiveImport.java	249
odps-sqoop/src/java/org/apache/sqoop/hive/HiveTypes.java	47
odps-sqoop/src/java/org/apache/sqoop/hive/TableDefWriter.java	195
odps-sqoop/src/java/org/apache/sqoop/io/CodecMap.java	116
odps-sqoop/src/java/org/apache/sqoop/io/FixedLengthInputStream.java	46
odps-sqoop/src/java/org/apache/sqoop/io/LobFile.java	980
odps-sqoop/src/java/org/apache/sqoop/io/LobReaderCache.java	66
odps-sqoop/src/java/org/apache/sqoop/io/NamedFifo.java	40
odps-sqoop/src/java/org/apache/sqoop/io/SplittableBufferedWriter.java	38
odps-sqoop/src/java/org/apache/sqoop/io/SplittingOutputStream.java	91
odps-sqoop/src/java/org/apache/sqoop/io/UnsupportedCodecException.java	13
odps-sqoop/src/java/org/apache/sqoop/lib/BigDecimalSerializer.java	40
odps-sqoop/src/java/org/apache/sqoop/lib/BlobRef.java	67
odps-sqoop/src/java/org/apache/sqoop/lib/BooleanParser.java	9
odps-sqoop/src/java/org/apache/sqoop/lib/ClobRef.java	56
odps-sqoop/src/java/org/apache/sqoop/lib/DelimiterSet.java	119
odps-sqoop/src/java/org/apache/sqoop/lib/FieldFormatter.java	61
odps-sqoop/src/java/org/apache/sqoop/lib/FieldMapProcessor.java	7
odps-sqoop/src/java/org/apache/sqoop/lib/FieldMappable.java	5
odps-sqoop/src/java/org/apache/sqoop/lib/JdbcWritableBridge.java	194
odps-sqoop/src/java/org/apache/sqoop/lib/LargeObjectLoader.java	181
odps-sqoop/src/java/org/apache/sqoop/lib/LobRef.java	179
odps-sqoop/src/java/org/apache/sqoop/lib/LobSerializer.java	27
odps-sqoop/src/java/org/apache/sqoop/lib/ProcessingException.java	21
odps-sqoop/src/java/org/apache/sqoop/lib/RecordParser.java	240
odps-sqoop/src/java/org/apache/sqoop/lib/SqoopRecord.java	75
odps-sqoop/src/java/org/apache/sqoop/manager/CatalogQueryManager.java	205
odps-sqoop/src/java/org/apache/sqoop/manager/ConnManager.java	374
odps-sqoop/src/java/org/apache/sqoop/manager/CubridManager.java	124
odps-sqoop/src/java/org/apache/sqoop/manager/Db2Manager.java	79
odps-sqoop/src/java/org/apache/sqoop/manager/DefaultManagerFactory.java	70
odps-sqoop/src/java/org/apache/sqoop/manager/DirectMySQLManager.java	67
odps-sqoop/src/java/org/apache/sqoop/manager/DirectNetezzaManager.java	255
odps-sqoop/src/java/org/apache/sqoop/manager/DirectPostgresqlManager.java	413
odps-sqoop/src/java/org/apache/sqoop/manager/ExportJobContext.java	34
odps-sqoop/src/java/org/apache/sqoop/manager/GenericJdbcManager.java	43
odps-sqoop/src/java/org/apache/sqoop/manager/HdfsManager.java	119
odps-sqoop/src/java/org/apache/sqoop/manager/HsqldbManager.java	48
odps-sqoop/src/java/org/apache/sqoop/manager/ImportJobContext.java	50
odps-sqoop/src/java/org/apache/sqoop/manager/InformationSchemaManager.java	40
odps-sqoop/src/java/org/apache/sqoop/manager/MainframeManager.java	120
odps-sqoop/src/java/org/apache/sqoop/manager/ManagerFactory.java	14
odps-sqoop/src/java/org/apache/sqoop/manager/MySQLManager.java	299
odps-sqoop/src/java/org/apache/sqoop/manager/MySQLUtils.java	65
odps-sqoop/src/java/org/apache/sqoop/manager/NetezzaManager.java	146
odps-sqoop/src/java/org/apache/sqoop/manager/OracleManager.java	798
odps-sqoop/src/java/org/apache/sqoop/manager/PGBulkloadManager.java	33
odps-sqoop/src/java/org/apache/sqoop/manager/PostgresqlManager.java	152
odps-sqoop/src/java/org/apache/sqoop/manager/SQLServerManager.java	287
odps-sqoop/src/java/org/apache/sqoop/manager/SqlManager.java	882
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopConnManager.java	401
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopConstants.java	208
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopDBInputSplit.java	131
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopDBRecordReader.java	308
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopDataDrivenDBInputFormat.java	233
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopGenerics.java	24
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopJdbcUrl.java	142
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopLog.java	148
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopLogFactory.java	18
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopLogMessage.java	35
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopManagerFactory.java	816
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopOracleDataChunk.java	33
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopOracleDataChunkExtent.java	60
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopOracleDataChunkPartition.java	45
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopOracleQueries.java	1352
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopOutputFormatBase.java	469
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopOutputFormatInsert.java	162
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopOutputFormatUpdate.java	286
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OraOopUtilities.java	1042
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleActiveInstance.java	17
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleConnectionFactory.java	154
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleTable.java	34
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleTableColumn.java	28
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleTableColumns.java	16
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleTablePartition.java	21
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleTablePartitions.java	31
odps-sqoop/src/java/org/apache/sqoop/manager/oracle/OracleVersion.java	49
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AccumuloImportJob.java	138
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AccumuloImportMapper.java	15
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AsyncSqlOutputFormat.java	153
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AsyncSqlRecordWriter.java	129
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AutoProgressMapper.java	38
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AutoProgressReducer.java	29
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AvroExportMapper.java	13
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AvroImportMapper.java	52
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AvroInputFormat.java	22
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AvroJob.java	21
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AvroOutputFormat.java	77
odps-sqoop/src/java/org/apache/sqoop/mapreduce/AvroRecordReader.java	74
odps-sqoop/src/java/org/apache/sqoop/mapreduce/CombineFileInputFormat.java	446
odps-sqoop/src/java/org/apache/sqoop/mapreduce/CombineFileRecordReader.java	101
odps-sqoop/src/java/org/apache/sqoop/mapreduce/CombineFileSplit.java	130
odps-sqoop/src/java/org/apache/sqoop/mapreduce/CombineShimRecordReader.java	81
odps-sqoop/src/java/org/apache/sqoop/mapreduce/DBWritable.java	8
odps-sqoop/src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java	252
odps-sqoop/src/java/org/apache/sqoop/mapreduce/DelegatingOutputFormat.java	72
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ExportBatchOutputFormat.java	81
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ExportCallOutputFormat.java	88
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ExportInputFormat.java	61
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ExportJobBase.java	398
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ExportOutputFormat.java	122
odps-sqoop/src/java/org/apache/sqoop/mapreduce/GenericRecordExportMapper.java	72
odps-sqoop/src/java/org/apache/sqoop/mapreduce/HBaseBulkImportJob.java	87
odps-sqoop/src/java/org/apache/sqoop/mapreduce/HBaseBulkImportMapper.java	60
odps-sqoop/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java	163
odps-sqoop/src/java/org/apache/sqoop/mapreduce/HBaseImportMapper.java	15
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ImportJobBase.java	219
odps-sqoop/src/java/org/apache/sqoop/mapreduce/JdbcCallExportJob.java	65
odps-sqoop/src/java/org/apache/sqoop/mapreduce/JdbcExportJob.java	150
odps-sqoop/src/java/org/apache/sqoop/mapreduce/JdbcUpdateExportJob.java	109
odps-sqoop/src/java/org/apache/sqoop/mapreduce/JdbcUpsertExportJob.java	75
odps-sqoop/src/java/org/apache/sqoop/mapreduce/JobBase.java	246
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeAvroMapper.java	61
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeAvroReducer.java	28
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeJob.java	124
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeMapperBase.java	54
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeRecord.java	69
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeRecordMapper.java	12
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeReducer.java	14
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeReducerBase.java	31
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MergeTextMapper.java	30
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLDumpImportJob.java	81
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLDumpInputFormat.java	52
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLDumpMapper.java	353
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLExportJob.java	74
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLExportMapper.java	237
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLRecordExportMapper.java	14
odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLTextExportMapper.java	23
odps-sqoop/src/java/org/apache/sqoop/mapreduce/NullOutputCommitter.java	14
odps-sqoop/src/java/org/apache/sqoop/mapreduce/OracleExportOutputFormat.java	64
odps-sqoop/src/java/org/apache/sqoop/mapreduce/OracleUpsertOutputFormat.java	87
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ParquetExportMapper.java	16
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ParquetImportMapper.java	49
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ParquetJob.java	132
odps-sqoop/src/java/org/apache/sqoop/mapreduce/ProgressThread.java	85
odps-sqoop/src/java/org/apache/sqoop/mapreduce/RawKeyTextOutputFormat.java	59
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SQLServerAsyncDBExecThread.java	188
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SQLServerExportDBExecThread.java	94
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SQLServerExportOutputFormat.java	64
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SQLServerResilientExportOutputFormat.java	116
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SQLServerResilientUpdateOutputFormat.java	53
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SQLServerUpdateDBExecThread.java	72
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SequenceFileExportMapper.java	16
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SequenceFileImportMapper.java	34
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SqoopMapper.java	20
odps-sqoop/src/java/org/apache/sqoop/mapreduce/SqoopReducer.java	17
odps-sqoop/src/java/org/apache/sqoop/mapreduce/TextExportMapper.java	94
odps-sqoop/src/java/org/apache/sqoop/mapreduce/TextImportMapper.java	40
odps-sqoop/src/java/org/apache/sqoop/mapreduce/UpdateOutputFormat.java	130
odps-sqoop/src/java/org/apache/sqoop/mapreduce/cubrid/CubridUpsertOutputFormat.java	68
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/BasicRetrySQLFailureHandler.java	93
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/BigDecimalSplitter.java	82
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/BooleanSplitter.java	35
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DBConfiguration.java	278
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DBInputFormat.java	250
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DBOutputFormat.java	153
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java	226
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DBSplitter.java	11
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java	253
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBRecordReader.java	78
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DateSplitter.java	111
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/Db2DBRecordReader.java	27
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/Db2DataDrivenDBInputFormat.java	27
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/Db2DataDrivenDBRecordReader.java	17
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/FloatSplitter.java	57
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/IntegerSplitter.java	93
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/NTextSplitter.java	6
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/OracleDBRecordReader.java	92
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/OracleDataDrivenDBInputFormat.java	43
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/OracleDataDrivenDBRecordReader.java	20
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/OracleDateSplitter.java	10
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/SQLFailureHandler.java	20
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/SQLServerConnectionFailureHandler.java	54
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBInputFormat.java	51
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java	129
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/TextSplitter.java	131
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaDBDataSliceSplitter.java	26
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableExportMapper.java	220
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableHCatExportMapper.java	31
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableHCatImportMapper.java	49
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java	182
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableRecordExportMapper.java	13
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableTextExportMapper.java	13
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableTextImportMapper.java	12
odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaJDBCStatementRunner.java	58
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatExportFormat.java	94
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatExportHelper.java	349
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatExportMapper.java	31
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatImportHelper.java	407
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatImportMapper.java	32
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatInputSplit.java	75
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatOdpsExportMapper.java	31
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatRecordReader.java	107
odps-sqoop/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatUtilities.java	1183
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mainframe/MainframeConfiguration.java	6
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mainframe/MainframeDatasetFTPRecordReader.java	79
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mainframe/MainframeDatasetImportMapper.java	46
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mainframe/MainframeDatasetInputFormat.java	60
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mainframe/MainframeDatasetInputSplit.java	58
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mainframe/MainframeDatasetRecordReader.java	76
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mainframe/MainframeImportJob.java	39
odps-sqoop/src/java/org/apache/sqoop/mapreduce/mysql/MySQLUpsertOutputFormat.java	89
odps-sqoop/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaDataDrivenDBInputFormat.java	32
odps-sqoop/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableExportJob.java	123
odps-sqoop/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableImportJob.java	123
odps-sqoop/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableInputFormat.java	66
odps-sqoop/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableInputSplit.java	39
odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/HdfsOdpsImportJob.java	640
odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/OdpsExportInputFormat.java	90
odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/OdpsExportMapper.java	66
odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/OdpsImportJob.java	201
odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/OdpsImportMapper.java	14
odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/OdpsSplitter.java	38
odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/ParquetExportMapper.java	79
odps-sqoop/src/java/org/apache/sqoop/mapreduce/postgresql/PGBulkloadExportJob.java	150
odps-sqoop/src/java/org/apache/sqoop/mapreduce/postgresql/PGBulkloadExportMapper.java	259
odps-sqoop/src/java/org/apache/sqoop/mapreduce/postgresql/PGBulkloadExportReducer.java	74
odps-sqoop/src/java/org/apache/sqoop/mapreduce/postgresql/PostgreSQLCopyExportJob.java	77
odps-sqoop/src/java/org/apache/sqoop/mapreduce/postgresql/PostgreSQLCopyExportMapper.java	124
odps-sqoop/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerExportBatchOutputFormat.java	73
odps-sqoop/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerInputFormat.java	26
odps-sqoop/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerRecordReader.java	70
odps-sqoop/src/java/org/apache/sqoop/mapreduce/sqlserver/SqlServerUpsertOutputFormat.java	111
odps-sqoop/src/java/org/apache/sqoop/metastore/JobData.java	25
odps-sqoop/src/java/org/apache/sqoop/metastore/JobStorage.java	22
odps-sqoop/src/java/org/apache/sqoop/metastore/JobStorageFactory.java	30
odps-sqoop/src/java/org/apache/sqoop/metastore/hsqldb/AutoHsqldbStorage.java	47
odps-sqoop/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbJobStorage.java	575
odps-sqoop/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbMetaStore.java	115
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsConstants.java	27
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsRecordBuilder.java	67
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsRowDO.java	18
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsSqoopRecordReader.java	95
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsTunnelWriter.java	135
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsUploadProcessor.java	221
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsUtil.java	31
odps-sqoop/src/java/org/apache/sqoop/odps/OdpsWriter.java	10
odps-sqoop/src/java/org/apache/sqoop/orm/AvroSchemaGenerator.java	82
odps-sqoop/src/java/org/apache/sqoop/orm/ClassWriter.java	1339
odps-sqoop/src/java/org/apache/sqoop/orm/CompilationManager.java	264
odps-sqoop/src/java/org/apache/sqoop/orm/TableClassName.java	58
odps-sqoop/src/java/org/apache/sqoop/tool/BaseSqoopTool.java	1573
odps-sqoop/src/java/org/apache/sqoop/tool/CodeGenTool.java	161
odps-sqoop/src/java/org/apache/sqoop/tool/CreateHiveTableTool.java	87
odps-sqoop/src/java/org/apache/sqoop/tool/EvalSqlTool.java	122
odps-sqoop/src/java/org/apache/sqoop/tool/ExportTool.java	334
odps-sqoop/src/java/org/apache/sqoop/tool/HelpTool.java	61
odps-sqoop/src/java/org/apache/sqoop/tool/ImportAllTablesTool.java	90
odps-sqoop/src/java/org/apache/sqoop/tool/ImportTool.java	887
odps-sqoop/src/java/org/apache/sqoop/tool/JobTool.java	277
odps-sqoop/src/java/org/apache/sqoop/tool/ListDatabasesTool.java	52
odps-sqoop/src/java/org/apache/sqoop/tool/ListTablesTool.java	54
odps-sqoop/src/java/org/apache/sqoop/tool/MainframeImportTool.java	113
odps-sqoop/src/java/org/apache/sqoop/tool/MergeTool.java	148
odps-sqoop/src/java/org/apache/sqoop/tool/MetastoreTool.java	52
odps-sqoop/src/java/org/apache/sqoop/tool/SqoopTool.java	281
odps-sqoop/src/java/org/apache/sqoop/tool/ToolDesc.java	20
odps-sqoop/src/java/org/apache/sqoop/tool/ToolPlugin.java	6
odps-sqoop/src/java/org/apache/sqoop/tool/VersionTool.java	17
odps-sqoop/src/java/org/apache/sqoop/util/AppendUtils.java	163
odps-sqoop/src/java/org/apache/sqoop/util/AsyncSink.java	6
odps-sqoop/src/java/org/apache/sqoop/util/ClassLoaderStack.java	51
odps-sqoop/src/java/org/apache/sqoop/util/CredentialsUtil.java	39
odps-sqoop/src/java/org/apache/sqoop/util/DirectImportUtils.java	67
odps-sqoop/src/java/org/apache/sqoop/util/ErrorableAsyncSink.java	13
odps-sqoop/src/java/org/apache/sqoop/util/ErrorableThread.java	13
odps-sqoop/src/java/org/apache/sqoop/util/Executor.java	49
odps-sqoop/src/java/org/apache/sqoop/util/ExitSecurityException.java	25
odps-sqoop/src/java/org/apache/sqoop/util/ExportException.java	21
odps-sqoop/src/java/org/apache/sqoop/util/FileListing.java	70
odps-sqoop/src/java/org/apache/sqoop/util/FileUploader.java	38
odps-sqoop/src/java/org/apache/sqoop/util/ImportException.java	21
odps-sqoop/src/java/org/apache/sqoop/util/Jars.java	55
odps-sqoop/src/java/org/apache/sqoop/util/JdbcUrl.java	70
odps-sqoop/src/java/org/apache/sqoop/util/LoggingAsyncSink.java	55
odps-sqoop/src/java/org/apache/sqoop/util/LoggingUtils.java	25
odps-sqoop/src/java/org/apache/sqoop/util/MainframeFTPClientUtils.java	146
odps-sqoop/src/java/org/apache/sqoop/util/NullAsyncSink.java	47
odps-sqoop/src/java/org/apache/sqoop/util/OptionsFileUtil.java	101
odps-sqoop/src/java/org/apache/sqoop/util/PerfCounters.java	77
odps-sqoop/src/java/org/apache/sqoop/util/PostgreSQLUtils.java	25
odps-sqoop/src/java/org/apache/sqoop/util/RandomHash.java	26
odps-sqoop/src/java/org/apache/sqoop/util/ResultSetPrinter.java	73
odps-sqoop/src/java/org/apache/sqoop/util/SqlTypeMap.java	26
odps-sqoop/src/java/org/apache/sqoop/util/SqoopJsonUtil.java	56
odps-sqoop/src/java/org/apache/sqoop/util/StoredAsProperty.java	12
odps-sqoop/src/java/org/apache/sqoop/util/SubprocessSecurityManager.java	42
odps-sqoop/src/java/org/apache/sqoop/util/SubstitutionUtils.java	27
odps-sqoop/src/java/org/apache/sqoop/util/TaskId.java	27
odps-sqoop/src/java/org/apache/sqoop/util/password/CredentialProviderHelper.java	106
odps-sqoop/src/java/org/apache/sqoop/util/password/CredentialProviderPasswordLoader.java	26
odps-sqoop/src/java/org/apache/sqoop/util/password/CryptoFileLoader.java	76
odps-sqoop/src/java/org/apache/sqoop/util/password/FilePasswordLoader.java	38
odps-sqoop/src/java/org/apache/sqoop/util/password/PasswordLoader.java	8
odps-sqoop/src/java/org/apache/sqoop/validation/AbortOnFailureHandler.java	17
odps-sqoop/src/java/org/apache/sqoop/validation/AbsoluteValidationThreshold.java	18
odps-sqoop/src/java/org/apache/sqoop/validation/LogOnFailureHandler.java	13
odps-sqoop/src/java/org/apache/sqoop/validation/RowCountValidator.java	32
odps-sqoop/src/java/org/apache/sqoop/validation/ValidationContext.java	29
odps-sqoop/src/java/org/apache/sqoop/validation/ValidationException.java	11
odps-sqoop/src/java/org/apache/sqoop/validation/ValidationFailureHandler.java	5
odps-sqoop/src/java/org/apache/sqoop/validation/ValidationThreshold.java	5
odps-sqoop/src/java/org/apache/sqoop/validation/Validator.java	9
odps-sqoop/src/perftest/ExportStressTest.java	100
odps-sqoop/src/perftest/ExtConnFactoryTest.java	44
odps-sqoop/src/perftest/ExtFactory.java	17
odps-sqoop/src/perftest/LobFilePerfTest.java	77
odps-sqoop/src/perftest/LobFileStressTest.java	288
odps-sqoop/src/scripts/create-tool-scripts.cmd	50
odps-sqoop/src/scripts/relnotes.py	129
odps-sqoop/src/scripts/write-version-info.cmd	87
ogg-plugin/ggjava/resources/classes/logback-debug.xml	31
ogg-plugin/ggjava/resources/classes/logback-default.xml	30
ogg-plugin/ggjava/resources/classes/logback-trace.xml	31
ogg-plugin/ggjava/resources/config/ggue-context.xml	30
ogg-plugin/ggjava/resources/config/jps-config-jse.xml	24
ogg-plugin/package.xml	43
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/BadOperateWriter.java	79
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/ClientHelper.java	132
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/ConfigureReader.java	271
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/Constant.java	15
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/DatahubHandler.java	125
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/HandlerInfoManager.java	20
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/RecordBatch.java	24
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/RecordBatchQueue.java	35
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/RecordBuilder.java	163
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/RecordWriter.java	90
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/ShardWriter.java	219
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/TableRecordBuilder.java	361
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/TopicWriter.java	117
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/modle/ColumnMapping.java	70
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/modle/Configure.java	206
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/modle/DirtyRecordInfo.java	39
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/modle/MetricHelper.java	97
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/modle/PluginStatictics.java	63
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/modle/TableMapping.java	114
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/operations/DeleteOperationHandler.java	14
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/operations/InsertOperationHandler.java	14
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/operations/OperationHandler.java	17
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/operations/OperationHandlerManager.java	24
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/operations/UpdateOperationHandler.java	14
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/util/BucketPath.java	121
ogg-plugin/src/main/java/com/aliyun/odps/ogg/handler/datahub/util/JsonHelper.java	61
ogg-plugin/src/main/resources/configure.xml	48
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeColumnHandle.java	70
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeConfig.java	62
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeConnector.java	63
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeConnectorFactory.java	44
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeConnectorId.java	33
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeErrorCode.java	25
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeHandleResolver.java	36
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeInputSplit.java	80
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeMetadata.java	177
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeModule.java	52
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputePageSource.java	128
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputePageSourceProvider.java	27
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputePartition.java	62
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputePlugin.java	13
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeSplit.java	101
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeSplitManager.java	141
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeTableHandle.java	119
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeTableLayoutHandle.java	20
presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeTransactionHandle.java	7
presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/ArrowToPageConverter.java	80
presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/ArrowUtils.java	260
presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/CommonUtils.java	38
presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/MaxComputeMetaCache.java	61
presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/MaxComputeUtils.java	74
presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/SimpleDataAccessor.java	39
presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/TypeConvertUtils.java	77
spark-connector/common/src/main/java/org/apache/spark/sql/odps/OdpsClient.java	323
spark-connector/common/src/main/java/org/apache/spark/sql/odps/arrow/OdpsExtensionType.java	26
spark-connector/common/src/main/java/org/apache/spark/sql/odps/arrow/OdpsTimestampType.java	48
spark-connector/common/src/main/java/org/apache/spark/sql/odps/bucket/OdpsDefaultHasher.java	129
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/read/TunnelArrowSplitReader.java	227
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/read/TunnelInputSplit.java	32
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/read/TunnelInputSplitAssigner.java	25
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/read/TunnelReadSessionProviderImpl.java	19
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/read/TunnelRowRangeInputSplitAssigner.java	20
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/read/TunnelSplitRecordReader.java	168
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/read/TunnelTableBatchReadSession.java	228
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/write/TunnelArrowBatchWriter.java	128
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/write/TunnelCommitMessage.java	45
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/write/TunnelRecordWriter.java	106
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/write/TunnelTableBatchWriteSession.java	162
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/tunnel/write/TunnelWriteSessionProviderImpl.java	21
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/utils/ArrowSchemaUtils.java	155
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/utils/DateTimeConstants.java	10
spark-connector/common/src/main/java/org/apache/spark/sql/odps/table/utils/TableUtils.java	105
spark-connector/common/src/main/java/org/apache/spark/sql/odps/udf/MaxPtUDF.java	19
spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/ByteConstantColumnVector.java	13
spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/ConstantColumnVector.java	78
spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/IntegerConstantColumnVector.java	13
spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/LongConstantColumnVector.java	13
spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/OdpsArrowColumnVector.java	248
spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/ShortConstantColumnVector.java	13
spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/StringConstantColumnVector.java	14
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/ArrowUtils.scala	152
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/ExecutionUtils.scala	89
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/OdpsPartitionReaderFactory.scala	332
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/OdpsTableDataWriter.scala	334
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/OdpsUtils.scala	250
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/OdpsWriteStatsTraker.scala	45
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/OdpsWriterFactory.scala	23
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/catalyst/expressions/hash.scala	174
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/catalyst/plans/physical/partitioning.scala	75
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/execution/exchange/OdpsShuffleExchangeExec.scala	227
spark-connector/common/src/main/scala/org/apache/spark/sql/odps/execution/vectorized/ArrowBatchWriter.scala	338
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsBatchWrite.scala	96
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsMetaClient.scala	185
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsOptions.scala	89
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsScan.scala	241
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsScanBuilder.scala	64
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsStatistics.scala	14
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsTable.scala	117
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsTableCatalog.scala	634
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsWriteBuilder.scala	205
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/extension/OdpsExtensions.scala	155
spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/extension/commands.scala	42
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala	20
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveExternalCatalog.scala	769
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveInspectors.scala	876
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala	30
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala	156
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveShim.scala	178
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala	124
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/HiveUtils.scala	415
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/OdpsOptions.scala	188
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClient.scala	137
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala	979
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala	1450
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/client/IsolatedClientLoader.scala	237
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/client/package.scala	88
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateOdpsTableAsSelectCommand.scala	90
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveOptions.scala	83
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoOdpsTable.scala	196
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/OdpsSqlParser.scala	39
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/OdpsTableProvider.scala	5
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/OdpsTableScanExec.scala	345
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/OdpsTableWriter.scala	254
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/PruneHiveTablePartitions.scala	68
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/execution/command/ddl.scala	27
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala	330
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/package-info.java	1
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/package.scala	2
spark-connector/hive/src/main/scala/org/apache/spark/sql/hive/security/HiveDelegationTokenProvider.scala	93
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/converter/TypesConverter.scala	288
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/datasource/DefaultSource.scala	33
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/datasource/OdpsBaseSource.scala	57
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/datasource/OdpsSourceOptions.scala	16
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/reader/DataSourceReader.scala	200
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/reader/InputSplitReader.scala	72
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/reader/InputSplitReaderFactory.scala	21
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/writer/DataSourceWriter.scala	91
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/writer/DynamicPartitionWriter.scala	88
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/writer/PartitionWriterFactory.scala	22
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/writer/SinglePartitionWriter.scala	79
spark-datasource-v2.3/src/main/scala/org/apache/spark/sql/odps/writer/SparkCommitMessage.scala	10
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/converter/TypesConverter.scala	287
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/datasource/DefaultSource.scala	69
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/datasource/OdpsSourceOptions.scala	15
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/datasource/OdpsTable.scala	88
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/reader/InputSplitReader.scala	72
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/reader/OdpsScan.scala	179
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/reader/OdpsScanBuilder.scala	89
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/writer/DynamicPartitionWriter.scala	94
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/writer/OdpsBatchWrite.scala	31
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/writer/OdpsWriteBuilder.scala	82
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/writer/PartitionWriterFactory.scala	22
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/writer/SinglePartitionWriter.scala	82
spark-datasource-v3.1/src/main/scala/org/apache/spark/sql/odps/writer/SparkCommitMessage.scala	10
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelDynamicWriteMsg.java	66
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelInputSplit.java	56
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelProvider.java	111
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelReadSession.java	162
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelReader.java	104
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelStreamWriter.java	79
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelWriteMsg.java	4
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelWriteSession.java	206
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelWriteSessionInfo.java	37
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/TunnelWriter.java	145
table-api-tunnel-impl/src/main/java/com/aliyun/odps/cupid/table/v1/tunnel/impl/Util.java	192
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeColumnHandle.java	70
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeConfig.java	62
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeConnector.java	64
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeConnectorFactory.java	32
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeErrorCode.java	25
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeInputSplit.java	80
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeMetadata.java	157
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeModule.java	20
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputePageSource.java	128
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputePageSourceProvider.java	32
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputePlugin.java	13
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeSplit.java	59
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeSplitManager.java	142
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeTableHandle.java	119
trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeTransactionHandle.java	7
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/ArrowToPageConverter.java	73
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/ArrowUtils.java	260
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/CommonUtils.java	38
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/MaxComputeArrowToPageConverter.java	221
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/MaxComputeMetaCache.java	61
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/MaxComputeUtils.java	76
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/SimpleDataAccessor.java	39
trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/TypeConvertUtils.java	77