You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ji...@apache.org on 2023/11/20 20:30:43 UTC
(phoenix) branch PHOENIX-6978-feature updated (393ab8fe61 -> 710320e3d0)
This is an automated email from the ASF dual-hosted git repository.
jisaac pushed a change to branch PHOENIX-6978-feature
in repository https://gitbox.apache.org/repos/asf/phoenix.git
from 393ab8fe61 Merge branch 'master' into PHOENIX-6978-feature
add 09d2299706 PHOENIX-6523 Support for HBase Registry Implementations through Phoenix connection URL
add 97915cd098 PHOENIX-6523 Support for HBase Registry Implementations through Phoenix connection URL (addendum:use hbase.client.bootstrap.servers for RPCRegistry)
add 17fac6a4d1 PHOENIX-7097 Allow specifying full JDBC URL string in psql/PhoenixRuntime and sqllline.py
add 5d5aaca213 PHOENIX-7038 : Implement Connection Query Service Metrics (#1682)
add 2feb70fc2e PHOENIX-7032 Partial Global Secondary Indexes (#1701)
add 20529a62b8 PHOENIX-7102 phoenix-connectors doesn't compile with core HEAD
add 62ccb3b815 PHOENIX-7067 View indexes should be created only on non overlapping updatable views (#1709)
add b64a9736b7 PHOENIX-7095 Implement Statement.closeOnCompletion() and fix related close() bugs
add 710320e3d0 Merge branch 'master' into PHOENIX-6978-feature-master
No new revisions were added by this update.
Summary of changes:
bin/sqlline.py | 9 +-
.../org/apache/phoenix/end2end/AlterTableIT.java | 75 +-
.../phoenix/end2end/ClientHashAggregateIT.java | 38 +-
.../org/apache/phoenix/end2end/ConnectionIT.java | 156 +++
.../end2end/ConnectionQueryServicesTestImpl.java | 2 +-
.../java/org/apache/phoenix/end2end/InListIT.java | 7 +-
.../phoenix/end2end/MetaDataEndpointImplIT.java | 26 +-
.../apache/phoenix/end2end/PhoenixTTLToolIT.java | 43 +-
.../phoenix/end2end/QueryDatabaseMetaDataIT.java | 50 +
.../end2end/RebuildIndexConnectionPropsIT.java | 4 +-
.../SystemTablesCreationOnConnectionIT.java | 8 +-
.../phoenix/end2end/SystemTablesUpgradeIT.java | 4 +-
.../end2end/ViewExtendsPkRestrictionsIT.java | 1169 ++++++++++++++++++++
.../java/org/apache/phoenix/end2end/ViewTTLIT.java | 75 +-
.../end2end/index/MutableIndexFailureIT.java | 7 +-
.../phoenix/end2end/index/PartialIndexIT.java | 767 +++++++++++++
.../index/UncoveredGlobalIndexRegionScannerIT.java | 9 +-
.../transform/TransformMonitorExtendedIT.java | 19 +
.../phoenix/jdbc/FailoverPhoenixConnectionIT.java | 18 +-
.../phoenix/jdbc/HighAvailabilityGroupIT.java | 2 +-
.../phoenix/jdbc/HighAvailabilityGroupTestIT.java | 8 +-
.../jdbc/HighAvailabilityTestingUtility.java | 10 +-
.../phoenix/jdbc/ParallelPhoenixConnectionIT.java | 2 +
.../phoenix/jdbc/SecureUserConnectionsIT.java | 41 +-
.../monitoring/PhoenixTableLevelMetricsIT.java | 10 +-
.../ConnectionQueryServicesMetricsIT.java | 366 ++++++
.../replication/SystemCatalogWALEntryFilterIT.java | 14 +-
phoenix-core/src/main/antlr3/PhoenixSQL.g | 9 +-
.../phoenix/compile/CreateIndexCompiler.java | 186 +++-
.../phoenix/compile/CreateTableCompiler.java | 61 +
.../phoenix/compile/ServerBuildIndexCompiler.java | 20 +-
.../apache/phoenix/compile/StatementContext.java | 25 +-
.../org/apache/phoenix/compile/WhereCompiler.java | 613 +++++++++-
.../coprocessor/GlobalIndexRegionScanner.java | 69 +-
.../phoenix/coprocessor/MetaDataEndpointImpl.java | 16 +-
.../phoenix/coprocessor/MetaDataProtocol.java | 2 +-
.../coprocessor/UncoveredIndexRegionScanner.java | 15 +-
.../UngroupedAggregateRegionObserver.java | 2 +-
.../apache/phoenix/exception/SQLExceptionCode.java | 9 +-
.../execute/PhoenixTxIndexMutationGenerator.java | 5 +-
.../phoenix/expression/ComparisonExpression.java | 138 ++-
.../org/apache/phoenix/expression/Expression.java | 10 +
.../phoenix/expression/IsNullExpression.java | 16 +-
.../phoenix/hbase/index/IndexRegionObserver.java | 60 +-
.../org/apache/phoenix/index/IndexMaintainer.java | 123 +-
.../phoenix/iterate/RegionScannerFactory.java | 15 +-
.../phoenix/iterate/TableResultIterator.java | 23 +
.../phoenix/jdbc/AbstractRPCConnectionInfo.java | 263 +++++
.../org/apache/phoenix/jdbc/ClusterRoleRecord.java | 1 +
.../org/apache/phoenix/jdbc/ConnectionInfo.java | 545 +++++++++
.../apache/phoenix/jdbc/HighAvailabilityGroup.java | 21 +-
.../apache/phoenix/jdbc/MasterConnectionInfo.java | 103 ++
.../phoenix/jdbc/ParallelPhoenixConnection.java | 8 +-
.../phoenix/jdbc/ParallelPhoenixContext.java | 1 +
.../org/apache/phoenix/jdbc/PhoenixConnection.java | 98 +-
.../phoenix/jdbc/PhoenixDatabaseMetaData.java | 507 +++++----
.../org/apache/phoenix/jdbc/PhoenixDriver.java | 25 +-
.../apache/phoenix/jdbc/PhoenixEmbeddedDriver.java | 568 +---------
.../apache/phoenix/jdbc/PhoenixHAAdminTool.java | 3 +-
.../org/apache/phoenix/jdbc/PhoenixResultSet.java | 7 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 75 +-
.../org/apache/phoenix/jdbc/RPCConnectionInfo.java | 188 ++++
.../org/apache/phoenix/jdbc/ZKConnectionInfo.java | 341 ++++++
.../apache/phoenix/log/BaseConnectionLimiter.java | 15 +-
.../org/apache/phoenix/log/ConnectionLimiter.java | 4 +
.../phoenix/mapreduce/AbstractBulkLoadTool.java | 6 +-
.../phoenix/mapreduce/util/ConnectionUtil.java | 77 +-
.../mapreduce/util/PhoenixConfigurationUtil.java | 48 +-
.../apache/phoenix/monitoring/AtomicMetric.java | 10 +
.../phoenix/monitoring/CombinableMetric.java | 8 +
.../phoenix/monitoring/CombinableMetricImpl.java | 10 +
...ric.java => ConnectionQueryServicesMetric.java} | 16 +-
...java => ConnectionQueryServicesMetricImpl.java} | 25 +-
.../phoenix/monitoring/GlobalMetricImpl.java | 10 +
.../java/org/apache/phoenix/monitoring/Metric.java | 4 +
.../phoenix/monitoring/NoOpGlobalMetricImpl.java | 10 +
.../apache/phoenix/monitoring/NonAtomicMetric.java | 10 +
.../phoenix/monitoring/PhoenixTableMetricImpl.java | 10 +
.../ConnectionQueryServicesHistogram.java} | 34 +-
.../ConnectionQueryServicesMetrics.java | 120 ++
.../ConnectionQueryServicesMetricsHistograms.java | 71 ++
.../ConnectionQueryServicesMetricsManager.java | 343 ++++++
.../NoOpConnectionQueryServicesMetricsManager.java | 62 ++
.../apache/phoenix/optimize/QueryOptimizer.java | 72 +-
.../apache/phoenix/parse/CreateIndexStatement.java | 12 +-
.../org/apache/phoenix/parse/ParseNodeFactory.java | 9 +-
.../phoenix/query/ConnectionQueryServices.java | 1 +
.../phoenix/query/ConnectionQueryServicesImpl.java | 32 +-
.../query/ConnectionlessQueryServicesImpl.java | 7 +-
.../query/DelegateConnectionQueryServices.java | 7 +-
.../phoenix/query/DelegateQueryServices.java | 4 +-
.../org/apache/phoenix/query/QueryConstants.java | 8 +-
.../org/apache/phoenix/query/QueryServices.java | 26 +
.../apache/phoenix/query/QueryServicesOptions.java | 43 +
.../org/apache/phoenix/schema/DelegateTable.java | 25 +-
.../org/apache/phoenix/schema/MetaDataClient.java | 394 ++++---
.../java/org/apache/phoenix/schema/PTable.java | 32 +-
.../java/org/apache/phoenix/schema/PTableImpl.java | 192 ++--
.../java/org/apache/phoenix/trace/TraceReader.java | 1 -
.../apache/phoenix/trace/TraceSpanReceiver.java | 2 -
.../NotAvailableTransactionProvider.java | 2 +-
.../transaction/OmidTransactionProvider.java | 2 +-
.../transaction/PhoenixTransactionProvider.java | 2 +-
.../java/org/apache/phoenix/util/IndexUtil.java | 31 +
.../java/org/apache/phoenix/util/JDBCUtil.java | 49 +-
.../org/apache/phoenix/util/PhoenixRuntime.java | 123 +-
.../java/org/apache/phoenix/util/QueryUtil.java | 46 +-
phoenix-core/src/main/protobuf/PTable.proto | 1 +
.../src/main/protobuf/ServerCachingService.proto | 2 +
.../apache/phoenix/compile/WhereCompilerTest.java | 88 ++
.../phoenix/index/VerifySingleIndexRowTest.java | 2 +-
.../apache/phoenix/jdbc/ClusterRoleRecordTest.java | 4 +-
.../jdbc/ParallelPhoenixConnectionFailureTest.java | 8 +-
.../phoenix/jdbc/PhoenixEmbeddedDriverTest.java | 534 +++++++--
.../apache/phoenix/jdbc/PhoenixStatementTest.java | 38 +
.../org/apache/phoenix/jdbc/PhoenixTestDriver.java | 10 +-
.../mapreduce/PhoenixMultiViewInputFormatTest.java | 5 +
.../util/PhoenixConfigurationUtilTest.java | 24 +-
.../ConnectionQueryServicesHistogramTest.java | 73 ++
...nnectionQueryServicesMetricsHistogramsTest.java | 37 +
.../ConnectionQueryServicesMetricsManagerTest.java | 112 ++
.../ConnectionQueryServicesMetricsTest.java | 106 ++
.../ConnectionQueryServicesNameMetricsTest.java | 87 ++
.../transaction/OmidTransactionService.java | 2 +-
.../transaction/TransactionServiceManager.java | 2 +-
.../java/org/apache/phoenix/util/JDBCUtilTest.java | 8 +-
.../org/apache/phoenix/util/QueryUtilTest.java | 16 +-
127 files changed, 8616 insertions(+), 1668 deletions(-)
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/ConnectionIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/ViewExtendsPkRestrictionsIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/index/PartialIndexIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesMetricsIT.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/AbstractRPCConnectionInfo.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ConnectionInfo.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/MasterConnectionInfo.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/RPCConnectionInfo.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ZKConnectionInfo.java
copy phoenix-core/src/main/java/org/apache/phoenix/monitoring/{PhoenixTableMetric.java => ConnectionQueryServicesMetric.java} (71%)
copy phoenix-core/src/main/java/org/apache/phoenix/monitoring/{PhoenixTableMetricImpl.java => ConnectionQueryServicesMetricImpl.java} (78%)
copy phoenix-core/src/main/java/org/apache/phoenix/monitoring/{SizeHistogram.java => connectionqueryservice/ConnectionQueryServicesHistogram.java} (59%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesMetrics.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesMetricsHistograms.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesMetricsManager.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/monitoring/connectionqueryservice/NoOpConnectionQueryServicesMetricsManager.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesHistogramTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesMetricsHistogramsTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesMetricsManagerTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesMetricsTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/monitoring/connectionqueryservice/ConnectionQueryServicesNameMetricsTest.java