This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a change to branch branch-2.0-beta
in repository https://gitbox.apache.org/repos/asf/doris.git
from b4e552c3c3 [typo](docs) add parameter version (#20672)
add 6652287b52 [Fix](regression-test) fix unstable test case
nereids_p0/update (#20692)
add 1433544c56 [fix](case expr) fix coredump of case for null value 3
#20711
add 283c55720d [bug](cooldown) Fix the issue of unused remote files not
being deleted (#19785)
add 412ca9059e [fix](routine-load) fix stackoverflow bug in routine load
(#20704)
add 5e3a96d605 [Bug](pipeline) fix memory leak because pipeline shared ptr
not release #20710
add 939575f5f3 [fix](mtmv)create mtmv failed when not specifying refresh
strategy #20696
add 73ad885e19 [Feature][Fix](multi-catalog) Implements transactional hive
full acid tables. (#20679)
add 550584e4e9 [docs](docs)Add the list of BI tools supported by Doris.
(#20690)
add 4ac38ca67a [typo](docs) add a python example for stream load. (#20697)
add ef4410821f [typo](doc)document optimization (#20645)
add 51bbf17786 [Refactor](Profile) Add and refactor the join profile
(#20693)
add 57656b2459 [Enhancement](java-udf) java-udf module split to sub
modules (#20185)
add e28187feb7 [fix](hive) fix NPE of hive meta store client (#20664)
add ce3050d75c [fix](regression) fix vertical compaction test (#20601)
add ee0e2b40da [Improvement](meta) support return brief info of restore
job (#20653)
add e010fa8d4f [Chore](runtime filter) remove runtime filter
ready_for_publish/publish_finally (#20593)
add eaa13e66f9 [fix](planner) inplement constant folding for function
to_monday() (#20708)
add 033f64de93 [tools](tpch)add analyze in run-tpch-queries.sh (#20733)
add 54a7dbeb4d [Refactor](External) Move Common ODBC Methods to JDBC Class
and Add Default config to Disable ODBC Creation (#20566)
add 2adf5169e6 [improvement](test) improve p2 case of githubevents (#20727)
add 4b15185e25 [improvement](hdfs) add parquet footer cache and hdfs file
handle cache (#20544)
add 2dddab03a1 [compatibility](schema cache) ensure schema version when
using schema cache (#20729)
add feb21fc9e9 [fix](group_concat) use default seperator ',' instead of ',
' for group_concat, to be consistant with mysql (#20741)
add 0e82c0d7a2 [Fix](Nereids) constant folding for function timestamp()
(#20607)
add 7942bd0bf9 [fix](planner) cast string literal to date like type should
not be an implict cast (#20709)
add 7636dd1fdc [fix](nereids) always use colocate scan when agg's fragment
has olap scan (#20695)
add ad2f1b5647 [Update](clucene) synchronize clucene version to address
PFOR adaptation issue (#20736)
add 37db0145b4 [fix](load) fix mysql load parse response npe (#20699)
add 9244cb6553 [Chore](runtime-filter) do not make query fail when rf
publish failed (#20742)
add 5d2758cb8f [improvement](build) move add BE extension jars to
java_extensions dir (#20740)
add f1fd486f84 [fix](docker)Fix docker be init script restart failed bug
(#20505)
add 35c19daec7 [opt](routine load) log BE id when get partitions failed.
(#20749)
No new revisions were added by this update.
Summary of changes:
be/src/clucene | 2 +-
be/src/common/config.cpp | 7 +-
be/src/common/config.h | 9 +-
be/src/exec/exec_node.cpp | 1 -
be/src/exprs/runtime_filter.cpp | 36 --
be/src/exprs/runtime_filter.h | 16 +-
be/src/exprs/runtime_filter_rpc.cpp | 35 +-
be/src/exprs/runtime_filter_slots.h | 41 +-
be/src/exprs/runtime_filter_slots_cross.h | 10 +-
be/src/io/CMakeLists.txt | 2 +-
be/src/io/fs/file_handle_cache.cpp | 193 +++++++++
be/src/io/fs/file_handle_cache.h | 199 +++++++++
be/src/io/fs/file_meta_cache.cpp | 42 ++
.../fs/file_meta_cache.h} | 45 +-
be/src/io/fs/hdfs_file_reader.cpp | 35 +-
be/src/io/fs/hdfs_file_reader.h | 13 +-
be/src/io/fs/hdfs_file_system.cpp | 72 ++--
be/src/io/fs/hdfs_file_system.h | 3 +
be/src/io/fs/s3_file_system.cpp | 4 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 6 +-
be/src/olap/tablet.cpp | 16 +-
be/src/olap/tablet_manager.cpp | 2 +-
be/src/olap/tablet_schema.h | 2 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 1 +
be/src/pipeline/pipeline.h | 4 +-
be/src/pipeline/pipeline_task.h | 2 +-
be/src/runtime/exec_env.h | 4 +
be/src/runtime/exec_env_init.cpp | 3 +
be/src/runtime/runtime_filter_mgr.cpp | 20 +-
be/src/service/internal_service.cpp | 3 +-
be/src/util/CMakeLists.txt | 2 +-
be/src/util/jni-util.cpp | 8 +-
be/src/util/jni_native_method.h | 2 +-
be/src/util/lru_multi_cache.h | 244 +++++++++++
be/src/util/lru_multi_cache.inline.h | 291 +++++++++++++
.../{jni_native_method.h => obj_lru_cache.cpp} | 51 +--
be/src/util/obj_lru_cache.h | 103 +++++
.../aggregate_function_group_concat.cpp | 2 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 137 ++++--
be/src/vec/exec/format/orc/vorc_reader.h | 28 +-
.../vec/exec/format/parquet/parquet_thrift_util.h | 6 +-
.../exec/format/parquet/vparquet_column_reader.h | 4 +
.../exec/format/parquet/vparquet_page_reader.cpp | 5 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 37 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 11 +-
.../format/table/transactional_hive_common.cpp | 72 ++++
.../exec/format/table/transactional_hive_common.h | 54 +++
.../format/table/transactional_hive_reader.cpp | 191 ++++++++
.../exec/format/table/transactional_hive_reader.h | 144 +++++++
be/src/vec/exec/jni_connector.cpp | 10 +-
be/src/vec/exec/jni_connector.h | 8 +-
.../vec/exec/join/process_hash_table_probe_impl.h | 2 +
be/src/vec/exec/join/vhash_join_node.cpp | 29 +-
be/src/vec/exec/join/vhash_join_node.h | 12 +-
be/src/vec/exec/join/vjoin_node_base.cpp | 21 +
be/src/vec/exec/join/vjoin_node_base.h | 8 +-
be/src/vec/exec/join/vnested_loop_join_node.cpp | 31 +-
be/src/vec/exec/scan/jni_reader.cpp | 4 +-
be/src/vec/exec/scan/max_compute_jni_reader.cpp | 4 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 7 +-
be/src/vec/exec/scan/paimon_reader.cpp | 4 +-
be/src/vec/exec/scan/vfile_scanner.cpp | 34 +-
be/src/vec/exec/scan/vfile_scanner.h | 1 +
be/src/vec/exec/scan/vscan_node.cpp | 5 -
be/src/vec/exec/vjdbc_connector.cpp | 2 +-
be/src/vec/exprs/vexpr_context.cpp | 4 +
be/src/vec/functions/function_case.h | 12 +-
be/test/CMakeLists.txt | 1 -
be/test/io/fs/remote_file_system_test.cpp | 2 +
be/test/olap/file_header_test.cpp | 6 +-
be/test/util/lru_multi_cache_test.cpp | 480 +++++++++++++++++++++
bin/start_be.sh | 10 +-
build.sh | 116 ++---
conf/fe.conf | 4 +-
docker/runtime/be/resource/init_be.sh | 4 +-
.../hive/scripts/create_preinstalled_table.hql | 39 ++
docs/en/docs/admin-manual/config/fe-config.md | 2 +-
.../import/import-way/stream-load-manual.md | 16 +
.../Create/CREATE-TABLE.md | 2 +-
.../sql-reference/Show-Statements/SHOW-RESTORE.md | 8 +-
docs/en/docs/summary/basic-summary.md | 2 +-
docs/zh-CN/docs/admin-manual/config/fe-config.md | 2 +-
.../import/import-way/stream-load-manual.md | 16 +
.../Create/CREATE-TABLE.md | 2 +-
.../sql-reference/Show-Statements/SHOW-RESTORE.md | 8 +-
docs/zh-CN/docs/summary/basic-summary.md | 2 +-
.../hudi-scanner}/pom.xml | 103 +----
.../org/apache/doris/hudi/HudiColumnValue.java | 3 +-
.../java/org/apache/doris/hudi/HudiJniScanner.java | 9 +-
.../java/org/apache/doris/hudi/HudiScanParam.java | 3 +-
.../java/org/apache/doris/hudi/HudiScanUtils.java | 0
.../main/java/org/apache/doris/hudi}/Utils.java | 2 +-
.../hudi-scanner}/src/main/resources/package.xml | 0
.../org/apache/doris/hudi/HudiJniScannerTest.java | 0
fe/be-java-extensions/java-common/pom.xml | 60 +++
.../doris/common/exception}/InternalException.java | 2 +-
.../common/exception}/UdfRuntimeException.java | 2 +-
.../org/apache/doris/common}/jni/JniScanner.java | 11 +-
.../apache/doris/common}/jni/MockJniScanner.java | 9 +-
.../doris/common/jni/utils}/JMXJsonUtil.java | 2 +-
.../doris/common/jni/utils}/JNINativeMethod.java | 2 +-
.../apache/doris/common/jni/utils}/JniUtil.java | 3 +-
.../doris/common/jni/utils}/JvmPauseMonitor.java | 2 +-
.../apache/doris/common}/jni/utils/OffHeap.java | 3 +-
.../doris/common}/jni/utils/TypeNativeBytes.java | 2 +-
.../apache/doris/common/jni/utils}/UdfUtils.java | 7 +-
.../apache/doris/common}/jni/vec/ColumnType.java | 2 +-
.../apache/doris/common}/jni/vec/ColumnValue.java | 2 +-
.../doris/common}/jni/vec/ScanPredicate.java | 9 +-
.../apache/doris/common}/jni/vec/VectorColumn.java | 9 +-
.../apache/doris/common}/jni/vec/VectorTable.java | 7 +-
.../src/main/resources/log4j.properties | 0
.../java-common}/src/main/resources/package.xml | 0
.../apache/doris/common}/jni/JniScannerTest.java | 7 +-
fe/be-java-extensions/java-udf/pom.xml | 74 ++++
.../java/org/apache/doris/udf/BaseExecutor.java | 5 +-
.../java/org/apache/doris/udf/UdafExecutor.java | 4 +-
.../java/org/apache/doris/udf/UdfExecutor.java | 4 +-
.../java-udf/src/main/resources/package.xml | 0
.../java/org/apache/doris/udf/ConstantOneUdf.java | 0
.../java/org/apache/doris/udf/DateTimeUdf.java | 0
.../test/java/org/apache/doris/udf/DecimalUdf.java | 0
.../java/org/apache/doris/udf/LargeIntUdf.java | 0
.../java/org/apache/doris/udf/SimpleAddUdf.java | 0
.../java/org/apache/doris/udf/StringConcatUdf.java | 0
.../java/org/apache/doris/udf/UdfExecutorTest.java | 1 +
fe/be-java-extensions/jdbc-scanner/pom.xml | 90 ++++
.../org/apache/doris/jdbc}/JdbcDataSource.java | 2 +-
.../java/org/apache/doris/jdbc}/JdbcExecutor.java | 14 +-
.../jdbc-scanner}/src/main/resources/package.xml | 0
fe/be-java-extensions/max-compute-scanner/pom.xml | 104 +++++
.../doris/maxcompute}/MaxComputeColumnValue.java | 4 +-
.../doris/maxcompute}/MaxComputeJniScanner.java | 8 +-
.../src/main/resources/package.xml | 0
fe/be-java-extensions/paimon-scanner/pom.xml | 100 +++++
.../apache/doris/paimon}/PaimonColumnValue.java | 4 +-
.../org/apache/doris/paimon}/PaimonJniScanner.java | 10 +-
.../paimon-scanner}/src/main/resources/package.xml | 0
fe/be-java-extensions/pom.xml | 46 ++
.../main/java/org/apache/doris/common/Config.java | 9 +
fe/fe-core/pom.xml | 5 +-
fe/fe-core/src/main/cup/sql_parser.cup | 12 +-
.../apache/doris/analysis/CreateResourceStmt.java | 5 +
.../org/apache/doris/analysis/CreateTableStmt.java | 4 +
.../org/apache/doris/analysis/DataDescription.java | 13 +-
.../org/apache/doris/analysis/FloatLiteral.java | 5 +-
.../org/apache/doris/analysis/LikePredicate.java | 2 +
.../org/apache/doris/analysis/ShowRestoreStmt.java | 29 +-
.../java/org/apache/doris/backup/RestoreJob.java | 26 +-
.../java/org/apache/doris/catalog/JdbcTable.java | 72 +++-
.../java/org/apache/doris/catalog/OdbcTable.java | 70 ---
.../doris/catalog/external/HMSExternalTable.java | 25 +-
.../org/apache/doris/common/util/BrokerUtil.java | 9 +-
.../org/apache/doris/common/util/KafkaUtil.java | 8 +-
.../org/apache/doris/datasource/hive/AcidInfo.java | 114 +++++
.../doris/datasource/hive/HiveMetaStoreCache.java | 61 ++-
.../doris/datasource/hive/HiveTransaction.java | 9 +-
.../datasource/hive/PooledHiveMetaStoreClient.java | 167 +++++--
.../apache/doris/load/loadv2/MysqlLoadManager.java | 6 +-
.../glue/translator/PhysicalPlanTranslator.java | 2 +-
.../executable/DateTimeExtractAndTransform.java | 14 +-
.../org/apache/doris/planner/JdbcScanNode.java | 64 ++-
.../org/apache/doris/planner/JdbcTableSink.java | 3 +-
.../org/apache/doris/planner/OdbcScanNode.java | 65 +--
.../org/apache/doris/planner/OdbcTableSink.java | 3 +-
.../doris/planner/external/FileQueryScanNode.java | 32 +-
.../doris/planner/external/FileScanNode.java | 16 +-
.../apache/doris/planner/external/FileSplit.java | 11 +
.../doris/planner/external/HiveScanNode.java | 8 +-
.../apache/doris/planner/external/HiveSplit.java | 69 +++
.../{TableFormatType.java => SplitCreator.java} | 18 +-
.../doris/planner/external/TableFormatType.java | 3 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 7 +-
.../java/org/apache/doris/rewrite/FEFunctions.java | 35 ++
.../hadoop/hive/metastore/HiveMetaStoreClient.java | 25 +-
.../java/org/apache/doris/alter/AlterTest.java | 1 +
.../apache/doris/analysis/ArrayLiteralTest.java | 2 +-
.../doris/analysis/CreateResourceStmtTest.java | 2 +
.../org/apache/doris/catalog/EnvOperationTest.java | 2 +
.../catalog/MultiTableMaterializedViewTest.java | 18 +
.../doris/catalog/OdbcCatalogResourceTest.java | 2 +
.../org/apache/doris/planner/QueryPlanTest.java | 2 +-
.../doris/rewrite/RewriteDateLiteralRuleTest.java | 8 +-
.../apache/doris/utframe/TestWithFeService.java | 1 +
fe/pom.xml | 49 ++-
gensrc/thrift/PlanNodes.thrift | 11 +
.../data/correctness_p0/test_cast_null.out | 13 +
.../hive/test_transactional_hive.out | 33 ++
regression-test/data/github_events_p2/load.out | 3 +
.../nereids_p0/group_concat/test_group_concat.out | 26 +-
.../test_aggregate_all_functions.out | 8 +-
.../nereids_syntax_p0/aggregate_strategies.out | 7 +
.../query_p0/group_concat/test_group_concat.out | 26 +-
.../test_aggregate_all_functions.out | 9 +-
.../test_vertical_compaction_agg_keys.groovy | 3 +-
.../suites/correctness_p0/test_cast_null.groovy | 87 ++++
.../hive/test_transactional_hive.groovy | 61 +++
.../suites/github_events_p2/load.groovy | 2 +
.../mysql_load/test_mysql_load_big_file.groovy | 28 +-
.../mysql_load/test_mysql_load_tiny_file.groovy | 26 +-
.../suites/nereids_p0/update/load.groovy | 3 +
.../nereids_syntax_p0/aggregate_strategies.groovy | 3 +
.../suites/nereids_syntax_p0/group_concat.groovy | 2 +-
run-be-ut.sh | 128 +++++-
samples/stream_load/python/DorisStreamLoad.py | 86 ++++
tools/tpch-tools/bin/run-tpch-queries.sh | 2 +
206 files changed, 4604 insertions(+), 947 deletions(-)
create mode 100644 be/src/io/fs/file_handle_cache.cpp
create mode 100644 be/src/io/fs/file_handle_cache.h
create mode 100644 be/src/io/fs/file_meta_cache.cpp
copy be/src/{util/jni_native_method.h => io/fs/file_meta_cache.h} (52%)
create mode 100644 be/src/util/lru_multi_cache.h
create mode 100644 be/src/util/lru_multi_cache.inline.h
copy be/src/util/{jni_native_method.h => obj_lru_cache.cpp} (54%)
create mode 100644 be/src/util/obj_lru_cache.h
create mode 100644 be/src/vec/exec/format/table/transactional_hive_common.cpp
create mode 100644 be/src/vec/exec/format/table/transactional_hive_common.h
create mode 100644 be/src/vec/exec/format/table/transactional_hive_reader.cpp
create mode 100644 be/src/vec/exec/format/table/transactional_hive_reader.h
create mode 100644 be/test/util/lru_multi_cache_test.cpp
rename fe/{java-udf => be-java-extensions/hudi-scanner}/pom.xml (57%)
rename fe/{java-udf =>
be-java-extensions/hudi-scanner}/src/main/java/org/apache/doris/hudi/HudiColumnValue.java
(98%)
rename fe/{java-udf =>
be-java-extensions/hudi-scanner}/src/main/java/org/apache/doris/hudi/HudiJniScanner.java
(97%)
rename fe/{java-udf =>
be-java-extensions/hudi-scanner}/src/main/java/org/apache/doris/hudi/HudiScanParam.java
(99%)
rename fe/{java-udf =>
be-java-extensions/hudi-scanner}/src/main/java/org/apache/doris/hudi/HudiScanUtils.java
(100%)
rename fe/{java-udf/src/main/java/org/apache/doris/jni/utils =>
be-java-extensions/hudi-scanner/src/main/java/org/apache/doris/hudi}/Utils.java
(99%)
copy fe/{java-udf =>
be-java-extensions/hudi-scanner}/src/main/resources/package.xml (100%)
rename fe/{java-udf =>
be-java-extensions/hudi-scanner}/src/test/java/org/apache/doris/hudi/HudiJniScannerTest.java
(100%)
create mode 100644 fe/be-java-extensions/java-common/pom.xml
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common/exception}/InternalException.java
(95%)
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common/exception}/UdfRuntimeException.java
(95%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/JniScanner.java
(92%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/MockJniScanner.java
(96%)
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils}/JMXJsonUtil.java
(99%)
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils}/JNINativeMethod.java
(96%)
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils}/JniUtil.java
(99%)
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils}/JvmPauseMonitor.java
(99%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/utils/OffHeap.java
(98%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/utils/TypeNativeBytes.java
(99%)
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common/jni/utils}/UdfUtils.java
(99%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/vec/ColumnType.java
(99%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/vec/ColumnValue.java
(97%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/vec/ScanPredicate.java
(97%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/vec/VectorColumn.java
(99%)
rename fe/{java-udf/src/main/java/org/apache/doris =>
be-java-extensions/java-common/src/main/java/org/apache/doris/common}/jni/vec/VectorTable.java
(96%)
rename fe/{java-udf =>
be-java-extensions/java-common}/src/main/resources/log4j.properties (100%)
copy fe/{java-udf =>
be-java-extensions/java-common}/src/main/resources/package.xml (100%)
rename fe/{java-udf/src/test/java/org/apache/doris =>
be-java-extensions/java-common/src/test/java/org/apache/doris/common}/jni/JniScannerTest.java
(94%)
create mode 100644 fe/be-java-extensions/java-udf/pom.xml
rename fe/{ =>
be-java-extensions}/java-udf/src/main/java/org/apache/doris/udf/BaseExecutor.java
(99%)
rename fe/{ =>
be-java-extensions}/java-udf/src/main/java/org/apache/doris/udf/UdafExecutor.java
(98%)
rename fe/{ =>
be-java-extensions}/java-udf/src/main/java/org/apache/doris/udf/UdfExecutor.java
(98%)
copy fe/{ => be-java-extensions}/java-udf/src/main/resources/package.xml (100%)
rename fe/{ =>
be-java-extensions}/java-udf/src/test/java/org/apache/doris/udf/ConstantOneUdf.java
(100%)
rename fe/{ =>
be-java-extensions}/java-udf/src/test/java/org/apache/doris/udf/DateTimeUdf.java
(100%)
rename fe/{ =>
be-java-extensions}/java-udf/src/test/java/org/apache/doris/udf/DecimalUdf.java
(100%)
rename fe/{ =>
be-java-extensions}/java-udf/src/test/java/org/apache/doris/udf/LargeIntUdf.java
(100%)
rename fe/{ =>
be-java-extensions}/java-udf/src/test/java/org/apache/doris/udf/SimpleAddUdf.java
(100%)
rename fe/{ =>
be-java-extensions}/java-udf/src/test/java/org/apache/doris/udf/StringConcatUdf.java
(100%)
rename fe/{ =>
be-java-extensions}/java-udf/src/test/java/org/apache/doris/udf/UdfExecutorTest.java
(99%)
create mode 100644 fe/be-java-extensions/jdbc-scanner/pom.xml
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc}/JdbcDataSource.java
(97%)
rename fe/{java-udf/src/main/java/org/apache/doris/udf =>
be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc}/JdbcExecutor.java
(99%)
copy fe/{java-udf =>
be-java-extensions/jdbc-scanner}/src/main/resources/package.xml (100%)
create mode 100644 fe/be-java-extensions/max-compute-scanner/pom.xml
rename fe/{java-udf/src/main/java/org/apache/doris/jni/vec =>
be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute}/MaxComputeColumnValue.java
(98%)
rename fe/{java-udf/src/main/java/org/apache/doris/jni =>
be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute}/MaxComputeJniScanner.java
(98%)
copy fe/{java-udf =>
be-java-extensions/max-compute-scanner}/src/main/resources/package.xml (100%)
create mode 100644 fe/be-java-extensions/paimon-scanner/pom.xml
rename fe/{java-udf/src/main/java/org/apache/doris/jni/vec =>
be-java-extensions/paimon-scanner/src/main/java/org/apache/doris/paimon}/PaimonColumnValue.java
(97%)
rename fe/{java-udf/src/main/java/org/apache/doris/jni =>
be-java-extensions/paimon-scanner/src/main/java/org/apache/doris/paimon}/PaimonJniScanner.java
(97%)
rename fe/{java-udf =>
be-java-extensions/paimon-scanner}/src/main/resources/package.xml (100%)
create mode 100644 fe/be-java-extensions/pom.xml
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/hive/AcidInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/external/HiveSplit.java
copy
fe/fe-core/src/main/java/org/apache/doris/planner/external/{TableFormatType.java
=> SplitCreator.java} (72%)
create mode 100644 regression-test/data/correctness_p0/test_cast_null.out
create mode 100644
regression-test/data/external_catalog_p0/hive/test_transactional_hive.out
create mode 100644 regression-test/data/github_events_p2/load.out
create mode 100644 regression-test/suites/correctness_p0/test_cast_null.groovy
create mode 100644
regression-test/suites/external_catalog_p0/hive/test_transactional_hive.groovy
create mode 100644 samples/stream_load/python/DorisStreamLoad.py
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
