This is an automated email from the ASF dual-hosted git repository.
apurtell pushed a change to branch PHOENIX-7562-feature
in repository https://gitbox.apache.org/repos/asf/phoenix.git
omit 9962c9bedb PHOENIX-7567 Replication Log Writer (Synchronous mode)
(#2144)
omit 16910e063f PHOENIX-7565 Replication log file, and replication log file
writer and reader classes (#2133)
add 9d2d840746 PHOENIX-7358 Upsert select result wrong when use order by
in query (#2148)
add af11be2313 PHOENIX-7600 Replace commons-logging with slf4j (#2165)
add 00d948bbad PHOENIX-7627 Atomic Delete return row fails for
case-sensitive schema and table names (#2171)
add 497fdef69d PHOENIX-7629 :- Invalidate already closed CQSI in case of
URL change for Phoenix HA Connections (#2173)
add 6972a4f8c5 PHOENIX-7631 BSON_VALUE() to support returning binary value
with VARBINARY_ENCODED data type (#2175)
add d381c878ad PHOENIX-7573 (ADDENDUM) Handles upgrade for tables with
alternate default column family (#2179)
add 40c2934a34 PHOENIX-7586 (ADDENDUM) :- Handle Role transitions for
ActiveToStanby role in Failover HAPolicy (#2174)
add 6871cb8a1e PHOENIX-7633 Tuple API to provide serialized bytes size for
the given Tuple (#2183)
add bd2699657a PHOENIX-7481 HBase 3 compatibility changes: Cleanup
deprecated APIs, HTable and HTableDescriptor (#2124)
add 9d79feb20f PHOENIX-7619 Excess HFiles are being read to look for more
than required column versions (#2181)
add b45166dbab PHOENIX-7634 : Change stream name delimiter (#2185)
add d3c5d98c49 PHOENIX-7636 CDC on table with case-sensitive pk columns
fails to read change records (#2186)
add 6de70efc0d PHOENIX-7637 Add jcl-over-slf4j dependency to phoenix-pherf
pom (#2187)
add e3e6a471ac PHOENIX-7639 Improve error handling in
PhoenixMasterObserver (#2191)
add 545b7e7a46 PHOENIX-7630: Return ResultSet for UPSERT with ON DUPLICATE
KEY (#2176)
add be04ae882f PHOENIX-7642 : Add CDC Stream creation datetime to stream
name (#2194)
add b094e82ad0 PHOENIX-7641 Support placeholder for document field keys in
BSON condition expression (#2193)
add 5ac3a5b69c PHOENIX-7643 : Add parent partition start time to
CDC_STREAM table (#2195)
add 90d3e16c68 PHOENIX-7644 : CDC Stream improvements (#2196)
add 4526040e29 PHOENIX-7626: Add metrics to capture HTable thread pool
utilization and contention (#2169)
add 4941aacbad PHOENIX-7646 New PhoenixStatement API to return old row
state in Atomic Updates (#2199)
add d5e33b4433 PHOENIX-7638 Creating a large number of views leads to OS
thread exhaustion (#2190)
add a211350de6 PHOENIX-7647 : BSON_UPDATE_EXPRESSION() set value if field
key does not exist (#2202)
add 03f99d77fc PHOENIX-7645 HighAvailabilityGroup can leak zookeeper
connections (#2200)
new 9c29755851 PHOENIX-7565 Replication log file, and replication log file
writer and reader classes (#2133)
new 73f4a870cb PHOENIX-7567 Replication Log Writer (Synchronous mode)
(#2144)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (9962c9bedb)
\
N -- N -- N refs/heads/PHOENIX-7562-feature (73f4a870cb)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 1 +
bin/performance.py | 9 +-
bin/phoenix_utils.py | 2 +
phoenix-assembly/pom.xml | 4 +
.../build/components/all-common-dependencies.xml | 1 +
phoenix-core-client/pom.xml | 4 +
.../src/main/antlr3/PhoenixBsonExpression.g | 47 +-
.../org/apache/phoenix/compile/DeleteCompiler.java | 9 +-
.../org/apache/phoenix/compile/UpsertCompiler.java | 4 +-
.../MetricsPhoenixCoprocessorSourceFactory.java | 12 +
.../metrics/MetricsPhoenixMasterSource.java | 60 ++
.../metrics/MetricsPhoenixMasterSourceImpl.java | 69 ++
.../org/apache/phoenix/execute/DelegateHTable.java | 107 ----
.../org/apache/phoenix/execute/MutationState.java | 18 +-
.../org/apache/phoenix/execute/TupleProjector.java | 9 +
.../function/BsonConditionExpressionFunction.java | 4 +-
.../expression/function/BsonValueFunction.java | 8 +-
.../util/bson/SQLComparisonExpressionUtils.java | 122 +++-
.../util/bson/UpdateExpressionUtils.java | 21 +-
.../MultiEncodedCQKeyValueComparisonFilter.java | 15 +
.../filter/MultiKeyValueComparisonFilter.java | 14 +
.../phoenix/filter/RowKeyComparisonFilter.java | 5 +
.../phoenix/index/PhoenixIndexBuilderHelper.java | 1 +
.../apache/phoenix/jdbc/HighAvailabilityGroup.java | 19 +-
.../phoenix/jdbc/HighAvailabilityPolicy.java | 65 +-
.../phoenix/jdbc/PhoenixDatabaseMetaData.java | 1 +
.../org/apache/phoenix/jdbc/PhoenixDriver.java | 6 +
.../phoenix/jdbc/PhoenixPrefetchedResultSet.java | 3 +-
.../phoenix/jdbc/PhoenixPreparedStatement.java | 25 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 69 +-
.../job/HTableThreadPoolWithUtilizationStats.java | 142 +++++
.../monitoring/HTableThreadPoolHistograms.java | 176 +++++
.../monitoring/HTableThreadPoolMetricsManager.java | 158 +++++
.../phoenix/monitoring/HistogramDistribution.java | 10 +
.../phoenix/monitoring/PercentileHistogram.java | 162 +++++
.../PercentileHistogramDistribution.java | 101 +++
.../phoenix/monitoring/UtilizationHistogram.java | 62 ++
.../phoenix/query/ConnectionQueryServicesImpl.java | 54 +-
.../org/apache/phoenix/query/QueryConstants.java | 10 +-
.../org/apache/phoenix/query/QueryServices.java | 4 +
.../apache/phoenix/query/QueryServicesOptions.java | 14 +-
.../org/apache/phoenix/schema/MetaDataClient.java | 19 +-
...ueDecoder.java => ParentPartitionNotFound.java} | 20 +-
.../org/apache/phoenix/schema/tuple/BaseTuple.java | 5 +
.../apache/phoenix/schema/tuple/DelegateTuple.java | 5 +
.../phoenix/schema/tuple/MultiKeyValueTuple.java | 12 +
.../tuple/PositionBasedMultiKeyValueTuple.java | 12 +
.../schema/tuple/PositionBasedResultTuple.java | 14 +-
.../apache/phoenix/schema/tuple/ResultTuple.java | 12 +
.../phoenix/schema/tuple/SingleKeyValueTuple.java | 5 +
.../org/apache/phoenix/schema/tuple/Tuple.java | 10 +
.../phoenix/schema/tuple/ValueGetterTuple.java | 11 +
.../phoenix/transaction/OmidTransactionTable.java | 31 +-
.../main/java/org/apache/phoenix/util/CDCUtil.java | 26 +-
.../org/apache/phoenix/util/PhoenixRuntime.java | 50 +-
.../java/org/apache/phoenix/util/TupleUtil.java | 29 +-
.../java/org/apache/phoenix/util/UpgradeUtil.java | 20 +-
.../coprocessor/BaseScannerRegionObserver.java | 3 +-
.../phoenix/coprocessor/MetaDataEndpointImpl.java | 5 +
.../coprocessor/MetaDataRegionObserver.java | 4 +-
.../phoenix/coprocessor/PhoenixMasterObserver.java | 366 +++++++----
.../coprocessor/PhoenixRegionServerEndpoint.java | 7 +
.../tasks/CdcStreamPartitionMetadataTask.java | 5 +-
.../phoenix/hbase/index/IndexRegionObserver.java | 51 +-
.../apache/phoenix/index/PhoenixIndexBuilder.java | 6 +-
.../java/org/apache/phoenix/util/ServerUtil.java | 12 +-
phoenix-core/pom.xml | 18 +
.../phoenix/end2end/AlterTableWithViewsIT.java | 5 +-
.../java/org/apache/phoenix/end2end/Bson2IT.java | 334 ++++++++++
.../java/org/apache/phoenix/end2end/Bson3IT.java | 73 +++
.../java/org/apache/phoenix/end2end/Bson4IT.java | 453 ++++++++++++-
.../java/org/apache/phoenix/end2end/Bson5IT.java | 709 +++++++++++++++++++++
.../java/org/apache/phoenix/end2end/CDCBaseIT.java | 100 ++-
.../apache/phoenix/end2end/CDCDefinitionIT.java | 67 +-
.../org/apache/phoenix/end2end/CDCStream2IT.java | 120 ++++
.../org/apache/phoenix/end2end/CDCStreamIT.java | 177 +++--
.../apache/phoenix/end2end/DynamicUpsertIT.java | 5 +
.../end2end/MetadataServerConnectionsIT.java | 194 +++++-
.../phoenix/end2end/MoveTTLDuringUpgradeIT.java | 22 +-
.../apache/phoenix/end2end/OnDuplicateKey2IT.java | 338 ++++++++--
.../phoenix/end2end/PreStoreScannerOpenIT.java | 260 ++++++++
.../phoenix/end2end/TestPhoenixMasterObserver.java | 74 +++
...T.java => UpsertBindNullParamToCaseExprIT.java} | 4 +-
.../phoenix/end2end/UpsertSelectAutoCommitIT.java | 20 +-
.../org/apache/phoenix/end2end/UpsertSelectIT.java | 64 ++
.../org/apache/phoenix/end2end/UpsertValuesIT.java | 5 +
.../phoenix/end2end/ViewTTLNotEnabledIT.java | 1 -
.../apache/phoenix/end2end/index/BaseIndexIT.java | 3 +-
.../end2end/index/BaseIndexWithRegionMovesIT.java | 3 +-
.../end2end/index/ImmutableIndexExtendedIT.java | 4 +-
.../phoenix/jdbc/FailoverPhoenixConnection2IT.java | 137 ++--
.../HAConnectionWithMasterAndRPCRegistryIT.java | 59 ++
.../phoenix/jdbc/ParallelPhoenixConnectionIT.java | 148 ++++-
.../monitoring/BaseHTableThreadPoolMetricsIT.java | 143 +++++
.../monitoring/CQSIThreadPoolMetricsIT.java | 250 ++++++++
.../ExternalHTableThreadPoolMetricsIT.java | 299 +++++++++
.../org/apache/phoenix/jdbc/PhoenixTestDriver.java | 13 +
.../java/org/apache/phoenix/query/BaseTest.java | 11 +-
.../schema/tuple/TupleKeyValueBytesSizeTest.java | 151 +++++
.../util/bson/ComparisonExpressionUtils2Test.java | 318 +++++++++
.../util/bson/ComparisonExpressionUtilsTest.java | 7 +
.../util/bson/UpdateExpressionUtilsTest.java | 124 +++-
.../phoenix/compat/hbase/CompatDelegateHTable.java | 111 ++++
.../compat/hbase/CompatOmidTransactionTable.java | 13 -
.../phoenix/compat/hbase/CompatDelegateHTable.java | 110 ++++
.../compat/hbase/CompatOmidTransactionTable.java | 13 -
.../phoenix/compat/hbase/CompatDelegateHTable.java | 111 ++++
.../compat/hbase/CompatOmidTransactionTable.java | 13 -
.../phoenix/compat/hbase/CompatDelegateHTable.java | 113 ++++
.../compat/hbase/CompatOmidTransactionTable.java | 13 -
phoenix-mapreduce-byo-shaded-hbase/pom.xml | 5 +
phoenix-pherf/pom.xml | 8 +
phoenix-server/pom.xml | 5 +
pom.xml | 34 +
114 files changed, 6926 insertions(+), 703 deletions(-)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/metrics/MetricsPhoenixMasterSource.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/metrics/MetricsPhoenixMasterSourceImpl.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/job/HTableThreadPoolWithUtilizationStats.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/monitoring/HTableThreadPoolHistograms.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/monitoring/HTableThreadPoolMetricsManager.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/monitoring/PercentileHistogram.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/monitoring/PercentileHistogramDistribution.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/monitoring/UtilizationHistogram.java
copy
phoenix-core-client/src/main/java/org/apache/phoenix/schema/{ColumnValueDecoder.java
=> ParentPartitionNotFound.java} (62%)
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson5IT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/CDCStream2IT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/PreStoreScannerOpenIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/TestPhoenixMasterObserver.java
rename
phoenix-core/src/it/java/org/apache/phoenix/end2end/{TestUpsertBindNullParamToCaseExprIT.java
=> UpsertBindNullParamToCaseExprIT.java} (98%)
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/monitoring/BaseHTableThreadPoolMetricsIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/monitoring/CQSIThreadPoolMetricsIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/monitoring/ExternalHTableThreadPoolMetricsIT.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/schema/tuple/TupleKeyValueBytesSizeTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/util/bson/ComparisonExpressionUtils2Test.java
