This is an automated email from the ASF dual-hosted git repository.
tkhurana pushed a change to branch PHOENIX-7562-feature-new
in repository https://gitbox.apache.org/repos/asf/phoenix.git
from 4a08b1d10d PHOENIX-7862 addendum Fix the race which caused double
rotation
add 6230eb024d PHOENIX-7748 Empty column cell is not returned when scan
has both EmptyColumnOnlyFilter and DistinctPrefixFilter (#2353)
add 27d6b1b251 PHOENIX-7474 Migrate IndexTool tables and make sure they
are created (#2031)
add 1115c7c306 PHOENIX-300 Add support for TRUNCATE TABLE (#1409)
add 137cca5734 spotless fix
add 5ed966711c PHOENIX-7757 : Support arithmetic with if_not_exists in
bson SET update expression (#2362)
add ba340dd31c PHOENIX-7474 addendum (#2363)
add aa44ae6dcb PHOENIX-7743 : Fix TNFE in IndexTool server side builds for
case sensitive names (#2331)
add 3050049d30 PHOENIX-7753 : Allow uncovered index creation on tables
with relaxed conditional TTL (#2357)
add 5cd2b7487a PHOENIX-7729: Identify top N slowest parallel scans for
metrics reporting (#2337)
add 8a9b299b2b PHOENIX-7760 Incorrect scan range for RVC with overlapping
constraints (#2367)
add 9006fafce5 PHOENIX-7198 support for multi row constructors in single
upsert query (#2222)
add 7d8cfe9714 PHOENIX-7759: Preserve buffered mutations when batch size
limit is exceeded (#2371)
add 57b1f9f498 PHOENIX-7762 Incorrect scan boundary when slot span exceeds
actual bound in composite key (#2373)
add a7feb02eac spotless fix
add 9aa67a74b0 PHOENIX-7770 Incorrect index scan range while using RVC on
VARBINARY_ENCODED (#2380)
add d06e17e2da PHOENIX-7772 : Fix NPE in TOTAL_SEGMENTS query when table
has index (#2382)
add fe50526f33 PHOENIX-7758 Read repair with DistinctPrefixFilter can give
incorrect results (#2365)
add 4583671b9c PHOENIX-7774 : Increase default number of max indexes
allowed per table (#2385)
add 4455038df7 PHOENIX-7777 : Disable default configuration for View TTL
(#2387)
add 6a0149a8ed PHOENIX-7766: Generate point lookups while using IS NULL on
trailing PK columns (#2377)
add 42dc7dba7f PHOENIX-7789: Fix Flappers in SlowestScanMetricsIT (#2396)
add f088fdeb28 PHOENIX-7797 Fixing flapper test
HAGroupStoreClientIT.testHAGroupStoreClientWithMultiThreadedUpdates (#2402)
add f5f093e53b PHOENIX-7751: Feature to validate table data using
PhoenixSyncTable tool b/w source and target cluster (#2379)
add 606b261e50 PHOENIX-7729 Identify top N slowest parallel scans for
metrics reporting (Addendum) (#2408)
add 4398bc0583 PHOENIX-7794 Eventually Consistent Global Secondary Indexes
(#2401)
add 5d14dec569 PHOENIX-7276 Add REGEXP_LIKE built-in function (#2398)
add 8f5daf5acb PHOENIX-7806 Upgrade hbase versions to 2.5.14 and 2.6.5
(#2420)
add c46000aa7c PHOENIX-7806 Fix permission tests (ADDENDUM) (#2424)
add 391c1d2261 PHOENIX-7811 : Create CDC should not drop user supplied
table properties (#2426)
add 078e29ae3e PHOENIX-7799 Coalesce splits by region server to avoid
hotspotting from concurrent mappers (#2411)
add 4e8472ce9b PHOENIX-7841 Harden the phoenix-vote script (#2458)
add e8f1ba2ee0 PHOENIX-7844: Add Pull Request template with guidelines for
generative AI tools (#2462)
add 2019178b87 PHOENIX-7849 : Support LIST_APPEND operator in BSON
UpdateExpression SET (#2468)
add 78d91e074b PHOENIX-7850: Unblock Phoenix PR validation builds (#2471)
add ae0e932df5 PHOENIX-7850 addendum (#2472)
add 19422a0147 PHOENIX-7848: Use ZK TLS properties from HBase config if
present (#2467)
add 225cf0e51f PHOENIX-7842 Reduce the shading contribution to build time
(#2460)
add 29fbbbcef0 PHOENIX-7879 Tests for EXPLAIN text and
ExplainPlanAttributes serialization compatibility (#2495)
new 8f9655a69e Merge remote-tracking branch 'upstream/master' into
PHOENIX-7562-feature-new
The 1 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:
.github/PULL_REQUEST_TEMPLATE | 54 +
BUILDING.md | 33 +
Jenkinsfile | 2 +-
Jenkinsfile.github | 10 +-
Jenkinsfile.yetus | 2 +-
bin/phoenix_utils.py | 26 +
bin/sqlline.py | 1 +
dev/phoenix-vote.sh | 72 +-
docs/phoenix.csv | 16 +
phoenix-assembly/pom.xml | 78 +-
.../src/build/components/all-common-jars.xml | 10 +-
...l-common-dependencies.xml => assembly-noop.xml} | 31 +-
...mmon-dependencies.xml => release-only-jars.xml} | 32 +-
phoenix-assembly/src/build/package-to-tar-all.xml | 3 +
phoenix-core-client/pom.xml | 4 +
phoenix-core-client/src/main/antlr3/PhoenixSQL.g | 38 +-
.../phoenix/compile/ExplainPlanAttributes.java | 13 +
.../org/apache/phoenix/compile/JoinCompiler.java | 3 +-
.../apache/phoenix/compile/RVCOffsetCompiler.java | 23 +-
.../compile/RegionLocationsListSerializer.java | 61 +
.../org/apache/phoenix/compile/ScanRanges.java | 35 +-
.../compile/ServerMergeColumnsSerializer.java | 59 +
.../apache/phoenix/compile/StatementContext.java | 83 +
.../org/apache/phoenix/compile/UpsertCompiler.java | 334 +--
.../org/apache/phoenix/compile/WhereOptimizer.java | 26 +-
.../BaseScannerRegionObserverConstants.java | 29 +
.../coprocessorclient/MetaDataProtocol.java | 4 +-
.../apache/phoenix/exception/SQLExceptionCode.java | 10 +
.../org/apache/phoenix/execute/MutationState.java | 124 +-
.../apache/phoenix/execute/SegmentInfoPlan.java | 7 +
.../apache/phoenix/expression/ExpressionType.java | 5 +-
...ction.java => ByteBasedRegexpLikeFunction.java} | 24 +-
.../expression/function/RegexpLikeFunction.java | 244 ++
...ion.java => StringBasedRegexpLikeFunction.java} | 14 +-
.../util/bson/UpdateExpressionUtils.java | 138 +-
.../phoenix/filter/DistinctPrefixFilter.java | 42 +
.../metrics/MetricsIndexCDCConsumerSource.java | 103 +
.../metrics/MetricsIndexCDCConsumerSourceImpl.java | 120 +
.../index/metrics/MetricsIndexerSourceFactory.java | 8 +
.../org/apache/phoenix/index/IndexMaintainer.java | 17 +
.../phoenix/iterate/BaseResultIterators.java | 9 +-
.../apache/phoenix/iterate/ParallelIterators.java | 7 +-
.../phoenix/iterate/ScanningResultIterator.java | 111 +-
.../apache/phoenix/iterate/SerialIterators.java | 3 +-
.../phoenix/iterate/UnionResultIterators.java | 4 +-
.../phoenix/jdbc/MutationLimitBatchException.java | 50 +
.../ParallelPhoenixNullComparingResultSet.java | 8 +
.../phoenix/jdbc/ParallelPhoenixResultSet.java | 8 +
.../org/apache/phoenix/jdbc/PhoenixConnection.java | 17 +
.../phoenix/jdbc/PhoenixDatabaseMetaData.java | 12 +
.../phoenix/jdbc/PhoenixMonitoredResultSet.java | 5 +
.../org/apache/phoenix/jdbc/PhoenixResultSet.java | 7 +
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 85 +-
.../mapreduce/index/IndexToolTableUtil.java | 165 ++
.../phoenix/monitoring/GlobalClientMetrics.java | 25 +
.../org/apache/phoenix/monitoring/MetricType.java | 91 +-
.../phoenix/monitoring/OverAllQueryMetrics.java | 14 +-
.../apache/phoenix/monitoring/ReadMetricQueue.java | 15 +-
.../phoenix/monitoring/ScanMetricsHolder.java | 181 +-
.../monitoring/SlowestScanMetricsQueue.java | 81 +
.../phoenix/monitoring/TopNTreeMultiMap.java | 196 ++
.../apache/phoenix/parse/AlterIndexStatement.java | 15 +-
.../apache/phoenix/parse/CreateIndexStatement.java | 34 +
.../org/apache/phoenix/parse/ParseNodeFactory.java | 24 +-
...plitParseNode.java => RegexpLikeParseNode.java} | 18 +-
...eStatement.java => TruncateTableStatement.java} | 45 +-
.../org/apache/phoenix/parse/UpsertStatement.java | 6 +-
.../phoenix/query/ConnectionQueryServices.java | 9 +-
.../phoenix/query/ConnectionQueryServicesImpl.java | 68 +-
.../query/ConnectionlessQueryServicesImpl.java | 13 +
.../query/DelegateConnectionQueryServices.java | 6 +
.../org/apache/phoenix/query/QueryConstants.java | 27 +-
.../org/apache/phoenix/query/QueryServices.java | 13 +
.../apache/phoenix/query/QueryServicesOptions.java | 13 +-
.../phoenix/schema/ConditionalTTLExpression.java | 12 +-
.../org/apache/phoenix/schema/DelegateTable.java | 6 +
.../phoenix/schema/LiteralTTLExpression.java | 2 +-
.../org/apache/phoenix/schema/MetaDataClient.java | 273 +-
...ion.java => MutationLimitReachedException.java} | 15 +-
.../java/org/apache/phoenix/schema/PTable.java | 13 +
.../java/org/apache/phoenix/schema/PTableImpl.java | 28 +-
.../org/apache/phoenix/schema/TTLExpression.java | 8 +-
.../apache/phoenix/schema/tool/SchemaSQLUtil.java | 7 +
.../phoenix/schema/transform/TransformClient.java | 7 +-
.../phoenix/schema/types/IndexConsistency.java | 109 +
.../org/apache/phoenix/util/CDCChangeBuilder.java | 86 +-
.../main/java/org/apache/phoenix/util/CDCUtil.java | 29 +
.../java/org/apache/phoenix/util/JDBCUtil.java | 48 +-
.../java/org/apache/phoenix/util/MetaDataUtil.java | 3 +-
.../apache/phoenix/util/PhoenixKeyValueUtil.java | 15 -
.../org/apache/phoenix/util/PhoenixRuntime.java | 25 +
.../org/apache/phoenix/util/SHA256DigestUtil.java | 77 +
.../java/org/apache/phoenix/util/ScanUtil.java | 96 +-
.../{CDCInfo.proto => IndexMutations.proto} | 26 +-
phoenix-core-client/src/main/protobuf/PTable.proto | 1 +
.../src/main/protobuf/ServerCachingService.proto | 1 +
phoenix-core-server/pom.xml | 8 +
.../coprocessor/CDCGlobalIndexRegionScanner.java | 294 ++-
.../phoenix/coprocessor/DataTableScanMetrics.java | 5 +-
.../phoenix/coprocessor/MetaDataEndpointImpl.java | 68 +-
.../coprocessor/PhoenixSyncTableRegionScanner.java | 350 +++
.../UncoveredGlobalIndexRegionScanner.java | 4 +-
.../coprocessor/UncoveredIndexRegionScanner.java | 38 +-
.../UncoveredLocalIndexRegionScanner.java | 4 +-
.../UngroupedAggregateRegionObserver.java | 9 +
.../phoenix/hbase/index/IndexCDCConsumer.java | 1347 ++++++++++
.../phoenix/hbase/index/IndexRegionObserver.java | 427 ++-
.../TrackingParallelWriterIndexCommitter.java | 7 +-
.../apache/phoenix/index/GlobalIndexChecker.java | 23 +-
.../phoenix/iterate/RegionScannerFactory.java | 22 +-
.../phoenix/mapreduce/PhoenixInputSplit.java | 49 +-
.../mapreduce/PhoenixNoOpSingleRecordReader.java | 114 +
.../PhoenixServerBuildIndexInputFormat.java | 16 +-
.../PhoenixSyncTableCheckpointOutputRow.java | 318 +++
.../mapreduce/PhoenixSyncTableInputFormat.java | 345 +++
.../phoenix/mapreduce/PhoenixSyncTableMapper.java | 782 ++++++
.../PhoenixSyncTableOutputRepository.java | 244 ++
.../phoenix/mapreduce/PhoenixSyncTableTool.java | 614 +++++
.../apache/phoenix/mapreduce/index/IndexTool.java | 34 +-
.../index/IndexVerificationOutputRepository.java | 42 +-
.../index/IndexVerificationResultRepository.java | 50 +-
.../phoenix/mapreduce/transform/TransformTool.java | 8 +-
.../mapreduce/util/PhoenixConfigurationUtil.java | 5 +
.../mapreduce/util/PhoenixMapReduceUtil.java | 55 +
phoenix-core/pom.xml | 5 +
.../phoenix/end2end/AsyncIndexPermissionIT.java | 355 +++
.../phoenix/end2end/BackwardCompatibilityIT.java | 9 +
.../end2end/BackwardCompatibilityTestUtil.java | 3 +
.../apache/phoenix/end2end/BasePermissionsIT.java | 20 +-
.../end2end/BaseTotalSegmentsFunctionIT.java | 17 +-
.../java/org/apache/phoenix/end2end/Bson2IT.java | 101 +
.../java/org/apache/phoenix/end2end/Bson4IT.java | 11 +
.../java/org/apache/phoenix/end2end/Bson5IT.java | 108 +-
.../apache/phoenix/end2end/CDCDefinitionIT.java | 115 +
...ncurrentMutationsCoveredEventualGenerateIT.java | 73 +
...a => ConcurrentMutationsCoveredEventualIT.java} | 16 +-
...> ConcurrentMutationsCoveredNonEventualIT.java} | 16 +-
... => ConcurrentMutationsExtendedGenerateIT.java} | 36 +-
.../end2end/ConcurrentMutationsExtendedIT.java | 114 +-
.../ConcurrentMutationsExtendedIndexIT.java | 438 ++++
.../ConcurrentMutationsLazyPostBatchWriteIT.java | 18 +-
...urrentMutationsUncoveredEventualGenerateIT.java | 73 +
...=> ConcurrentMutationsUncoveredEventualIT.java} | 16 +-
...ConcurrentMutationsUncoveredNonEventualIT.java} | 16 +-
.../org/apache/phoenix/end2end/EmptyColumnIT.java | 57 +
.../end2end/IndexMaintainerConsistencyIT.java | 237 ++
.../end2end/IndexRepairRegionScannerIT.java | 21 +-
...xToolForNonTxGlobalIndexEventualGenerateIT.java | 93 +
.../IndexToolForNonTxGlobalIndexEventualIT.java | 93 +
.../end2end/IndexToolForNonTxGlobalIndexIT.java | 75 +-
.../org/apache/phoenix/end2end/IndexToolIT.java | 166 +-
.../end2end/LoadSystemTableSnapshotBase.java | 36 +-
.../end2end/MetadataServerConnectionsIT.java | 2 +
.../MigrateSystemTablesToSystemNamespaceIT.java | 28 +-
...ava => MultiTenantEventualIndexGenerateIT.java} | 33 +-
.../end2end/MultiTenantEventualIndexIT.java | 626 +++++
.../apache/phoenix/end2end/MultipleUpsertIT.java | 123 +
.../apache/phoenix/end2end/MutationStateIT.java | 526 ++++
.../ParallelStatsDisabledWithRegionMovesIT.java | 2 +
.../phoenix/end2end/PhoenixSyncTableToolIT.java | 2761 ++++++++++++++++++++
.../phoenix/end2end/QueryDatabaseMetaDataIT.java | 5 +
.../phoenix/end2end/RegexpLikeFunctionIT.java | 452 ++++
.../phoenix/end2end/RowValueConstructorIT.java | 863 ++++++
.../org/apache/phoenix/end2end/ServerPagingIT.java | 10 +-
.../end2end/ServerPagingWithRegionMovesIT.java | 31 +-
.../org/apache/phoenix/end2end/SetPropertyIT.java | 44 +
.../end2end/SkipSystemTablesExistenceCheckIT.java | 3 +-
.../SystemTablesCreationOnConnectionIT.java | 10 +-
.../apache/phoenix/end2end/TTLAsPhoenixTTLIT.java | 19 +-
.../it/java/org/apache/phoenix/end2end/TTLIT.java | 18 +-
.../phoenix/end2end/TenantSpecificTablesDDLIT.java | 3 +
.../apache/phoenix/end2end/TruncateTableIT.java | 534 ++++
.../phoenix/end2end/UCFWithServerMetadataIT.java | 2 +
.../phoenix/end2end/UpgradeIndexToolTablesIT.java | 97 +
...IndexToolTablesNameSpaceMappingDisabledIT.java} | 11 +-
.../org/apache/phoenix/end2end/UpsertSelectIT.java | 2 +
.../end2end/UpsertSelectWithRegionMovesIT.java | 2 +
.../phoenix/end2end/VarBinaryEncoded2IT.java | 97 +-
.../end2end/WhereOptimizerForArrayAnyIT.java | 36 +-
.../end2end/WhereOptimizerForArrayAnyITBase.java | 83 +
.../WhereOptimizerForArrayAnyNullablePKIT.java | 1160 ++++++++
.../GlobalIndexCheckerEventualGenerateIT.java | 89 +
.../index/GlobalIndexCheckerEventualIT.java | 89 +
.../end2end/index/GlobalIndexCheckerIT.java | 252 +-
.../index/GlobalIndexCheckerWithRegionMovesIT.java | 2 +
.../end2end/index/IndexAsyncThresholdIT.java | 2 +
.../index/IndexVerificationOutputRepositoryIT.java | 13 +-
.../index/IndexVerificationResultRepositoryIT.java | 17 +-
.../end2end/index/PartialSystemCatalogIndexIT.java | 4 +-
.../index/ReplicationWithWALAnnotationIT.java | 3 +
.../UncoveredGlobalIndexRegionScanner2IT.java | 2 +
.../phoenix/jdbc/FailoverPhoenixConnection2IT.java | 4 +
.../phoenix/jdbc/FailoverPhoenixConnectionIT.java | 5 +
.../jdbc/HighAvailabilityTestingUtilityIT.java | 5 +
.../jdbc/ParallelPhoenixConnectionFallbackIT.java | 5 +
.../phoenix/jdbc/ParallelPhoenixConnectionIT.java | 78 +
.../ParallelPhoenixNullComparingResultSetIT.java | 5 +
.../phoenix/monitoring/BasePhoenixMetricsIT.java | 2 +
.../monitoring/PhoenixTableLevelMetricsIT.java | 3 +
.../phoenix/monitoring/SlowestScanMetricsIT.java | 955 +++++++
.../ConnectionQueryServicesMetricsIT.java | 4 +
.../phoenix/query/MaxConcurrentConnectionsIT.java | 2 +
.../apache/phoenix/query/MetaDataCachingIT.java | 2 +
...uery_add_delete.txt => gold_query_distinct.txt} | 13 +-
.../indexToolsnapshot.tar.gz | Bin 0 -> 20480 bytes
.../src/it/resources/sql_files/create_distinct.sql | 36 +
.../{query_offset.sql => query_distinct.sql} | 2 +-
.../apache/phoenix/compile/QueryCompilerTest.java | 189 ++
.../phoenix/compile/SlowestScanMetricsTest.java | 406 +++
.../apache/phoenix/compile/WhereOptimizerTest.java | 36 +-
.../PhoenixSyncTableRegionScannerTest.java | 535 ++++
.../function/RegexpLikeFunctionTest.java | 241 ++
.../org/apache/phoenix/index/IndexToolTest.java | 2 +-
.../phoenix/mapreduce/PhoenixInputSplitTest.java | 200 ++
.../PhoenixNoOpSingleRecordReaderTest.java | 72 +
.../mapreduce/PhoenixSyncTableInputFormatTest.java | 587 +++++
.../mapreduce/PhoenixSyncTableMapperTest.java | 512 ++++
.../PhoenixSyncTableOutputRepositoryTest.java | 848 ++++++
.../mapreduce/PhoenixSyncTableToolTest.java | 593 +++++
.../mapreduce/util/SHA256DigestUtilTest.java | 277 ++
.../phoenix/parse/IndexConsistencyParseTest.java | 87 +
.../org/apache/phoenix/parse/QueryParserTest.java | 36 +
.../java/org/apache/phoenix/query/BaseTest.java | 2 +-
.../phoenix/query/explain/ExplainChangeRule.java | 54 +
.../query/explain/ExplainCompatibilityTest.java | 769 ++++++
.../query/explain/ExplainJsonNormalizer.java | 71 +
.../phoenix/query/explain/ExplainOracle.java | 207 ++
.../query/explain/ExplainTextNormalizer.java | 68 +
.../schema/ConditionalTTLExpressionTest.java | 97 +-
.../org/apache/phoenix/util/IndexScrutiny.java | 18 +-
.../java/org/apache/phoenix/util/TestUtil.java | 94 +
.../util/bson/UpdateExpressionUtilsTest.java | 446 ++++
.../phoenix/compat/hbase/CompatScanMetrics.java | 67 +-
.../phoenix/compat/hbase/CompatScanMetrics.java | 67 +-
.../phoenix/compat/hbase/CompatScanMetrics.java | 67 +-
phoenix-hbase-compat-2.6.4/pom.xml | 2 +-
.../phoenix/compat/hbase/CompatScanMetrics.java | 109 +-
pom.xml | 36 +-
238 files changed, 26404 insertions(+), 1398 deletions(-)
create mode 100644 .github/PULL_REQUEST_TEMPLATE
copy phoenix-assembly/src/build/components/{all-common-dependencies.xml =>
assembly-noop.xml} (53%)
copy phoenix-assembly/src/build/components/{all-common-dependencies.xml =>
release-only-jars.xml} (54%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/compile/RegionLocationsListSerializer.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/compile/ServerMergeColumnsSerializer.java
copy
phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/{ByteBasedRegexpReplaceFunction.java
=> ByteBasedRegexpLikeFunction.java} (70%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/RegexpLikeFunction.java
copy
phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/{StringBasedRegexpReplaceFunction.java
=> StringBasedRegexpLikeFunction.java} (79%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/hbase/index/metrics/MetricsIndexCDCConsumerSource.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/hbase/index/metrics/MetricsIndexCDCConsumerSourceImpl.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/jdbc/MutationLimitBatchException.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/mapreduce/index/IndexToolTableUtil.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/monitoring/SlowestScanMetricsQueue.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/monitoring/TopNTreeMultiMap.java
copy
phoenix-core-client/src/main/java/org/apache/phoenix/parse/{RegexpSplitParseNode.java
=> RegexpLikeParseNode.java} (71%)
copy
phoenix-core-client/src/main/java/org/apache/phoenix/parse/{DropTableStatement.java
=> TruncateTableStatement.java} (58%)
copy
phoenix-core-client/src/main/java/org/apache/phoenix/schema/{RowValueConstructorOffsetNotCoercibleException.java
=> MutationLimitReachedException.java} (65%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/schema/types/IndexConsistency.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/util/SHA256DigestUtil.java
copy phoenix-core-client/src/main/protobuf/{CDCInfo.proto =>
IndexMutations.proto} (61%)
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixSyncTableRegionScanner.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexCDCConsumer.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixNoOpSingleRecordReader.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixSyncTableCheckpointOutputRow.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixSyncTableInputFormat.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixSyncTableMapper.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixSyncTableOutputRepository.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixSyncTableTool.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/AsyncIndexPermissionIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsCoveredEventualGenerateIT.java
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/{SetPropertyOnEncodedTableIT.java
=> ConcurrentMutationsCoveredEventualIT.java} (68%)
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/{SetPropertyOnEncodedTableIT.java
=> ConcurrentMutationsCoveredNonEventualIT.java} (68%)
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/{ConcurrentMutationsLazyPostBatchWriteIT.java
=> ConcurrentMutationsExtendedGenerateIT.java} (54%)
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIndexIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsUncoveredEventualGenerateIT.java
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/{SetPropertyOnEncodedTableIT.java
=> ConcurrentMutationsUncoveredEventualIT.java} (68%)
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/{SetPropertyOnEncodedTableIT.java
=> ConcurrentMutationsUncoveredNonEventualIT.java} (68%)
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexMaintainerConsistencyIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolForNonTxGlobalIndexEventualGenerateIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolForNonTxGlobalIndexEventualIT.java
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/{ConcurrentMutationsLazyPostBatchWriteIT.java
=> MultiTenantEventualIndexGenerateIT.java} (56%)
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/MultiTenantEventualIndexIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/MultipleUpsertIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/PhoenixSyncTableToolIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/RegexpLikeFunctionIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/TruncateTableIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/UpgradeIndexToolTablesIT.java
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/{OrderByWithRegionMovesIT.java
=> UpgradeIndexToolTablesNameSpaceMappingDisabledIT.java} (75%)
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/WhereOptimizerForArrayAnyITBase.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/WhereOptimizerForArrayAnyNullablePKIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/index/GlobalIndexCheckerEventualGenerateIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/index/GlobalIndexCheckerEventualIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/monitoring/SlowestScanMetricsIT.java
copy phoenix-core/src/it/resources/gold_files/{gold_query_add_delete.txt =>
gold_query_distinct.txt} (92%)
create mode 100644
phoenix-core/src/it/resources/indexToolResultSnapshot/indexToolsnapshot.tar.gz
create mode 100644 phoenix-core/src/it/resources/sql_files/create_distinct.sql
copy phoenix-core/src/it/resources/sql_files/{query_offset.sql =>
query_distinct.sql} (91%)
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/compile/SlowestScanMetricsTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/coprocessor/PhoenixSyncTableRegionScannerTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/expression/function/RegexpLikeFunctionTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixInputSplitTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixNoOpSingleRecordReaderTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixSyncTableInputFormatTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixSyncTableMapperTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixSyncTableOutputRepositoryTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixSyncTableToolTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/util/SHA256DigestUtilTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/parse/IndexConsistencyParseTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/query/explain/ExplainChangeRule.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/query/explain/ExplainCompatibilityTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/query/explain/ExplainJsonNormalizer.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/query/explain/ExplainOracle.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/query/explain/ExplainTextNormalizer.java
