This is an automated email from the ASF dual-hosted git repository. shahrs87 pushed a commit to branch PHOENIX-6883-feature in repository https://gitbox.apache.org/repos/asf/phoenix.git
commit d7fef5c8537ea4690e2a2b01518dd03f24061c24 Merge: 4f8811b456 8a94074c67 Author: Rushabh Shah <[email protected]> AuthorDate: Tue Feb 20 13:09:57 2024 -0800 Merge branch 'master' into PHOENIX-6883-feature bin/hbase-omid-client-config.yml | 5 +- dev/phoenix-personality.sh | 9 +- phoenix-assembly/pom.xml | 55 +- .../src/build/components/all-common-jars.xml | 16 + phoenix-client-parent/phoenix-client-lite/pom.xml | 135 ++ phoenix-client-parent/pom.xml | 2 - phoenix-core-client/pom.xml | 9 +- .../BaseScannerRegionObserverConstants.java | 30 + .../ResultSetOutOfScanRangeException.java | 30 +- .../apache/phoenix/exception/SQLExceptionCode.java | 1 + .../org/apache/phoenix/filter/PagingFilter.java | 24 +- .../phoenix/iterate/BaseResultIterators.java | 5 +- .../phoenix/iterate/OffsetResultIterator.java | 47 +- .../phoenix/iterate/OrderedResultIterator.java | 212 ++- .../phoenix/iterate/ScanningResultIterator.java | 31 + .../ScanningResultPostDummyResultCaller.java | 30 + .../ScanningResultPostValidResultCaller.java | 30 + .../phoenix/iterate/TableResultIterator.java | 36 +- .../phoenix/jdbc/AbstractRPCConnectionInfo.java | 6 +- .../org/apache/phoenix/jdbc/ConnectionInfo.java | 25 +- .../apache/phoenix/jdbc/MasterConnectionInfo.java | 15 +- .../org/apache/phoenix/jdbc/RPCConnectionInfo.java | 17 +- .../org/apache/phoenix/jdbc/ZKConnectionInfo.java | 19 +- .../phoenix/job/AbstractRoundRobinQueue.java | 16 +- .../phoenix/mapreduce/util/ConnectionUtil.java | 89 +- .../util/PhoenixConfigurationUtilHelper.java | 50 +- .../org/apache/phoenix/query/QueryConstants.java | 3 +- .../org/apache/phoenix/query/QueryServices.java | 29 + .../apache/phoenix/query/QueryServicesOptions.java | 31 +- .../phoenix/transaction/OmidTransactionTable.java | 7 +- .../java/org/apache/phoenix/util/ByteUtil.java | 124 ++ .../java/org/apache/phoenix/util/QueryUtil.java | 17 +- .../java/org/apache/phoenix/util/ScanUtil.java | 126 +- .../java/org/apache/phoenix/util/TupleUtil.java | 44 +- .../cache/aggcache/SpillableGroupByCache.java | 66 +- .../coprocessor/BaseScannerRegionObserver.java | 42 +- .../apache/phoenix/coprocessor/GroupByCache.java | 1 + .../GroupedAggregateRegionObserver.java | 501 ++++- .../coprocessor/IndexRebuildRegionScanner.java | 56 +- .../coprocessor/IndexRepairRegionScanner.java | 27 +- .../phoenix/coprocessor/IndexerRegionScanner.java | 31 +- .../phoenix/coprocessor/PagingRegionScanner.java | 35 +- .../coprocessor/UncoveredIndexRegionScanner.java | 76 +- .../UngroupedAggregateRegionObserver.java | 50 +- .../UngroupedAggregateRegionScanner.java | 13 +- .../apache/phoenix/index/GlobalIndexChecker.java | 47 +- .../iterate/NonAggregateRegionScannerFactory.java | 176 +- .../phoenix/mapreduce/PhoenixOutputFormat.java | 5 +- .../phoenix/mapreduce/PhoenixRecordWriter.java | 2 +- .../mapreduce/util/PhoenixConfigurationUtil.java | 26 +- .../java/org/apache/phoenix/util/ServerUtil.java | 16 + phoenix-core/pom.xml | 39 +- .../end2end/AggregateQueryWithRegionMoves2IT.java | 136 ++ .../end2end/AggregateQueryWithRegionMovesIT.java | 279 +++ .../end2end/AggregateWithRegionMoves2IT.java | 124 ++ .../end2end/AggregateWithRegionMovesIT.java | 537 ++++++ .../apache/phoenix/end2end/AppendOnlySchemaIT.java | 27 +- .../phoenix/end2end/BackwardCompatibilityIT.java | 90 + .../end2end/BackwardCompatibilityTestUtil.java | 12 + .../end2end/BaseAggregateWithRegionMoves2IT.java | 633 +++++++ .../end2end/BaseAggregateWithRegionMoves3IT.java | 124 ++ .../end2end/BaseAggregateWithRegionMoves4IT.java | 136 ++ .../end2end/BaseAggregateWithRegionMovesIT.java | 998 ++++++++++ .../end2end/BaseOrderByWithRegionMovesIT.java | 1406 ++++++++++++++ .../end2end/BaseQueryWithRegionMovesIT.java | 165 ++ .../phoenix/end2end/ConfigurableCacheIT.java | 3 +- .../java/org/apache/phoenix/end2end/GroupByIT.java | 51 + .../phoenix/end2end/OrderByWithRegionMovesIT.java | 14 +- .../end2end/OrderByWithServerMemoryLimitIT.java | 13 +- .../ParallelStatsDisabledWithRegionMovesIT.java | 310 +++ .../end2end/ParameterizedIndexUpgradeToolIT.java | 2 +- .../org/apache/phoenix/end2end/QueryTimeoutIT.java | 38 +- .../apache/phoenix/end2end/QueryWithLimitIT.java | 67 +- .../end2end/RebuildIndexConnectionPropsIT.java | 21 +- .../end2end/ScanUncommittedWithRegionMovesIT.java | 551 ++++++ .../org/apache/phoenix/end2end/ServerPagingIT.java | 9 +- .../end2end/ServerPagingWithRegionMovesIT.java | 840 ++++++++ .../org/apache/phoenix/end2end/SortOrderIT.java | 60 +- .../end2end/SortOrderWithRegionMoves2IT.java | 200 ++ .../end2end/SortOrderWithRegionMovesIT.java | 210 ++ .../org/apache/phoenix/end2end/SumFunctionIT.java | 13 +- .../end2end/UncoveredIndexWithRegionMovesIT.java | 391 ++++ .../end2end/UpsertSelectWithRegionMovesIT.java | 1996 ++++++++++++++++++++ .../apache/phoenix/end2end/UpsertWithSCNIT.java | 25 +- .../end2end/index/BaseIndexWithRegionMovesIT.java | 1847 ++++++++++++++++++ ...GlobalImmutableNonTxIndexWithRegionMovesIT.java | 26 +- .../GlobalImmutableTxIndexWithRegionMovesIT.java | 44 + .../index/GlobalIndexCheckerWithRegionMovesIT.java | 1715 +++++++++++++++++ .../GlobalMutableNonTxIndexWithRegionMovesIT.java | 27 +- .../phoenix/end2end/index/PartialIndexIT.java | 56 + .../UncoveredGlobalImmutableNonTxIndex2IT.java | 30 +- .../UncoveredGlobalIndexRegionScanner2IT.java | 1116 +++++++++++ .../end2end/join/SortMergeJoinNoSpoolingIT.java | 5 +- .../end2end/transform/TransformMonitorIT.java | 3 +- .../phoenix/iterate/PhoenixQueryTimeoutIT.java | 116 +- .../phoenix/jdbc/FailoverPhoenixConnection2IT.java | 374 ++++ .../phoenix/jdbc/FailoverPhoenixConnectionIT.java | 231 --- .../phoenix/jdbc/HighAvailabilityGroupTestIT.java | 10 +- .../monitoring/PhoenixMetricsDisabledIT.java | 5 +- .../phoenix/monitoring/PhoenixMetricsIT.java | 23 +- .../ConnectionQueryServicesMetricsIT.java | 6 +- .../rpc/UpdateCacheConnectionLevelPropIT.java | 4 +- .../java/org/apache/phoenix/rpc/UpdateCacheIT.java | 6 +- .../it/resources/compatible_client_versions.json | 2 +- .../it/resources/gold_files/gold_query_offset.txt | 22 +- .../gold_files/gold_query_orderby_nonpk.txt | 29 +- .../gold_files/gold_query_ordered_groupby.txt | 25 +- .../gold_files/gold_query_unorder_groupby.txt | 14 +- .../src/it/resources/sql_files/create_offset.sql | 48 + .../resources/sql_files/create_orderby_nonpk.sql | 48 + .../resources/sql_files/create_ordered_groupby.sql | 48 + .../resources/sql_files/create_unorder_groupby.sql | 44 + .../src/it/resources/sql_files/query_offset.sql | 7 +- .../it/resources/sql_files/query_orderby_nonpk.sql | 7 +- .../resources/sql_files/query_ordered_groupby.sql | 15 +- .../resources/sql_files/query_unorder_groupby.sql | 7 +- .../coprocessor/TaskMetaDataEndpointTest.java | 8 +- .../phoenix/hbase/index/write/TestIndexWriter.java | 2 +- .../hbase/index/write/TestParalleIndexWriter.java | 2 +- .../write/TestParalleWriterIndexCommitter.java | 2 +- .../apache/phoenix/index/IndexUpgradeToolTest.java | 15 +- .../org/apache/phoenix/index/ShouldVerifyTest.java | 8 +- .../phoenix/index/VerifySingleIndexRowTest.java | 22 +- .../phoenix/iterate/OrderedResultIteratorTest.java | 3 + .../jdbc/ClusterRoleRecordGeneratorToolTest.java | 2 +- .../jdbc/FailoverPhoenixConnectionTest.java | 2 +- .../phoenix/jdbc/ParallelPhoenixResultSetTest.java | 2 +- .../phoenix/jdbc/ParallelPhoenixUtilTest.java | 2 +- .../phoenix/jdbc/PhoenixHAAdminToolTest.java | 8 +- .../apache/phoenix/jdbc/PhoenixStatementTest.java | 24 +- .../mapreduce/PhoenixMultiViewInputFormatTest.java | 29 +- .../util/PhoenixConfigurationUtilTest.java | 24 +- .../apache/phoenix/monitoring/MetricUtilTest.java | 2 +- .../java/org/apache/phoenix/query/BaseTest.java | 3 +- .../query/ConnectionQueryServicesImplTest.java | 7 +- .../apache/phoenix/query/ConnectionlessTest.java | 6 +- .../schema/stats/StatisticsScannerTest.java | 12 +- .../phoenix/util/AbstractUpsertExecutorTest.java | 4 +- .../java/org/apache/phoenix/util/LogUtilTest.java | 2 +- .../org/apache/phoenix/util/QueryUtilTest.java | 5 + phoenix-hbase-compat-2.3.0/pom.xml | 113 -- .../compat/hbase/CompatPhoenixRpcScheduler.java | 40 - .../apache/phoenix/compat/hbase/CompatUtil.java | 77 - .../hbase/ReplicationSinkCompatEndpoint.java | 37 - phoenix-hbase-compat-2.4.0/pom.xml | 113 -- .../apache/phoenix/compat/hbase/CompatUtil.java | 80 - .../hbase/ReplicationSinkCompatEndpoint.java | 37 - .../compat/hbase/CompatOmidTransactionTable.java | 12 + .../compat/hbase/CompatOmidTransactionTable.java | 12 + .../compat/hbase/CompatOmidTransactionTable.java | 12 + phoenix-mapreduce-byo-shaded-hbase/pom.xml | 613 ++++++ phoenix-pherf/pom.xml | 7 - .../org/apache/phoenix/pherf/ResourceTest.java | 16 +- phoenix-server/pom.xml | 673 ++++--- phoenix-tracing-webapp/pom.xml | 2 +- pom.xml | 273 ++- 156 files changed, 18560 insertions(+), 1728 deletions(-)
