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