This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from 09d46dc6e4c 2.1.0-rc05
new f66f6b2a822 [refactor](close) refactor ispendingfinish logic and close
logic to do close more quickly (#30021)
new 8a75da0fec3 [enhance-wip](multi-catalog) Speed up consume rate of hms
events. (#27666)
new 21db1ecff20 [fix](tablet meta) stale rowset is not loaded while BE
start (#30077)
new caf7790797c [pipelineX](filescan) Support parallel executing for
external table scanning (#30121)
new 7cc85f893c8 [ci](perf) add required (#30155)
new 7180ca707c4 [doc](ranger) update ranger doc #30101
new c8be73934d1 [fix](ci) remove required of performance (#30185)
new ec898f26770 Revert "[ci](perf) add required (#30155)" (#30165)
new ead3b4ac1db [feature](function) support ip function is_ipv4_compat,
is_ipv4_mapped (#29954)
new a9ab0946141 [Bug](fix) try to fix the coredump of streambyte decode of
sse (#30190)
new 1bb1d35f709 [fix](group commit) Fix some group commit case (#30132)
new 332b9cb6199 [opt](nereids) do not change RuntimeFilter Type from
IN-OR_BLOOM to BLOOM on broadcast join (#30148)
new 9dd368f8dcf [config](load) set default
memtable_flush_running_count_limit to 2 (#30146)
new e5f1d8d7ec5 [fix](phrase_prefix) fix match_phrase_prefix query
incorrect result (#29946)
new 4480f751e62 [Improve](Variant) support implicit cast to numeric and
string type (#30029)
new dfde10d4c8a [improvement](function) switch inet(6)_aton alias origin
function (#30196)
new 06f8266ca21 [regression test](schema change) add boolean type check
for agg (#30186)
new ad1c19bd656 [refactor](Nereids): Eager Aggregation unify pushdown agg
function (#30142)
new 9a58cacf0f5 [Improvement](nereids) Make sure to catch and record
exception for every materialization context (#29953)
new d0dd0904586 [fix](routine-load) optimize error msg when meet out of
range (#30118)
new 3e73933857d [fix](routineload) check offset when schedule tasks
(#30136)
new 62a46876b62 [improvement](statistics) Optimize drop stats operation
(#30144)
new 5a7ce5cbf55 [temporary](log) Add temporary log for debug insert into
lost result (#30140)
new cd0ca2b3af0 [docs](ip function) add ipv4/v6 datatype and some ip
functions' docs (#30194)
new e5dea910bf3 [feature](bitwise function)
bit_count/bit_shift_left/bit_shift_right implementation (#30046)
new 24c0900b419 [fix](planner) should return outputTupleDesc's id instead
of tupleIds if outputTupleDesc is set in Plan Node (#30150)
new 5c43708d920 [Fix](Job)Incorrect task query result of insert type
(#30024)
new 8061597f2a0 [fix](Nereids) nullable not adjust in output exprs in
result sink node (#30206)
new 1b1e088e832 [fix](exec_node) crashing caused by cancelled query in
ExecNode (#30192)
new 9b100207d23 [docker](container)create data path after rm residual data
avoiding docker start fail (#30141)
new 45f6cba837d [fix](Nereids) Fixed a bug where the execution plan was
incorrect after ddl (#30107)
new 68e67470c0a [Improvement](doc) add table-buckets doc for flink
connector (#29672)
new d5d0e5e6118 [feature](function) support ip functions named
to_ipv4[or_default, or_null](string) and to_ipv6[or_default, or_null](string)
(#29838)
new 60ce22f15e8 [fix](auto-partition) Fix a concurrent bug (#30086)
new ce47354d598 [fix](Nereids) result nullable of sum distinct in scalar
agg is wrong (#30221)
new 24ed3e41030 [Fix](Expr&code-style) check prepare&open before every
VExpr execute (#26673)
new b3296a2a16c [fix](Nereids) user identify syntax is wrong (#30226)
new 9e0c518aaf4 [Feature](executor)Workload Group support Non-Pipeline
Execution (#30164)
new 9c742d46a23 [fix](group commit) abort txn should use label if replay
wal failed (#30219)
new 32c5153999d [fix](routine-load) pause job when json path is invalid
#30197
new bb6fff3455f [fix](move-memtable) make sure index descriptor is set
when creating delta writer (#30157)
new 510d88f3150 [fix](mtmv)return MTMV with at least one available
partition #30156
new fb2145fe961 [fix](fe) Upgrade mariadb client version from 3.0.4 to
3.0.9 (#30242)
The 43 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/agent/workload_group_listener.cpp | 6 +-
be/src/common/config.cpp | 4 +-
be/src/common/status.h | 2 +
be/src/exec/data_sink.h | 2 +-
be/src/exec/exec_node.cpp | 72 ++--
be/src/exec/exec_node.h | 19 +-
.../inverted_index/query/phrase_prefix_query.cpp | 5 +-
be/src/olap/tablet_meta.cpp | 7 +
be/src/olap/wal/wal_manager.cpp | 10 +-
be/src/olap/wal/wal_table.cpp | 29 +-
be/src/olap/wal/wal_table.h | 2 +-
be/src/pipeline/exec/jdbc_table_sink_operator.h | 1 +
.../exec/multi_cast_data_stream_source.cpp | 8 +-
be/src/pipeline/exec/olap_table_sink_operator.h | 1 +
be/src/pipeline/exec/olap_table_sink_v2_operator.h | 1 +
be/src/pipeline/exec/operator.h | 20 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 2 -
be/src/pipeline/exec/result_file_sink_operator.cpp | 6 +-
be/src/pipeline/exec/result_file_sink_operator.h | 1 +
be/src/pipeline/exec/set_sink_operator.cpp | 16 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 1 -
be/src/pipeline/exec/table_function_operator.cpp | 1 -
be/src/pipeline/pipeline_fragment_context.cpp | 33 +-
be/src/pipeline/pipeline_fragment_context.h | 4 +-
be/src/pipeline/pipeline_x/operator.cpp | 14 +-
be/src/pipeline/pipeline_x/operator.h | 5 +
.../pipeline_x/pipeline_x_fragment_context.cpp | 5 +-
be/src/runtime/fragment_mgr.cpp | 61 ++--
be/src/runtime/group_commit_mgr.cpp | 12 +-
be/src/runtime/query_context.cpp | 25 ++
be/src/runtime/query_context.h | 13 +-
be/src/runtime/result_writer.h | 2 +
be/src/runtime/runtime_state.cpp | 18 -
be/src/runtime/runtime_state.h | 5 -
be/src/runtime/tablets_channel.cpp | 2 +-
be/src/runtime/task_group/task_group_manager.cpp | 57 +++-
be/src/runtime/task_group/task_group_manager.h | 9 +-
.../workload_sched_policy_mgr.cpp | 1 -
be/src/service/point_query_executor.cpp | 10 +-
be/src/vec/columns/column_nullable.cpp | 6 +-
be/src/vec/columns/column_nullable.h | 4 +-
be/src/vec/common/unaligned.h | 33 +-
be/src/vec/core/block.cpp | 3 +-
be/src/vec/data_types/data_type_decimal.cpp | 2 -
be/src/vec/exec/format/json/new_json_reader.cpp | 6 +-
be/src/vec/exec/join/vjoin_node_base.h | 19 +-
be/src/vec/exec/scan/scanner_context.h | 2 +-
be/src/vec/exec/vpartition_sort_node.cpp | 3 -
be/src/vec/exec/vset_operation_node.cpp | 7 +-
be/src/vec/exec/vset_operation_node.h | 7 +-
be/src/vec/exec/vsort_node.cpp | 2 -
be/src/vec/exec/vtable_function_node.cpp | 1 -
be/src/vec/exec/vunion_node.cpp | 25 +-
be/src/vec/exprs/vbitmap_predicate.cpp | 4 +
be/src/vec/exprs/vbloom_predicate.cpp | 4 +
be/src/vec/exprs/vcase_expr.cpp | 9 +-
be/src/vec/exprs/vcast_expr.cpp | 4 +
be/src/vec/exprs/vcolumn_ref.h | 10 +
be/src/vec/exprs/vdirect_in_predicate.h | 19 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 19 +-
be/src/vec/exprs/vexpr.cpp | 62 ++--
be/src/vec/exprs/vexpr.h | 63 ++--
be/src/vec/exprs/vexpr_context.cpp | 28 +-
be/src/vec/exprs/vexpr_context.h | 15 +-
be/src/vec/exprs/vin_predicate.cpp | 4 +
be/src/vec/exprs/vlambda_function_call_expr.h | 12 +-
be/src/vec/exprs/vlambda_function_expr.h | 15 +
be/src/vec/exprs/vliteral.cpp | 19 +-
be/src/vec/exprs/vliteral.h | 5 +
be/src/vec/exprs/vmatch_predicate.cpp | 5 +-
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 15 +-
be/src/vec/exprs/vslot_ref.cpp | 11 +
be/src/vec/exprs/vslot_ref.h | 5 +-
be/src/vec/exprs/vtuple_is_null_predicate.cpp | 9 +
be/src/vec/exprs/vtuple_is_null_predicate.h | 4 +-
be/src/vec/functions/function_bit_count.cpp | 61 ++++
be/src/vec/functions/function_bit_shift.cpp | 90 +++++
be/src/vec/functions/function_ip.cpp | 26 +-
be/src/vec/functions/function_ip.h | 349 ++++++++++++++-----
be/src/vec/functions/simple_function_factory.h | 4 +
be/src/vec/runtime/vdata_stream_recvr.h | 8 +-
be/src/vec/sink/async_writer_sink.h | 23 +-
be/src/vec/sink/vresult_file_sink.cpp | 19 +-
be/src/vec/sink/writer/async_result_writer.cpp | 23 +-
be/src/vec/sink/writer/async_result_writer.h | 7 -
be/src/vec/sink/writer/vjdbc_table_writer.h | 6 +-
be/src/vec/sink/writer/vodbc_table_writer.h | 6 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 83 +++--
be/src/vec/sink/writer/vtablet_writer.h | 12 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 12 +
docker/thirdparties/run-thirdparties-docker.sh | 10 +-
docs/en/docs/ecosystem/flink-doris-connector.md | 4 +-
docs/en/docs/lakehouse/multi-catalog/hive.md | 13 +
.../inet-aton.md => bitwise-functions/bitcount.md} | 43 +--
.../bitwise-functions/bitshfitleft.md | 71 ++++
.../bitwise-functions/bitshfitright.md | 79 +++++
.../sql-functions/ip-functions/inet-aton.md | 20 +-
.../sql-functions/ip-functions/inet6-aton.md | 30 +-
.../ip-functions/ipv4-cidr-to-range.md | 72 ++++
.../ip-functions/ipv6-cidr-to-range.md | 72 ++++
.../ip-functions/is-ip-address-in-range.md | 65 ++++
.../{inet-aton.md => is-ipv4-compat.md} | 44 +--
.../sql-functions/ip-functions/is-ipv4-mapped.md | 69 ++++
.../sql-functions/ip-functions/is-ipv4-string.md | 80 +++++
.../sql-functions/ip-functions/is-ipv6-string.md | 80 +++++
.../{inet-aton.md => to-ipv4-or-default.md} | 38 ++-
.../{inet-aton.md => to-ipv4-or-null.md} | 38 ++-
.../ip-functions/{inet-aton.md => to-ipv4.md} | 33 +-
.../{inet-aton.md => to-ipv6-or-default.md} | 38 ++-
.../{inet-aton.md => to-ipv6-or-null.md} | 38 ++-
.../ip-functions/{inet-aton.md => to-ipv6.md} | 33 +-
.../sql-manual/sql-reference/Data-Types/IPV4.md | 85 +++++
.../sql-manual/sql-reference/Data-Types/IPV6.md | 83 +++++
.../sql-manual/sql-reference/Data-Types/STRUCT.md | 2 +-
docs/sidebars.json | 22 +-
docs/zh-CN/docs/ecosystem/flink-doris-connector.md | 2 +-
docs/zh-CN/docs/lakehouse/multi-catalog/hive.md | 13 +
.../inet-aton.md => bitwise-functions/bitcount.md} | 45 +--
.../bitwise-functions/bitshiftleft.md | 71 ++++
.../bitwise-functions/bitshiftright.md | 78 +++++
.../sql-functions/ip-functions/inet-aton.md | 19 +-
.../sql-functions/ip-functions/inet6-aton.md | 29 +-
.../ip-functions/ipv4-cidr-to-range.md | 72 ++++
.../ip-functions/ipv6-cidr-to-range.md | 72 ++++
.../ip-functions/is-ip-address-in-range.md | 65 ++++
.../{inet-aton.md => is-ipv4-compat.md} | 44 +--
.../sql-functions/ip-functions/is-ipv4-mapped.md | 68 ++++
.../sql-functions/ip-functions/is-ipv4-string.md | 80 +++++
.../sql-functions/ip-functions/is-ipv6-string.md | 80 +++++
.../{inet-aton.md => to-ipv4-or-default.md} | 38 ++-
.../{inet-aton.md => to-ipv4-or-null.md} | 38 ++-
.../ip-functions/{inet-aton.md => to-ipv4.md} | 33 +-
.../{inet-aton.md => to-ipv6-or-default.md} | 38 ++-
.../{inet-aton.md => to-ipv6-or-null.md} | 38 ++-
.../ip-functions/{inet-aton.md => to-ipv6.md} | 33 +-
.../sql-manual/sql-reference/Data-Types/IPV4.md | 85 +++++
.../sql-manual/sql-reference/Data-Types/IPV6.md | 83 +++++
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 2 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 15 +-
.../java/org/apache/doris/alter/SystemHandler.java | 11 +-
.../org/apache/doris/analysis/BinaryPredicate.java | 8 +
.../org/apache/doris/analysis/DropStatsStmt.java | 19 ++
.../org/apache/doris/analysis/MatchPredicate.java | 10 +-
.../apache/doris/analysis/NativeInsertStmt.java | 2 +-
.../doris/catalog/BuiltinScalarFunctions.java | 30 +-
.../main/java/org/apache/doris/catalog/Env.java | 17 +-
.../doris/catalog/external/ExternalDatabase.java | 20 +-
.../catalog/external/HMSExternalDatabase.java | 13 +-
.../catalog/external/IcebergExternalDatabase.java | 4 +-
.../catalog/external/PaimonExternalDatabase.java | 4 +-
.../org/apache/doris/datasource/CatalogMgr.java | 257 ++------------
.../apache/doris/datasource/ExternalCatalog.java | 14 +-
.../apache/doris/datasource/ExternalMetaIdMgr.java | 263 +++++++++++++++
.../doris/datasource/HMSExternalCatalog.java | 107 ++----
.../org/apache/doris/datasource/InitTableLog.java | 67 ----
.../apache/doris/datasource/MetaIdMappingsLog.java | 274 +++++++++++++++
.../datasource/hive/event/AddPartitionEvent.java | 16 +
.../datasource/hive/event/AlterTableEvent.java | 6 +-
.../datasource/hive/event/CreateDatabaseEvent.java | 12 +
.../datasource/hive/event/CreateTableEvent.java | 14 +-
.../datasource/hive/event/DropDatabaseEvent.java | 11 +
.../datasource/hive/event/DropPartitionEvent.java | 17 +-
.../datasource/hive/event/DropTableEvent.java | 15 +-
.../datasource/hive/event/MetastoreEvent.java | 9 +
.../hive/event/MetastoreEventFactory.java | 26 +-
.../hive/event/MetastoreEventsProcessor.java | 225 +++++++++++--
.../doris/httpv2/rest/CheckWalSizeAction.java | 3 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 23 +-
.../org/apache/doris/job/base/AbstractJob.java | 15 +-
.../doris/job/extensions/insert/InsertJob.java | 46 ++-
.../doris/job/extensions/insert/InsertTask.java | 30 +-
.../org/apache/doris/job/manager/JobManager.java | 23 +-
.../apache/doris/job/scheduler/JobScheduler.java | 6 +-
.../org/apache/doris/journal/JournalEntity.java | 20 +-
.../org/apache/doris/load/GroupCommitManager.java | 25 +-
.../load/routineload/KafkaRoutineLoadJob.java | 23 +-
.../doris/load/routineload/KafkaTaskInfo.java | 2 +-
.../doris/load/routineload/RoutineLoadJob.java | 25 +-
.../load/routineload/RoutineLoadTaskInfo.java | 2 +-
.../load/routineload/RoutineLoadTaskScheduler.java | 16 +-
.../main/java/org/apache/doris/mtmv/MTMVCache.java | 4 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 21 +-
.../doris/nereids/analyzer/UnboundResultSink.java | 5 +
.../doris/nereids/analyzer/UnboundTableSink.java | 6 +
.../glue/translator/RuntimeFilterTranslator.java | 6 -
.../processor/post/RuntimeFilterGenerator.java | 2 +-
.../AdjustAggregateNullableForEmptySet.java | 3 +-
.../mv/AbstractMaterializedViewAggregateRule.java | 114 +++----
.../mv/AbstractMaterializedViewJoinRule.java | 17 +-
.../mv/AbstractMaterializedViewRule.java | 372 ++++++++++++---------
.../mv/InitMaterializationContextHook.java | 2 +-
.../mv/MaterializedViewAggregateRule.java | 2 +-
.../nereids/rules/exploration/mv/Predicates.java | 28 +-
.../nereids/rules/exploration/mv/StructInfo.java | 147 +++++---
.../rules/implementation/AggregateStrategies.java | 44 +--
.../LogicalOlapScanToPhysicalOlapScan.java | 10 +-
.../nereids/rules/rewrite/AdjustNullable.java | 8 +
.../nereids/rules/rewrite/NormalizeToSlot.java | 23 +-
.../rules/rewrite/PushDownMinMaxThroughJoin.java | 17 +-
.../rules/rewrite/PushDownSumThroughJoin.java | 4 +-
.../rewrite/PushDownSumThroughJoinOneSide.java | 117 +------
.../org/apache/doris/nereids/trees/TreeNode.java | 17 -
.../trees/expressions/functions/agg/Sum.java | 6 +
.../expressions/functions/scalar/BitCount.java | 67 ++++
.../expressions/functions/scalar/BitShiftLeft.java | 61 ++++
.../functions/scalar/BitShiftRight.java | 63 ++++
.../expressions/functions/scalar/IsIpv4Compat.java | 67 ++++
.../expressions/functions/scalar/IsIpv4Mapped.java | 67 ++++
.../trees/expressions/functions/scalar/ToIpv4.java | 67 ++++
.../functions/scalar/ToIpv4OrDefault.java | 67 ++++
.../expressions/functions/scalar/ToIpv4OrNull.java | 67 ++++
.../trees/expressions/functions/scalar/ToIpv6.java | 67 ++++
.../functions/scalar/ToIpv6OrDefault.java | 67 ++++
.../expressions/functions/scalar/ToIpv6OrNull.java | 67 ++++
.../expressions/visitor/ScalarFunctionVisitor.java | 55 +++
.../logical/LogicalDeferMaterializeResultSink.java | 7 +
.../trees/plans/logical/LogicalFileSink.java | 2 +-
.../trees/plans/logical/LogicalOlapTableSink.java | 5 +
.../trees/plans/logical/LogicalProject.java | 4 +
.../trees/plans/logical/LogicalResultSink.java | 5 +
.../nereids/trees/plans/logical/LogicalSink.java | 2 +
.../trees/plans/physical/AbstractPhysicalJoin.java | 15 +
.../trees/plans/physical/AbstractPhysicalPlan.java | 21 +-
.../trees/plans/physical/RuntimeFilter.java | 4 +
.../apache/doris/nereids/util/ExpressionUtils.java | 4 +-
.../java/org/apache/doris/persist/EditLog.java | 29 +-
.../org/apache/doris/persist/OperationType.java | 9 +
.../apache/doris/planner/GroupCommitPlanner.java | 3 -
.../org/apache/doris/planner/OlapScanNode.java | 5 +
.../java/org/apache/doris/planner/PlanNode.java | 3 +
.../java/org/apache/doris/planner/ScanNode.java | 7 +-
.../doris/planner/external/FileQueryScanNode.java | 12 +
.../main/java/org/apache/doris/qe/Coordinator.java | 3 +
.../java/org/apache/doris/qe/StmtExecutor.java | 2 +-
.../org/apache/doris/rewrite/FunctionAlias.java | 4 +-
.../apache/doris/service/FrontendServiceImpl.java | 36 +-
.../apache/doris/statistics/AnalysisManager.java | 70 +++-
.../doris/statistics/InvalidateStatsTarget.java | 44 ++-
.../apache/doris/statistics/StatisticsCache.java | 17 +-
.../apache/doris/transaction/TransactionState.java | 3 +-
.../doris/datasource/ExternalMetaIdMgrTest.java | 76 +++++
.../doris/datasource/MetaIdMappingsLogTest.java | 97 ++++++
.../external/hms/MetastoreEventFactoryTest.java | 2 +-
fe/pom.xml | 2 +-
gensrc/proto/internal_service.proto | 6 +-
gensrc/script/doris_builtins_functions.py | 43 ++-
gensrc/thrift/FrontendService.thrift | 2 +
gensrc/thrift/PaloInternalService.thrift | 19 +-
gensrc/thrift/Status.thrift | 1 +
.../data/correctness_p0/test_bit_function.out | 132 ++++++++
.../data/correctness_p0/test_bit_shift_lagency.out | 345 +++++++++++++++++++
.../data/correctness_p0/test_bit_shift_nereids.out | 345 +++++++++++++++++++
.../correctness_p0/test_nested_lateral_view.out | 15 +
.../test_index_match_phrase_prefix_1.out} | 13 +-
.../data/nereids_function_p0/ip_functions.out | 68 +++-
.../mv/agg_with_roll_up/aggregate_with_roll_up.out | 6 +
.../data/nereids_syntax_p0/agg_with_empty_set.out | 3 +
.../rf_prune/query64.out | 16 +-
.../nereids_tpcds_shape_sf100_p0/shape/query64.out | 28 +-
.../ip_functions/test_ip_functions.out | 68 +++-
.../ip_functions/test_to_ip_functions.out | 21 ++
.../data/variant_p0/sql/implicit_cast.out | 80 +++++
.../suites/correctness_p0/test_bit_function.groovy | 63 ++++
.../correctness_p0/test_bit_shift_lagency.groovy | 105 ++++++
.../correctness_p0/test_bit_shift_nereids.groovy | 105 ++++++
.../correctness_p0/test_nested_lateral_view.groovy | 55 +++
.../test_index_match_phrase_prefix_1.groovy | 62 ++++
.../suites/job_p0/test_base_insert_job.groovy | 24 +-
.../routine_load/data/invalid_json_path.json | 0
.../routine_load/test_routine_load_error.groovy | 157 +++++++++
.../suites/nereids_function_p0/ip_functions.groovy | 24 ++
.../agg_with_roll_up/aggregate_with_roll_up.groovy | 131 +++++---
.../nereids_syntax_p0/agg_with_empty_set.groovy | 1 +
.../auto_partition/ddl/stress_destination.sql | 20 ++
.../auto_partition/ddl/stress_source.sql | 19 ++
.../doris_dbgen_conf/stress_test_insert_into.yaml} | 8 +-
.../auto_partition/sql/multi_thread_load.groovy | 3 +-
.../sql/stress_test_insert_into.groovy | 118 +++++++
.../ip_functions/test_ip_functions.groovy | 24 ++
.../ip_functions/test_to_ip_functions.groovy | 49 +++
.../schema_change_p0/test_schema_change_agg.groovy | 28 ++
.../suites/variant_p0/sql/implicit_cast.sql | 15 +
282 files changed, 7978 insertions(+), 2209 deletions(-)
create mode 100644 be/src/vec/functions/function_bit_count.cpp
create mode 100644 be/src/vec/functions/function_bit_shift.cpp
copy docs/en/docs/sql-manual/sql-functions/{ip-functions/inet-aton.md =>
bitwise-functions/bitcount.md} (52%)
create mode 100644
docs/en/docs/sql-manual/sql-functions/bitwise-functions/bitshfitleft.md
create mode 100644
docs/en/docs/sql-manual/sql-functions/bitwise-functions/bitshfitright.md
create mode 100644
docs/en/docs/sql-manual/sql-functions/ip-functions/ipv4-cidr-to-range.md
create mode 100644
docs/en/docs/sql-manual/sql-functions/ip-functions/ipv6-cidr-to-range.md
create mode 100644
docs/en/docs/sql-manual/sql-functions/ip-functions/is-ip-address-in-range.md
copy docs/en/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
is-ipv4-compat.md} (53%)
create mode 100644
docs/en/docs/sql-manual/sql-functions/ip-functions/is-ipv4-mapped.md
create mode 100644
docs/en/docs/sql-manual/sql-functions/ip-functions/is-ipv4-string.md
create mode 100644
docs/en/docs/sql-manual/sql-functions/ip-functions/is-ipv6-string.md
copy docs/en/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv4-or-default.md} (54%)
copy docs/en/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv4-or-null.md} (54%)
copy docs/en/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv4.md} (54%)
copy docs/en/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv6-or-default.md} (54%)
copy docs/en/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv6-or-null.md} (54%)
copy docs/en/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv6.md} (54%)
create mode 100644 docs/en/docs/sql-manual/sql-reference/Data-Types/IPV4.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Data-Types/IPV6.md
copy docs/zh-CN/docs/sql-manual/sql-functions/{ip-functions/inet-aton.md =>
bitwise-functions/bitcount.md} (52%)
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/bitwise-functions/bitshiftleft.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/bitwise-functions/bitshiftright.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/ipv4-cidr-to-range.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/ipv6-cidr-to-range.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/is-ip-address-in-range.md
copy docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
is-ipv4-compat.md} (53%)
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/is-ipv4-mapped.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/is-ipv4-string.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/is-ipv6-string.md
copy docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv4-or-default.md} (56%)
copy docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv4-or-null.md} (56%)
copy docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv4.md} (56%)
copy docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv6-or-default.md} (56%)
copy docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv6-or-null.md} (56%)
copy docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/{inet-aton.md =>
to-ipv6.md} (56%)
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Data-Types/IPV4.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Data-Types/IPV6.md
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/ExternalMetaIdMgr.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/InitTableLog.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/MetaIdMappingsLog.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/BitCount.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/BitShiftLeft.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/BitShiftRight.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/IsIpv4Compat.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/IsIpv4Mapped.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToIpv4.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToIpv4OrDefault.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToIpv4OrNull.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToIpv6.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToIpv6OrDefault.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ToIpv6OrNull.java
copy be/src/vec/exprs/vlambda_function_expr.h =>
fe/fe-core/src/main/java/org/apache/doris/statistics/InvalidateStatsTarget.java
(52%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/ExternalMetaIdMgrTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/MetaIdMappingsLogTest.java
create mode 100644
regression-test/data/correctness_p0/test_bit_shift_lagency.out
create mode 100644
regression-test/data/correctness_p0/test_bit_shift_nereids.out
create mode 100644
regression-test/data/correctness_p0/test_nested_lateral_view.out
copy regression-test/data/{correctness_p0/test_bit_function.out =>
inverted_index_p0/test_index_match_phrase_prefix_1.out} (63%)
create mode 100644
regression-test/data/query_p0/sql_functions/ip_functions/test_to_ip_functions.out
create mode 100644 regression-test/data/variant_p0/sql/implicit_cast.out
create mode 100644
regression-test/suites/correctness_p0/test_bit_shift_lagency.groovy
create mode 100644
regression-test/suites/correctness_p0/test_bit_shift_nereids.groovy
create mode 100644
regression-test/suites/correctness_p0/test_nested_lateral_view.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_index_match_phrase_prefix_1.groovy
copy
docker/thirdparties/docker-compose/kafka/scripts/basic_data_json_by_line.json
=> regression-test/suites/load_p0/routine_load/data/invalid_json_path.json
(100%)
create mode 100644
regression-test/suites/partition_p1/auto_partition/ddl/stress_destination.sql
create mode 100644
regression-test/suites/partition_p1/auto_partition/ddl/stress_source.sql
copy regression-test/suites/{correctness_p0/test_bit_function.groovy =>
partition_p1/auto_partition/doris_dbgen_conf/stress_test_insert_into.yaml} (81%)
create mode 100644
regression-test/suites/partition_p1/auto_partition/sql/stress_test_insert_into.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/ip_functions/test_to_ip_functions.groovy
create mode 100644 regression-test/suites/variant_p0/sql/implicit_cast.sql
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]