Path Lines of Code cupid-table-api/src/main/java/com/aliyun/odps/cupid/table/v1/reader/ReadCapabilities.java 22 flink-connector-odps/src/main/java/org/apache/flink/odps/catalog/OdpsCatalog.java 650 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/RecordIterator.java 94 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/file/ColumnarBlockWriter.java 51 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/GroupedOdpsPartitionStreamWrite.java 63 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/util/OdpsTypeConverter.java 790 flink-connector-odps/src/main/java/org/apache/flink/odps/util/OdpsTypeUtil.java 214 hive_data_transfer_udtf/src/main/java/odps/data/dump/MaxComputeDataTransferUDTFMultiPart.java 199 odps-data-carrier/data-transfer-hive-udtf/src/main/java/com/aliyun/odps/datacarrier/transfer/converter/HiveCharObjectConverter.java 12 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/report/ReportBuilder.java 50 odps-sqoop/pom-old.xml 548 odps-sqoop/src/java/com/cloudera/sqoop/mapreduce/db/DBRecordReader.java 14 odps-sqoop/src/java/org/apache/sqoop/SqoopOptions.java 1741 odps-sqoop/src/java/org/apache/sqoop/avro/AvroUtil.java 174 odps-sqoop/src/java/org/apache/sqoop/lib/JdbcWritableBridge.java 194 odps-sqoop/src/java/org/apache/sqoop/lib/RecordParser.java 240 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/oracle/OraOopDBRecordReader.java 308 odps-sqoop/src/java/org/apache/sqoop/mapreduce/JobBase.java 246 odps-sqoop/src/java/org/apache/sqoop/mapreduce/MySQLExportMapper.java 237 odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DBInputFormat.java 250 odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java 226 odps-sqoop/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java 253 odps-sqoop/src/java/org/apache/sqoop/mapreduce/odps/HdfsOdpsImportJob.java 640 odps-sqoop/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbJobStorage.java 575 odps-sqoop/src/java/org/apache/sqoop/tool/BaseSqoopTool.java 1573 odps-sqoop/src/java/org/apache/sqoop/tool/JobTool.java 277 presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeColumnHandle.java 70 presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeMetadata.java 177 presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/ArrowToPageConverter.java 80 presto-connector/src/main/java/com/facebook/presto/maxcompute/utils/MaxComputeMetaCache.java 61 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/table/tunnel/read/TunnelArrowSplitReader.java 227 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/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/utils/ArrowSchemaUtils.java 155 spark-connector/common/src/main/java/org/apache/spark/sql/odps/vectorized/OdpsArrowColumnVector.java 248 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/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/execution/exchange/OdpsShuffleExchangeExec.scala 227 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/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/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/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/execution/CreateOdpsTableAsSelectCommand.scala 90 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/OdpsTableScanExec.scala 345 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/hiveUDFs.scala 330 trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeColumnHandle.java 70 trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeMetadata.java 157 trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/MaxComputeMetaCache.java 61 trino-connector/src/main/java/io/trino/plugin/maxcompute/utils/TypeConvertUtils.java 77