Path Lines of Code holo-chatbot-webui/Pooling.py 122 holo-chatbot-webui/args.py 45 holo-chatbot-webui/html/footer.html 8 holo-chatbot-webui/main.py 165 holo-chatbot-webui/modules/CustomLLM.py 59 holo-chatbot-webui/modules/CustomPrompt.py 66 holo-chatbot-webui/modules/EASAgent.py 19 holo-chatbot-webui/modules/EmbeddingModel.py 9 holo-chatbot-webui/modules/KeywordExtractor.py 15 holo-chatbot-webui/modules/LLMService.py 134 holo-chatbot-webui/modules/QuestionPrompt.py 12 holo-chatbot-webui/modules/TextSplitter.py 59 holo-chatbot-webui/modules/UI.py 204 holo-chatbot-webui/modules/VectorDB.py 43 holo-chatbot-webui/style.css 13 holo-chatbot-webui/webui.py 108 holo-chatbot/chatbot.py 99 holo-chatbot/dingding_server.py 36 holo-chatbot/generate_config.py 18 holo-chatbot/utils.py 14 holo-client-c/include/defs.h 72 holo-client-c/include/holo_client.h 26 holo-client-c/include/holo_config.h 40 holo-client-c/include/logger.h 11 holo-client-c/include/record.h 28 holo-client-c/include/request.h 58 holo-client-c/include/table_schema.h 30 holo-client-c/include/worker_pool.h 14 holo-client-c/src/action.c 83 holo-client-c/src/action.h 51 holo-client-c/src/batch.c 125 holo-client-c/src/batch.h 37 holo-client-c/src/connection_holder.c 462 holo-client-c/src/connection_holder.h 54 holo-client-c/src/direct_collector.c 96 holo-client-c/src/direct_collector.h 22 holo-client-c/src/exception.c 84 holo-client-c/src/exception.h 55 holo-client-c/src/future.c 37 holo-client-c/src/future.h 16 holo-client-c/src/get_collector.c 167 holo-client-c/src/get_collector.h 40 holo-client-c/src/holo_client.c 534 holo-client-c/src/holo_client_private.h 20 holo-client-c/src/holo_config.c 132 holo-client-c/src/holo_config_private.h 6 holo-client-c/src/ilist.h 273 holo-client-c/src/keywords.c 47 holo-client-c/src/keywords.h 19 holo-client-c/src/kwlist.h 444 holo-client-c/src/logger.c 21 holo-client-c/src/logger_log4c.c 62 holo-client-c/src/logger_log4c.h 8 holo-client-c/src/logger_private.h 48 holo-client-c/src/lp_map.c 21 holo-client-c/src/lp_map.h 14 holo-client-c/src/meta_cache.c 178 holo-client-c/src/meta_cache.h 36 holo-client-c/src/metrics.c 144 holo-client-c/src/metrics.h 56 holo-client-c/src/murmur3.c 193 holo-client-c/src/murmur3.h 13 holo-client-c/src/mutation_collector.c 384 holo-client-c/src/mutation_collector.h 69 holo-client-c/src/mutation_map.c 61 holo-client-c/src/mutation_map.h 18 holo-client-c/src/record.c 351 holo-client-c/src/record_private.h 30 holo-client-c/src/request.c 1020 holo-client-c/src/request_private.h 54 holo-client-c/src/sql_builder.c 408 holo-client-c/src/sql_builder.h 14 holo-client-c/src/table_schema.c 91 holo-client-c/src/table_schema_private.h 16 holo-client-c/src/utils.c 334 holo-client-c/src/utils.h 47 holo-client-c/src/worker.c 865 holo-client-c/src/worker.h 37 holo-client-c/src/worker_pool.c 118 holo-client-c/src/worker_pool_private.h 18 holo-client-go/example.go 160 holo-client-go/holo-client/holo_client.go 70 holo-client-go/holo-client/holo_config.go 70 holo-client-go/holo-client/include/defs.h 72 holo-client-go/holo-client/include/holo_client.h 26 holo-client-go/holo-client/include/holo_config.h 40 holo-client-go/holo-client/include/logger.h 11 holo-client-go/holo-client/include/record.h 28 holo-client-go/holo-client/include/request.h 58 holo-client-go/holo-client/include/table_schema.h 30 holo-client-go/holo-client/include/worker_pool.h 14 holo-client-go/holo-client/request.go 277 holo-client/src/main/java/com/alibaba/hologres/client/BinlogPartitionGroupReader.java 252 holo-client/src/main/java/com/alibaba/hologres/client/BinlogShardGroupReader.java 175 holo-client/src/main/java/com/alibaba/hologres/client/CheckAndPut.java 45 holo-client/src/main/java/com/alibaba/hologres/client/Command.java 142 holo-client/src/main/java/com/alibaba/hologres/client/EqualsFilter.java 15 holo-client/src/main/java/com/alibaba/hologres/client/Exporter.java 72 holo-client/src/main/java/com/alibaba/hologres/client/Filter.java 3 holo-client/src/main/java/com/alibaba/hologres/client/Get.java 127 holo-client/src/main/java/com/alibaba/hologres/client/HoloClient.java 851 holo-client/src/main/java/com/alibaba/hologres/client/HoloConfig.java 445 holo-client/src/main/java/com/alibaba/hologres/client/Importer.java 82 holo-client/src/main/java/com/alibaba/hologres/client/Put.java 48 holo-client/src/main/java/com/alibaba/hologres/client/RangeFilter.java 20 holo-client/src/main/java/com/alibaba/hologres/client/RecordInputFormat.java 57 holo-client/src/main/java/com/alibaba/hologres/client/RecordOutputFormat.java 208 holo-client/src/main/java/com/alibaba/hologres/client/Scan.java 126 holo-client/src/main/java/com/alibaba/hologres/client/SortKeys.java 6 holo-client/src/main/java/com/alibaba/hologres/client/Subscribe.java 147 holo-client/src/main/java/com/alibaba/hologres/client/Trace.java 33 holo-client/src/main/java/com/alibaba/hologres/client/copy/CopyInOutputStream.java 52 holo-client/src/main/java/com/alibaba/hologres/client/copy/CopyMode.java 6 holo-client/src/main/java/com/alibaba/hologres/client/copy/CopyUtil.java 84 holo-client/src/main/java/com/alibaba/hologres/client/copy/RecordBinaryOutputStream.java 328 holo-client/src/main/java/com/alibaba/hologres/client/copy/RecordOutputStream.java 104 holo-client/src/main/java/com/alibaba/hologres/client/copy/RecordTextOutputStream.java 102 holo-client/src/main/java/com/alibaba/hologres/client/copy/WithCopyResult.java 4 holo-client/src/main/java/com/alibaba/hologres/client/ddl/DDLGenerator.java 94 holo-client/src/main/java/com/alibaba/hologres/client/ddl/DDLGeneratorUtil.java 132 holo-client/src/main/java/com/alibaba/hologres/client/ddl/StatementKeywords.java 34 holo-client/src/main/java/com/alibaba/hologres/client/exception/ExceptionCode.java 40 holo-client/src/main/java/com/alibaba/hologres/client/exception/HoloClientException.java 68 holo-client/src/main/java/com/alibaba/hologres/client/exception/HoloClientWithDetailsException.java 60 holo-client/src/main/java/com/alibaba/hologres/client/exception/InvalidIdentifierException.java 14 holo-client/src/main/java/com/alibaba/hologres/client/function/FunctionWithSQLException.java 5 holo-client/src/main/java/com/alibaba/hologres/client/impl/Cache.java 147 holo-client/src/main/java/com/alibaba/hologres/client/impl/ConnectionHolder.java 310 holo-client/src/main/java/com/alibaba/hologres/client/impl/ExecutionPool.java 587 holo-client/src/main/java/com/alibaba/hologres/client/impl/MetaStore.java 12 holo-client/src/main/java/com/alibaba/hologres/client/impl/ObjectChan.java 51 holo-client/src/main/java/com/alibaba/hologres/client/impl/OneshotWorker.java 32 holo-client/src/main/java/com/alibaba/hologres/client/impl/PreparedStatementWithBatchInfo.java 31 holo-client/src/main/java/com/alibaba/hologres/client/impl/RecordReader.java 247 holo-client/src/main/java/com/alibaba/hologres/client/impl/UnnestUpsertStatementBuilder.java 373 holo-client/src/main/java/com/alibaba/hologres/client/impl/UpsertStatementBuilder.java 709 holo-client/src/main/java/com/alibaba/hologres/client/impl/Worker.java 133 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/AbstractAction.java 36 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/CopyAction.java 55 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/EmptyAction.java 3 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/GetAction.java 12 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/MetaAction.java 12 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/PutAction.java 45 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/ScanAction.java 12 holo-client/src/main/java/com/alibaba/hologres/client/impl/action/SqlAction.java 12 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/ArrayBuffer.java 69 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/BinlogEventType.java 33 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/BinlogLevel.java 5 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/BinlogOffset.java 58 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/BinlogRecordCollector.java 43 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/Committer.java 40 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/HoloBinlogDecoder.java 290 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/TableSchemaSupplier.java 6 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/action/BinlogAction.java 54 holo-client/src/main/java/com/alibaba/hologres/client/impl/binlog/handler/BinlogActionHandler.java 259 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/ActionCollector.java 159 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/BatchState.java 19 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/CollectorStatistics.java 34 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/DefaultResizePolicy.java 35 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/RecordCollector.java 191 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/ResizePolicy.java 7 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/TableCollector.java 95 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/TableShardCollector.java 226 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/shard/DistributionKeyShardPolicy.java 21 holo-client/src/main/java/com/alibaba/hologres/client/impl/collector/shard/ShardPolicy.java 6 holo-client/src/main/java/com/alibaba/hologres/client/impl/copy/CopyContext.java 23 holo-client/src/main/java/com/alibaba/hologres/client/impl/copy/InternalPipedOutputStream.java 11 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/ActionHandler.java 132 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/CopyActionHandler.java 206 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/EmptyActionHandler.java 16 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/GetActionHandler.java 124 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/MetaActionHandler.java 43 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/PutActionHandler.java 187 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/ScanActionHandler.java 204 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/SqlActionHandler.java 25 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcBigDecimalColumnValues.java 56 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcBooleanColumnValues.java 70 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcByteaColumnValues.java 30 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcColumnValues.java 50 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcColumnValuesBuilder.java 62 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcDateColumnValues.java 66 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcDoubleColumnValues.java 44 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcFloatColumnValues.java 44 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcIntegerColumnValues.java 44 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcLongColumnValues.java 44 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcShortColumnValues.java 44 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcStringColumnValues.java 42 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcTimeColumnValues.java 60 holo-client/src/main/java/com/alibaba/hologres/client/impl/handler/jdbc/JdbcTimestampColumnValues.java 81 holo-client/src/main/java/com/alibaba/hologres/client/impl/util/ConnectionUtil.java 429 holo-client/src/main/java/com/alibaba/hologres/client/impl/util/ExceptionUtil.java 21 holo-client/src/main/java/com/alibaba/hologres/client/impl/util/ShardUtil.java 86 holo-client/src/main/java/com/alibaba/hologres/client/model/AutoPartitioning.java 75 holo-client/src/main/java/com/alibaba/hologres/client/model/Column.java 93 holo-client/src/main/java/com/alibaba/hologres/client/model/ExportContext.java 41 holo-client/src/main/java/com/alibaba/hologres/client/model/HoloVersion.java 76 holo-client/src/main/java/com/alibaba/hologres/client/model/ImportContext.java 52 holo-client/src/main/java/com/alibaba/hologres/client/model/Partition.java 39 holo-client/src/main/java/com/alibaba/hologres/client/model/Record.java 302 holo-client/src/main/java/com/alibaba/hologres/client/model/RecordKey.java 100 holo-client/src/main/java/com/alibaba/hologres/client/model/RecordScanner.java 75 holo-client/src/main/java/com/alibaba/hologres/client/model/SSLMode.java 22 holo-client/src/main/java/com/alibaba/hologres/client/model/TableName.java 194 holo-client/src/main/java/com/alibaba/hologres/client/model/TableSchema.java 341 holo-client/src/main/java/com/alibaba/hologres/client/model/WriteFailStrategy.java 5 holo-client/src/main/java/com/alibaba/hologres/client/model/WriteMode.java 6 holo-client/src/main/java/com/alibaba/hologres/client/model/binlog/BinlogHeartBeatRecord.java 12 holo-client/src/main/java/com/alibaba/hologres/client/model/binlog/BinlogPartitionSubscribeMode.java 6 holo-client/src/main/java/com/alibaba/hologres/client/model/binlog/BinlogRecord.java 40 holo-client/src/main/java/com/alibaba/hologres/client/model/checkandput/CheckAndPutCondition.java 81 holo-client/src/main/java/com/alibaba/hologres/client/model/checkandput/CheckAndPutRecord.java 27 holo-client/src/main/java/com/alibaba/hologres/client/model/checkandput/CheckCompareOp.java 18 holo-client/src/main/java/com/alibaba/hologres/client/type/PGroaringbitmap.java 26 holo-client/src/main/java/com/alibaba/hologres/client/type/PgDefaultBinaryObject.java 39 holo-client/src/main/java/com/alibaba/hologres/client/utils/CommonUtil.java 81 holo-client/src/main/java/com/alibaba/hologres/client/utils/ConfLoader.java 90 holo-client/src/main/java/com/alibaba/hologres/client/utils/FutureUtil.java 22 holo-client/src/main/java/com/alibaba/hologres/client/utils/IdentifierUtil.java 516 holo-client/src/main/java/com/alibaba/hologres/client/utils/Metrics.java 61 holo-client/src/main/java/com/alibaba/hologres/client/utils/PartitionUtil.java 114 holo-client/src/main/java/com/alibaba/hologres/client/utils/RecordChecker.java 495 holo-client/src/main/java/com/alibaba/hologres/client/utils/Tuple.java 33 holo-client/src/main/java/com/alibaba/hologres/client/utils/Tuple3.java 29 holo-client/src/main/java/com/alibaba/hologres/client/utils/Tuple4.java 32 holo-client/src/main/java/org/postgresql/jdbc/ArrayUtil.java 136 holo-client/src/main/java/org/postgresql/jdbc/TimestampUtil.java 78 holo-client/testng.xml 16 holo-client/tools/maven/scalastyle-config.xml 75 holo-client/tools/maven/spotbugs-exclude.xml 437 holo-client/tools/maven/suppressions-core.xml 63 holo-client/tools/maven/suppressions-optimizer.xml 66 holo-client/tools/maven/suppressions-runtime.xml 144 holo-client/tools/maven/suppressions.xml 43 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/CaseUtil.java 82 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/BinlogTest.java 162 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/FixedCopyTest.java 150 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/GetTest.java 180 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/HoloClientExecutionPool.java 40 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/InsertTest.java 109 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/Main.java 44 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/PrepareBinlogData.java 31 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/PrepareGetData.java 23 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/PrepareScanData.java 26 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/PutTest.java 213 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/Reporter.java 55 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/ScanTest.java 179 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/SqlUtil.java 219 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/client/Util.java 146 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/params/IntRandomParamProvider.java 16 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/params/LongRandomParamProvider.java 16 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/params/ParamProvider.java 5 holo-e2e-performance-tool/src/main/java/com/alibaba/hologres/performace/params/ParamsProvider.java 32 holo-llm-deepseek/main.py 161 holo-llm/main.py 143 holo-shipper/dependency-reduced-pom.xml 132 holo-shipper/src/main/java/com/alibaba/hologres/shipper/HoloDBShipper.java 344 holo-shipper/src/main/java/com/alibaba/hologres/shipper/HoloShipper.java 369 holo-shipper/src/main/java/com/alibaba/hologres/shipper/generic/AbstractDB.java 29 holo-shipper/src/main/java/com/alibaba/hologres/shipper/generic/AbstractInstance.java 13 holo-shipper/src/main/java/com/alibaba/hologres/shipper/generic/AbstractTable.java 16 holo-shipper/src/main/java/com/alibaba/hologres/shipper/holo/HoloDB.java 489 holo-shipper/src/main/java/com/alibaba/hologres/shipper/holo/HoloInstance.java 142 holo-shipper/src/main/java/com/alibaba/hologres/shipper/holo/HoloTable.java 447 holo-shipper/src/main/java/com/alibaba/hologres/shipper/holo/HoloUtils.java 55 holo-shipper/src/main/java/com/alibaba/hologres/shipper/localstorage/LocalStorageDB.java 149 holo-shipper/src/main/java/com/alibaba/hologres/shipper/localstorage/LocalStorageInstance.java 115 holo-shipper/src/main/java/com/alibaba/hologres/shipper/localstorage/LocalStorageTable.java 163 holo-shipper/src/main/java/com/alibaba/hologres/shipper/oss/OSSDB.java 99 holo-shipper/src/main/java/com/alibaba/hologres/shipper/oss/OSSInstance.java 112 holo-shipper/src/main/java/com/alibaba/hologres/shipper/oss/OSSTable.java 142 holo-shipper/src/main/java/com/alibaba/hologres/shipper/oss/OSSUtils.java 51 holo-shipper/src/main/java/com/alibaba/hologres/shipper/utils/CustomPipedInputStream.java 14 holo-shipper/src/main/java/com/alibaba/hologres/shipper/utils/ProcessBar.java 121 holo-shipper/src/main/java/com/alibaba/hologres/shipper/utils/SqlUtil.java 49 holo-shipper/src/main/java/com/alibaba/hologres/shipper/utils/TableInfo.java 10 holo-shipper/src/main/java/com/alibaba/hologres/shipper/utils/TablesMeta.java 185 holo-shipper/src/main/resources/logback.xml 28 holo-utils/find-incompatible-flink-jobs/src/main/java/com/alibaba/hologres/FindIncompatibleFlinkJobs.java 230 holo-utils/find-incompatible-flink-jobs/src/main/java/com/alibaba/hologres/IncompatibleResult.java 11 hologres-connector-datax-writer/src/main/assembly/package.xml 34 hologres-connector-datax-writer/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/BaseWriter.java 456 hologres-connector-datax-writer/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/Constant.java 7 hologres-connector-datax-writer/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/HologresJdbcWriter.java 60 hologres-connector-datax-writer/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/Key.java 15 hologres-connector-datax-writer/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/util/ConfLoader.java 55 hologres-connector-datax-writer/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/util/OriginalConfPretreatmentUtil.java 59 hologres-connector-datax-writer/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/util/WriterUtil.java 85 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/FlinkDSAndSQLToHoloExample.java 68 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/FlinkDataStreamToHoloExample.java 108 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/FlinkRoaringBitmapAggJob.java 215 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/FlinkSQLSourceAndSinkExample.java 69 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/FlinkSQLToHoloExample.java 96 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/FlinkSQLToHoloRePartitionExample.java 83 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/FlinkToHoloRePartitionExample.java 210 hologres-connector-examples/hologres-connector-flink-examples/src/main/java/com/alibaba/ververica/connectors/hologres/example/SourceItem.java 22 hologres-connector-examples/hologres-connector-flink-examples/src/main/resources/repartition.sql 39 hologres-connector-examples/hologres-connector-flink-ordergen/src/main/java/io/hologres/flink/ordergen/City.java 22 hologres-connector-examples/hologres-connector-flink-ordergen/src/main/java/io/hologres/flink/ordergen/OrderGenSourceFunction.java 64 hologres-connector-examples/hologres-connector-flink-ordergen/src/main/java/io/hologres/flink/ordergen/OrderGenTableFactory.java 40 hologres-connector-examples/hologres-connector-flink-ordergen/src/main/java/io/hologres/flink/ordergen/OrderGenTableSource.java 35 hologres-connector-examples/hologres-connector-flink-ordergen/src/main/java/io/hologres/flink/ordergen/PrefectureCity.java 22 hologres-connector-examples/hologres-connector-flink-ordergen/src/main/java/io/hologres/flink/ordergen/Province.java 23 hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkDataFrameToHoloExample.java 72 hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkHoloTableCatalogExample.java 41 hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkHoloToDataFrameExample.java 56 hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkReadHoloToDataFrameExample.java 54 hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkToHoloRepartitionExample.scala 129 hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkWriteDataFrameToHoloExample.java 72 hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkWriteToHoloRepartitionExample.scala 46 hologres-connector-flink-1.15/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/Flink115HologresLookUpFunctionFactory.java 32 hologres-connector-flink-1.17/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/Flink117HologresLookUpFunctionFactory.java 32 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/HologresIOClient.java 23 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/HologresReader.java 21 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/HologresRecordConverter.java 7 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/HologresTableSchema.java 45 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/HologresWriter.java 13 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/table/HologresRowDataConverter.java 236 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/table/PrimaryKeyBuilder.java 61 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/table/RowDataReader.java 132 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/api/table/RowDataWriter.java 256 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/config/HologresConfigs.java 82 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/config/HologresConnectionParam.java 357 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/config/JDBCOptions.java 87 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/factory/HologresTableFactory.java 75 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/jdbc/HologresJDBCClientProvider.java 96 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/jdbc/HologresJDBCConfigs.java 91 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/jdbc/HologresJDBCReader.java 197 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/jdbc/HologresJDBCRecordReader.java 204 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/jdbc/HologresJDBCRecordWriter.java 139 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/jdbc/HologresJDBCWriter.java 168 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/jdbc/copy/HologresJDBCCopyWriter.java 409 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/HologresDataStreamSinkProvider.java 19 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/HologresDynamicTableSink.java 93 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/HologresOutputFormat.java 98 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/HologresRepartitionSinkBuilder.java 92 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/HologresSinkFunction.java 20 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/HologresStreamPartitioner.java 56 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/HologresTableOutputFormat.java 44 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/repartition/HoloKeySelector.java 25 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/repartition/RowDataShardUtil.java 67 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/v2/HologresSink.java 28 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/sink/v2/HologresSinkWriter.java 93 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/HologresLookUpFunctionFactory.java 23 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/HologresTableSource.java 122 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/bulkread/HologresBulkReader.java 186 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/bulkread/HologresBulkreadInputFormat.java 86 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/bulkread/HologresShardInputSplit.java 12 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/AbstractHologresLookupFunction.java 57 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/DimJoinFetcher.java 211 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/HologresAsyncLookupFunction.java 74 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/HologresLookupFunction.java 52 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/utils/FlinkUtil.java 31 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/utils/HologresUtils.java 17 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/utils/JDBCUtils.java 221 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/utils/PostgresTypeUtil.java 114 hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/utils/SchemaUtil.java 21 hologres-connector-hive-2.x/src/main/java/com/alibaba/hologres/hive/HoloStorageHandler.java 2 hologres-connector-hive-3.x/src/main/java/com/alibaba/hologres/hive/HoloStorageHandler.java 8 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/BaseHoloStorageHandler.java 90 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/HoloClientProvider.java 54 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/HoloRecordWritable.java 41 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/HoloSerDe.java 454 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/conf/HoloClientParam.java 265 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/conf/HoloStorageConfig.java 55 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/conf/HoloStorageConfigManager.java 19 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/exception/HiveHoloStorageException.java 16 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/input/HoloInputFormat.java 67 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/input/HoloInputSplit.java 38 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/input/HoloRecordReader.java 135 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/output/HoloOutputFormat.java 98 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/output/HoloRecordCopyWriter.java 282 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/output/HoloRecordWriter.java 54 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/utils/DataTypeUtils.java 86 hologres-connector-hive-base/src/main/java/com/alibaba/hologres/hive/utils/JDBCUtils.java 174 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/HoloSinkConnector.java 44 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/conf/HoloSinkConfig.java 477 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/conf/HoloSinkConfigManager.java 136 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/exception/KafkaHoloException.java 16 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/model/DirtyDataStrategy.java 6 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/model/InputFormat.java 6 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/sink/HoloSinkTask.java 97 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/sink/HoloSinkWriter.java 293 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/sink/writer/AbstractHoloWriter.java 8 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/sink/writer/HoloCopyWriter.java 166 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/sink/writer/HoloSqlWriter.java 34 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/utils/DirtyDataUtils.java 26 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/utils/JDBCUtils.java 66 hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/utils/MessageInfo.java 21 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/HoloTable.scala 67 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/HoloTableCatalog.scala 96 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/SourceProvider.scala 61 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/sink/HoloDataWriter.scala 13 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/sink/HoloTable.scala 21 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/sink/HoloWriterBuilder.scala 106 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/sink/HoloWriterBuilderV1.scala 36 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/sink/SourceProvider.scala 27 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/sink/copy/HoloDataCopyWriter.scala 14 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/source/HoloInputPartition.scala 8 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/source/HoloPartitionReader.scala 13 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/source/HoloScanBuilder.scala 133 hologres-connector-spark-3.x/src/main/scala/com/alibaba/hologres/spark3/source/copy/HoloCopyPartitionReader.scala 9 hologres-connector-spark-base/src/main/java/com/alibaba/hologres/spark/exception/SparkHoloException.java 16 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/BaseSourceProvider.scala 55 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/config/HologresConfigs.scala 109 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/sink/BaseHoloDataWriter.scala 104 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/sink/BaseSourceProvider.scala 33 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/sink/FieldWriter.scala 145 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/sink/copy/BaseHoloDataCopyWriter.scala 128 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/sink/copy/CopyContext.scala 90 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/BaseHoloPartitionReader.scala 75 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/FieldReader.scala 156 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/BaseHoloCopyPartitionReader.scala 84 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/CopyContext.scala 78 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/arrow/SparkArrowArrayAccessor.scala 21 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/arrow/SparkArrowDateDayAccessor.scala 12 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/arrow/SparkArrowDateMilliAccessor.scala 13 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/arrow/SparkArrowDecimalAccessor.scala 13 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/arrow/SparkArrowStringAccessor.scala 13 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/arrow/SparkArrowTimeStampMicroAccessor.scala 14 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/source/copy/arrow/SparkArrowVectorAccessorUtil.scala 70 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/table/Column.scala 50 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/table/ColumnType.scala 5 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/table/TableColumn.scala 44 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/utils/DataTypeUtil.scala 45 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/utils/JDBCUtil.scala 369 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/utils/RepartitionUtil.scala 101 hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/utils/SparkHoloUtil.scala 187 tools/maven/scalastyle-config.xml 53 tools/maven/spotbugs-exclude.xml 437 tools/maven/suppressions-core.xml 72 tools/maven/suppressions-optimizer.xml 66 tools/maven/suppressions-runtime.xml 112 tools/maven/suppressions.xml 45