You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by gj...@apache.org on 2022/08/24 15:02:42 UTC
[phoenix] branch master updated (98fc4c18e2 -> b32e3005df)
This is an automated email from the ASF dual-hosted git repository.
gjacoby pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
from 98fc4c18e2 PHOENIX-6774 Enable code coverage reporting to SonarQube in Phoenix (#1491)
add b32e3005df PHOENIX-6491 Phoenix High Availability (#1430)
No new revisions were added by this update.
Summary of changes:
phoenix-core/pom.xml | 49 +-
.../jdbc/ClusterRoleRecordGeneratorToolIT.java | 130 +++
.../phoenix/jdbc/FailoverPhoenixConnectionIT.java | 862 ++++++++++++++++++++
.../phoenix/jdbc/HighAvailabilityGroupIT.java | 666 ++++++++++++++++
.../phoenix/jdbc/HighAvailabilityGroupTestIT.java | 312 ++++++++
.../jdbc/HighAvailabilityTestingUtility.java | 618 +++++++++++++++
.../jdbc/HighAvailabilityTestingUtilityIT.java | 142 ++++
.../jdbc/ParallelPhoenixConnectionFallbackIT.java | 156 ++++
.../phoenix/jdbc/ParallelPhoenixConnectionIT.java | 527 ++++++++++++
.../jdbc/ParallelPhoenixConnectionWorkflowIT.java | 469 +++++++++++
.../ParallelPhoenixNullComparingResultSetIT.java | 220 ++++++
.../apache/phoenix/jdbc/PhoenixHAAdminToolIT.java | 324 ++++++++
...adeException.java => FailoverSQLException.java} | 18 +-
.../apache/phoenix/exception/SQLExceptionCode.java | 10 +
.../apache/phoenix/exception/SQLExceptionInfo.java | 18 +-
.../org/apache/phoenix/jdbc/ClusterRoleRecord.java | 256 ++++++
.../jdbc/ClusterRoleRecordGeneratorTool.java | 156 ++++
.../phoenix/jdbc/FailoverPhoenixConnection.java | 645 +++++++++++++++
.../org/apache/phoenix/jdbc/FailoverPolicy.java | 145 ++++
.../apache/phoenix/jdbc/HighAvailabilityGroup.java | 879 +++++++++++++++++++++
.../phoenix/jdbc/HighAvailabilityPolicy.java | 142 ++++
.../phoenix/jdbc/ParallelPhoenixConnection.java | 681 ++++++++++++++++
.../phoenix/jdbc/ParallelPhoenixContext.java | 264 +++++++
.../phoenix/jdbc/ParallelPhoenixMetrics.java | 68 ++
.../ParallelPhoenixNullComparingResultSet.java | 333 ++++++++
.../jdbc/ParallelPhoenixPreparedStatement.java | 839 ++++++++++++++++++++
.../phoenix/jdbc/ParallelPhoenixResultSet.java | 155 ++++
.../jdbc/ParallelPhoenixResultSetFactory.java | 80 ++
.../phoenix/jdbc/ParallelPhoenixStatement.java | 592 ++++++++++++++
.../apache/phoenix/jdbc/ParallelPhoenixUtil.java | 322 ++++++++
.../org/apache/phoenix/jdbc/PhoenixConnection.java | 50 +-
.../org/apache/phoenix/jdbc/PhoenixDriver.java | 19 +
.../apache/phoenix/jdbc/PhoenixEmbeddedDriver.java | 74 +-
.../apache/phoenix/jdbc/PhoenixHAAdminTool.java | 634 +++++++++++++++
.../jdbc/PhoenixHAExecutorServiceProvider.java | 361 +++++++++
.../apache/phoenix/jdbc/PhoenixHAGroupMetrics.java | 84 ++
...ementFactory.java => PhoenixMetricsHolder.java} | 11 +-
...icsLog.java => PhoenixMonitoredConnection.java} | 39 +-
...java => PhoenixMonitoredPreparedStatement.java} | 10 +-
...Factory.java => PhoenixMonitoredResultSet.java} | 14 +-
.../PhoenixMonitoredStatement.java} | 23 +-
.../phoenix/jdbc/PhoenixPreparedStatement.java | 2 +-
.../org/apache/phoenix/jdbc/PhoenixResultSet.java | 9 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 3 +-
.../phoenix/monitoring/GlobalClientMetrics.java | 34 +-
.../org/apache/phoenix/monitoring/MetricType.java | 26 +-
.../phoenix/query/ConnectionQueryServices.java | 11 +
.../phoenix/query/ConnectionQueryServicesImpl.java | 23 +-
.../org/apache/phoenix/query/QueryServices.java | 2 +-
.../java/org/apache/phoenix/util/JDBCUtil.java | 21 +-
.../java/org/apache/phoenix/util/JacksonUtil.java | 4 +
.../org/apache/phoenix/util/PhoenixRuntime.java | 47 +-
.../jdbc/ClusterRoleRecordGeneratorToolTest.java | 106 +++
.../apache/phoenix/jdbc/ClusterRoleRecordTest.java | 251 ++++++
.../jdbc/FailoverPhoenixConnectionTest.java | 220 ++++++
.../jdbc/ParallelPhoenixConnectionFailureTest.java | 122 +++
.../jdbc/ParallelPhoenixConnectionTest.java | 411 ++++++++++
.../phoenix/jdbc/ParallelPhoenixContextTest.java | 134 ++++
.../ParallelPhoenixNullComparingResultSetTest.java | 199 +++++
.../jdbc/ParallelPhoenixPreparedStatementTest.java | 118 +++
.../phoenix/jdbc/ParallelPhoenixResultSetTest.java | 283 +++++++
.../phoenix/jdbc/ParallelPhoenixUtilTest.java | 177 +++++
.../phoenix/jdbc/PhoenixHAAdminToolTest.java | 326 ++++++++
.../jdbc/PhoenixHAExecutorServiceProviderTest.java | 132 ++++
.../java/org/apache/phoenix/util/JDBCUtilTest.java | 30 +
pom.xml | 2 +-
66 files changed, 13999 insertions(+), 91 deletions(-)
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/ClusterRoleRecordGeneratorToolIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/FailoverPhoenixConnectionIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/HighAvailabilityGroupIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/HighAvailabilityGroupTestIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/HighAvailabilityTestingUtility.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/HighAvailabilityTestingUtilityIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/ParallelPhoenixConnectionFallbackIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/ParallelPhoenixConnectionIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/ParallelPhoenixConnectionWorkflowIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/ParallelPhoenixNullComparingResultSetIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/jdbc/PhoenixHAAdminToolIT.java
copy phoenix-core/src/main/java/org/apache/phoenix/exception/{RetriableUpgradeException.java => FailoverSQLException.java} (67%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ClusterRoleRecord.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ClusterRoleRecordGeneratorTool.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/FailoverPhoenixConnection.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/FailoverPolicy.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/HighAvailabilityGroup.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/HighAvailabilityPolicy.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixConnection.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixContext.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixMetrics.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixNullComparingResultSet.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixPreparedStatement.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixResultSet.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixResultSetFactory.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixStatement.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/ParallelPhoenixUtil.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixHAAdminTool.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixHAExecutorServiceProvider.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixHAGroupMetrics.java
copy phoenix-core/src/main/java/org/apache/phoenix/jdbc/{PhoenixStatementFactory.java => PhoenixMetricsHolder.java} (76%)
copy phoenix-core/src/main/java/org/apache/phoenix/jdbc/{PhoenixMetricsLog.java => PhoenixMonitoredConnection.java} (51%)
copy phoenix-core/src/main/java/org/apache/phoenix/jdbc/{PhoenixStatementFactory.java => PhoenixMonitoredPreparedStatement.java} (78%)
copy phoenix-core/src/main/java/org/apache/phoenix/jdbc/{PhoenixStatementFactory.java => PhoenixMonitoredResultSet.java} (73%)
copy phoenix-core/src/main/java/org/apache/phoenix/{parse/ListJarsStatement.java => jdbc/PhoenixMonitoredStatement.java} (68%)
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ClusterRoleRecordGeneratorToolTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ClusterRoleRecordTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/FailoverPhoenixConnectionTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixConnectionFailureTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixConnectionTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixContextTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixNullComparingResultSetTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixPreparedStatementTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixResultSetTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixUtilTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/PhoenixHAAdminToolTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/jdbc/PhoenixHAExecutorServiceProviderTest.java