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