This is an automated email from the ASF dual-hosted git repository.
lokiore pushed a change to branch PHOENIX-7210-feature
in repository https://gitbox.apache.org/repos/asf/phoenix.git
from 11e0996795 PHOENIX-7211 : Identify IT tests that can be run
successfully against real distributed cluster (#1875)
add 4cd7809adc PHOENIX-7290 Cannot load or instantiate class
org.apache.phoenix.query.DefaultGuidePostsCacheFactory from SquirrelSQL
add ceb10a5315 PHOENIX-7229 Addendum to handle cases where a child view
extends the (#1885)
add f810b5bb7f PHOENIX-7245 NPE in Phoenix Coproc leading to Region Server
crash (#1886)
add 6ceadca3ac PHOENIX-7306 Metadata lookup should be permitted only
within query timeout (#1880)
add 9a7d79abe3 PHOENIX-628 Support native JSON data type (#1780)
add 0abdcdb8e2 PHOENIX-7313 All cell versions should not be retained
during flushes … (#1888)
add bd367ccd9d PHOENIX-7001: Initial implementation of Change Data Capture
(CDC) feature (#1866)
add 2dae9c4fdf PHOENIX-7319 Leverage Bloom Filters to improve performance
on write path (#1897)
add b0a18ec93e PHOENIX-7001: Addendum to initial CDC feature (#1899)
add 4eafc22a05 PHOENIX-7320 Upgrade HBase 2.4 to 2.4.18 (#1898)
add 579f58258f PHOENIX-7192 : IDE shows errors on JSON comment (#1895)
add d77f473100 PHOENIX-7314 Enable CompactionScanner for flushes and minor
compaction (#1896)
add 42b736093c PHOENIX-7326 Simplify LockManager and make it more
efficient (#1902)
add 01fbe01c3f PHOENIX-7072 : Implement json_modify function on the json
object as Atomic Upserts (#1893)
add 259b560548 PHOENIX-7328 Fix flapping
ConcurrentMutationsExtendedIT#testConcurren… (#1903)
add ce17ec1daa PHOENIX-7172: Support HBase 2.6 (#1793)
add 8ef3b79e99 PHOENIX-7333 Add HBase 2.6 profile to multibranch Jenkins
job
add 80414aa6e8 PHOENIX-7331 Fix incompatibilities with HBASE-28644
add cef55344b1 PHOENIX-7337 Centralize and upgrade
com.jayway.jsonpath:json-path version from 2.6.0 to 2.9.0
add aedfc32498 PHOENIX-7336 Upgrade org.iq80.snappy:snappy version to 0.5
add ff868ed671 PHOENIX-7303 fix CVE-2024-29025 in netty package
add aac505448d PHOENIX-7318 : Support JSON_MODIFY in Upserts (#1904)
add f6da05c4d5 PHOENIX-7339 HBase flushes with custom clock needs to
disable remote procedure delay (#1916)
add cb82e60f98 PHOENIX-7316 Need close more Statements (#1917)
add f2e2bce194 PHOENIX-6883 : Phoenix Metadata Caching Redesign (#1883)
add 5752adbdca PHOENIX-6066 : MetaDataEndpointImpl.doGetTable should
acquire a readLock instead of an exclusive writeLock (#1919)
add f1949b6664 PHOENIX-6714 Return update status from Conditional Upserts
(#1884)
add 9954df4ead PHOENIX-7348: Serialize the CDC_INCLUDES table attribute
and add a test (#1920)
add d12d5b1b8d PHOENIX-7353 Disable remote procedure delay in
TransformToolIT
add d71a882065 PHOENIX-7287 Leverage bloom filters for multi-key point
lookups (#1923)
add 8b0920784d PHOENIX-7287 Leverage bloom filters for multi-key point
lookups (addendum)
add 4afe4579bb PHOENIX-7354 Disable
TransformToolIT.testInvalidRowsWithTableLevelMaxLookback() on HBase 2.6+
add 489dce9ca0 PHOENIX-7356 Centralize and update versions for
exclude-only dependencies
add c0baa007ad PHOENIX-7356 Centralize and update versions for
exclude-only dependencies (addendum: fix typo)
add 96151c9639 PHOENIX-6978 Redesign Phoenix TTL for Views (#1938)
add 33e8c237d0 PHOENIX-7359 BackwardCompatibilityIT throws NPE with Hbase
2.6 profile
add 613a6898a3 PHOENIX-7365 ExplainPlanV2 should get trimmed list for
regionserver location (#1940)
add 37756efc11 PHOENIX-7352 Improve OrderPreservingTracker to support
extracting par… (#1926)
add 1f88ca83f0 PHOENIX-7309 Support specifying splits.txt file while
creating a table (#1931)
new c912d7b3c2 Merge branch 'master' of github.com:apache/phoenix into
PHOENIX-7210-feature
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:
.gitignore | 3 +
Jenkinsfile | 2 +-
phoenix-assembly/pom.xml | 5 +
phoenix-core-client/pom.xml | 15 +
phoenix-core-client/src/main/antlr3/PhoenixSQL.g | 41 +
...java => InvalidateMetadataCacheController.java} | 36 +-
... InvalidateMetadataCacheControllerFactory.java} | 26 +-
.../controller/ServerSideRPCControllerFactory.java | 3 -
.../apache/phoenix/cache/ServerCacheClient.java | 16 +-
.../apache/phoenix/cache/ServerMetadataCache.java | 28 +
.../phoenix/cache/ServerMetadataCacheImpl.java | 156 ++
.../phoenix/compile/CreateIndexCompiler.java | 9 +-
.../phoenix/compile/CreateTableCompiler.java | 30 +-
.../apache/phoenix/compile/ExpressionCompiler.java | 44 +-
.../org/apache/phoenix/compile/FromCompiler.java | 15 +-
.../apache/phoenix/compile/GroupByCompiler.java | 5 +
.../phoenix/compile/OrderPreservingTracker.java | 246 +-
.../apache/phoenix/compile/ProjectionCompiler.java | 274 +-
.../org/apache/phoenix/compile/QueryCompiler.java | 72 +
.../org/apache/phoenix/compile/ScanRanges.java | 3 +-
.../apache/phoenix/compile/StatementContext.java | 29 +-
.../phoenix/compile/TupleProjectionCompiler.java | 17 +-
.../org/apache/phoenix/compile/UpsertCompiler.java | 196 +-
.../org/apache/phoenix/compile/WhereOptimizer.java | 183 +-
.../BaseScannerRegionObserverConstants.java | 10 +-
.../InvalidateServerMetadataCacheRequest.java | 53 +
.../coprocessorclient/MetaDataProtocol.java | 2 +-
.../phoenix/coprocessorclient/RowKeyMatcher.java | 150 ++
.../phoenix/coprocessorclient/TableTTLInfo.java | 115 +
.../coprocessorclient/TableTTLInfoCache.java | 108 +
.../metrics/MetricsMetadataCachingSource.java | 230 ++
.../metrics/MetricsMetadataCachingSourceImpl.java | 122 +
.../MetricsPhoenixCoprocessorSourceFactory.java | 12 +
.../apache/phoenix/exception/SQLExceptionCode.java | 45 +-
.../apache/phoenix/exception/SQLExceptionInfo.java | 33 +
.../StaleMetadataCacheException.java} | 23 +-
.../org/apache/phoenix/execute/BaseQueryPlan.java | 28 +-
.../org/apache/phoenix/execute/MutationState.java | 174 +-
.../execute/PhoenixTxIndexMutationGenerator.java | 2 +-
.../apache/phoenix/execute/SortMergeJoinPlan.java | 15 +-
.../phoenix/execute/TupleProjectionPlan.java | 21 +-
.../org/apache/phoenix/execute/TupleProjector.java | 4 +-
.../apache/phoenix/expression/ExpressionType.java | 6 +-
.../expression/SingleCellColumnExpression.java | 17 +-
.../function/DistinctCountAggregateFunction.java | 6 +
.../expression/function/JsonExistsFunction.java | 110 +
.../expression/function/JsonModifyFunction.java | 120 +
.../expression/function/JsonQueryFunction.java | 120 +
.../expression/function/JsonValueFunction.java | 130 +
.../org/apache/phoenix/filter/PagingFilter.java | 109 +-
.../phoenix/filter/RowKeyComparisonFilter.java | 2 +-
.../org/apache/phoenix/filter/SkipScanFilter.java | 55 +-
.../hbase/index/util/ImmutableBytesPtr.java | 37 +-
.../hbase/index/util/IndexManagementUtil.java | 13 +-
.../org/apache/phoenix/index/CDCTableInfo.java | 276 ++
.../org/apache/phoenix/index/IndexMaintainer.java | 33 +-
.../phoenix/iterate/BaseResultIterators.java | 11 +-
.../iterate/DefaultParallelScanGrouper.java | 6 +-
.../org/apache/phoenix/iterate/ExplainTable.java | 12 +-
.../phoenix/iterate/TableResultIterator.java | 2 +-
.../org/apache/phoenix/jdbc/PhoenixConnection.java | 18 +
.../phoenix/jdbc/PhoenixDatabaseMetaData.java | 19 +-
.../org/apache/phoenix/jdbc/PhoenixResultSet.java | 3 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 254 +-
.../phoenix/monitoring/GlobalClientMetrics.java | 4 +-
.../org/apache/phoenix/monitoring/MetricType.java | 3 +
.../apache/phoenix/optimize/QueryOptimizer.java | 137 +-
.../java/org/apache/phoenix/parse/ColumnDef.java | 17 +-
.../java/org/apache/phoenix/parse/ColumnName.java | 6 +-
.../apache/phoenix/parse/ComparisonParseNode.java | 2 +-
.../apache/phoenix/parse/CreateCDCStatement.java | 71 +
...erminalParseNode.java => DropCDCStatement.java} | 45 +-
.../phoenix/parse/FamilyWildcardParseNode.java | 11 +-
.../java/org/apache/phoenix/parse/HintNode.java | 177 +-
.../apache/phoenix/parse/JsonExistsParseNode.java | 45 +
.../apache/phoenix/parse/JsonModifyParseNode.java | 48 +
.../apache/phoenix/parse/JsonQueryParseNode.java | 48 +
.../apache/phoenix/parse/JsonValueParseNode.java | 45 +
.../org/apache/phoenix/parse/NamedTableNode.java | 2 +-
.../java/org/apache/phoenix/parse/ParseNode.java | 23 +
.../org/apache/phoenix/parse/ParseNodeFactory.java | 18 +
.../apache/phoenix/parse/ParseNodeRewriter.java | 2 +-
.../org/apache/phoenix/parse/SelectStatement.java | 15 +-
.../phoenix/parse/TableWildcardParseNode.java | 10 +
.../apache/phoenix/parse/TerminalParseNode.java | 8 +
.../apache/phoenix/parse/WildcardParseNode.java | 13 +-
.../phoenix/query/ConnectionQueryServices.java | 52 +-
.../phoenix/query/ConnectionQueryServicesImpl.java | 475 +++-
.../query/ConnectionlessQueryServicesImpl.java | 46 +-
.../query/DelegateConnectionQueryServices.java | 42 +-
.../org/apache/phoenix/query/QueryConstants.java | 16 +
.../org/apache/phoenix/query/QueryServices.java | 28 +-
.../apache/phoenix/query/QueryServicesOptions.java | 29 +-
.../java/org/apache/phoenix/schema/ColumnRef.java | 3 +-
.../ComparisonNotSupportedException.java} | 24 +-
.../org/apache/phoenix/schema/DelegateTable.java | 29 +-
.../org/apache/phoenix/schema/KeyValueSchema.java | 26 +
.../org/apache/phoenix/schema/MetaDataClient.java | 1030 ++++++--
.../java/org/apache/phoenix/schema/PTable.java | 49 +-
.../java/org/apache/phoenix/schema/PTableImpl.java | 233 +-
.../java/org/apache/phoenix/schema/PTableKey.java | 13 +
.../java/org/apache/phoenix/schema/PTableType.java | 4 +-
.../org/apache/phoenix/schema/SaltingUtil.java | 3 -
.../org/apache/phoenix/schema/TableProperty.java | 32 +-
.../java/org/apache/phoenix/schema/TableRef.java | 2 +-
.../java/org/apache/phoenix/schema/task/Task.java | 23 +-
.../schema/tool/SchemaExtractionProcessor.java | 20 +-
.../phoenix/schema/transform/TransformClient.java | 2 -
.../org/apache/phoenix/schema/types/PDataType.java | 33 +
.../phoenix/schema/types/PDataTypeFactory.java | 1 +
.../org/apache/phoenix/schema/types/PJson.java | 130 +
.../apache/phoenix/schema/types/PVarbinary.java | 4 +
.../org/apache/phoenix/schema/types/PVarchar.java | 5 +
.../apache/phoenix/trace/PhoenixMetricsSink.java | 8 +-
.../java/org/apache/phoenix/trace/TraceReader.java | 146 +-
.../java/org/apache/phoenix/trace/TraceWriter.java | 3 +-
.../phoenix/transaction/OmidTransactionTable.java | 26 -
.../java/org/apache/phoenix/util/ByteUtil.java | 17 +
.../org/apache/phoenix/util/CDCChangeBuilder.java | 151 ++
.../main/java/org/apache/phoenix/util/CDCUtil.java | 141 +
.../java/org/apache/phoenix/util/ClientUtil.java | 16 +-
.../apache/phoenix/util/EncodedColumnsUtil.java | 8 +-
.../java/org/apache/phoenix/util/IndexUtil.java | 9 +-
.../apache/phoenix/util/PhoenixKeyValueUtil.java | 51 +-
.../org/apache/phoenix/util/PhoenixRuntime.java | 2 +
.../java/org/apache/phoenix/util/ScanUtil.java | 155 +-
.../java/org/apache/phoenix/util/SchemaUtil.java | 29 +-
.../java/org/apache/phoenix/util/UpgradeUtil.java | 227 ++
.../phoenix/util/ValidateLastDDLTimestampUtil.java | 228 ++
.../java/org/apache/phoenix/util/ViewUtil.java | 157 +-
.../apache/phoenix/util/json/BsonDataFormat.java | 202 ++
.../apache/phoenix/util/json/BsonJsonProvider.java | 251 ++
.../apache/phoenix/util/json/JsonDataFormat.java | 86 +
.../phoenix/util/json/JsonDataFormatFactory.java | 16 +-
.../src/main/protobuf/CDCInfo.proto | 33 +-
phoenix-core-client/src/main/protobuf/PTable.proto | 4 +
.../protobuf/RegionServerEndpointService.proto | 59 +
.../src/main/protobuf/ServerCachingService.proto | 1 +
phoenix-core-server/pom.xml | 2 +-
.../hadoop/hbase/ipc/PhoenixRpcScheduler.java | 37 +-
.../hbase/ipc/PhoenixRpcSchedulerFactory.java | 10 +-
.../regionserver/IndexHalfStoreFileReader.java | 9 +-
.../regionserver/LocalIndexStoreFileScanner.java | 9 +-
.../hbase/regionserver/wal/IndexedHLogReader.java | 10 +-
.../coprocessor/BaseScannerRegionObserver.java | 23 +-
.../coprocessor/CDCGlobalIndexRegionScanner.java | 267 ++
.../phoenix/coprocessor/CompactionScanner.java | 2002 ++++++++++++--
.../coprocessor/GlobalIndexRegionScanner.java | 59 +-
.../coprocessor/IndexRebuildRegionScanner.java | 7 +-
.../coprocessor/IndexRepairRegionScanner.java | 9 +-
.../phoenix/coprocessor/IndexerRegionScanner.java | 6 +-
.../phoenix/coprocessor/MetaDataEndpointImpl.java | 471 +++-
.../phoenix/coprocessor/PagingRegionScanner.java | 260 +-
.../coprocessor/PhoenixAccessController.java | 11 +-
.../coprocessor/PhoenixRegionServerEndpoint.java | 117 +
.../coprocessor/PhoenixTTLRegionObserver.java | 6 +-
.../phoenix/coprocessor/TTLRegionScanner.java | 24 +-
.../coprocessor/UncoveredIndexRegionScanner.java | 18 +-
.../UngroupedAggregateRegionObserver.java | 215 +-
.../coprocessor/VerifyLastDDLTimestamp.java | 69 +
.../phoenix/hbase/index/IndexRegionObserver.java | 496 ++--
.../apache/phoenix/hbase/index/LockManager.java | 212 +-
.../hbase/index/covered/data/CachedLocalTable.java | 2 +-
.../iterate/MapReduceParallelScanGrouper.java | 6 +-
.../iterate/NonAggregateRegionScannerFactory.java | 100 +-
.../phoenix/iterate/RegionScannerFactory.java | 66 +-
.../mapreduce/PhoenixTTLDeleteJobMapper.java | 6 +-
.../mapreduce/index/IndexScrutinyMapper.java | 32 +-
.../index/automation/PhoenixMRJobSubmitter.java | 27 +-
.../PhoenixTransformWithViewsInputFormat.java | 1 +
.../util/DefaultPhoenixMultiViewListProvider.java | 2 +-
.../mapreduce/util/PhoenixMultiInputUtil.java | 16 +-
.../phoenix/mapreduce/util/ViewInfoTracker.java | 2 +-
.../apache/phoenix/schema/transform/Transform.java | 6 +
.../java/org/apache/phoenix/util/ServerUtil.java | 2 +-
.../org/apache/phoenix/util/ServerViewUtil.java | 2 +-
phoenix-core/pom.xml | 24 +
.../phoenix/cache/ServerMetadataCacheIT.java | 1921 ++++++++++++++
.../phoenix/end2end/AlterTableWithViewsIT.java | 19 +-
.../apache/phoenix/end2end/AppendOnlySchemaIT.java | 2 +-
.../phoenix/end2end/BackwardCompatibilityIT.java | 1 +
.../phoenix/end2end/BaseRowKeyMatcherTestIT.java | 1056 ++++++++
.../org/apache/phoenix/end2end/BaseViewTTLIT.java | 2732 ++++++++++++++++++++
.../java/org/apache/phoenix/end2end/CDCBaseIT.java | 828 ++++++
.../apache/phoenix/end2end/CDCDefinitionIT.java | 321 +++
.../org/apache/phoenix/end2end/CDCQueryIT.java | 712 +++++
.../end2end/ConcurrentMutationsExtendedIT.java | 20 +-
.../org/apache/phoenix/end2end/ConnectionIT.java | 3 +
.../apache/phoenix/end2end/ConnectionUtilIT.java | 3 +
.../org/apache/phoenix/end2end/CreateTableIT.java | 153 +-
.../DefaultPhoenixMultiViewListProviderIT.java | 14 +-
.../FailingPhoenixRegionServerEndpoint.java | 91 +
.../phoenix/end2end/FlappingAlterTableIT.java | 23 +-
.../phoenix/end2end/FlappingLocalIndexIT.java | 5 +-
.../java/org/apache/phoenix/end2end/InListIT.java | 38 +-
.../end2end/IndexRepairRegionScannerIT.java | 1 +
.../end2end/IndexScrutinyWithMaxLookbackIT.java | 1 +
.../phoenix/end2end/InvalidateMetadataCacheIT.java | 166 ++
.../phoenix/end2end/LoadSystemTableSnapshotIT.java | 3 +-
.../phoenix/end2end/LogicalTableNameBaseIT.java | 10 +-
.../end2end/LogicalTableNameExtendedIT.java | 21 +-
.../LongViewIndexDisabledBaseRowKeyMatcherIT.java | 71 +
.../LongViewIndexEnabledBaseRowKeyMatcherIT.java | 71 +
.../org/apache/phoenix/end2end/MapReduceIT.java | 8 +-
.../phoenix/end2end/MaxLookbackExtendedIT.java | 110 +-
.../org/apache/phoenix/end2end/MaxLookbackIT.java | 16 +-
.../end2end/MetadataGetTableReadLockIT.java | 150 ++
.../MigrateSystemTablesToSystemNamespaceIT.java | 11 +
.../phoenix/end2end/MoveTTLDuringUpgradeIT.java | 152 ++
.../apache/phoenix/end2end/OnDuplicateKey2IT.java | 646 +++++
.../apache/phoenix/end2end/OnDuplicateKeyIT.java | 27 +-
.../java/org/apache/phoenix/end2end/OrderByIT.java | 136 +
.../PartialResultServerConfigurationIT.java | 3 +
.../end2end/PhoenixRegionServerEndpointIT.java | 193 ++
.../PhoenixRegionServerEndpointTestImpl.java | 45 +
.../apache/phoenix/end2end/PhoenixTTLToolIT.java | 48 +-
.../apache/phoenix/end2end/PropertiesInSyncIT.java | 25 +-
.../phoenix/end2end/ReadOnlyViewOnReadOnlyIT.java | 3 +-
.../end2end/ServerMetadataCacheTestImpl.java | 89 +
.../org/apache/phoenix/end2end/SetPropertyIT.java | 79 +
.../end2end/SetPropertyOnEncodedTableIT.java | 2 +-
.../end2end/SetPropertyOnNonEncodedTableIT.java | 2 +-
.../end2end/SkipScanAfterManualSplitIT.java | 10 +-
.../phoenix/end2end/SplitSystemCatalogIT.java | 1 -
.../SystemTablesCreationOnConnectionIT.java | 15 +
.../apache/phoenix/end2end/TTLAsPhoenixTTLIT.java | 514 ++++
.../it/java/org/apache/phoenix/end2end/TTLIT.java | 853 ++++++
.../org/apache/phoenix/end2end/TableTTLIT.java | 103 +-
.../phoenix/end2end/TenantSpecificTablesDMLIT.java | 58 +
.../UpdateCacheAcrossDifferentClientsIT.java | 17 +-
.../java/org/apache/phoenix/end2end/UpgradeIT.java | 92 +-
.../org/apache/phoenix/end2end/ViewMetadataIT.java | 117 +
.../java/org/apache/phoenix/end2end/ViewTTLIT.java | 1589 +++---------
.../phoenix/end2end/ViewTTLNotEnabledIT.java | 136 +-
.../end2end/ViewTTLWithLongViewIndexEnabledIT.java | 103 +
.../end2end/index/DropIndexDuringUpsertIT.java | 2 +
.../end2end/index/IndexAsyncThresholdIT.java | 6 +-
.../index/IndexVerificationOutputRepositoryIT.java | 2 +-
.../index/IndexVerificationResultRepositoryIT.java | 2 +-
.../end2end/index/MutableIndexFailureIT.java | 3 +
.../phoenix/end2end/index/PartialIndexIT.java | 233 +-
.../index/ReplicationWithWALAnnotationIT.java | 11 +-
.../phoenix/end2end/index/SingleCellIndexIT.java | 11 +-
.../index/UncoveredGlobalIndexRegionScannerIT.java | 7 +-
.../phoenix/end2end/json/JsonFunctionsIT.java | 1040 ++++++++
.../phoenix/end2end/transform/TransformToolIT.java | 6 +
.../execute/UpsertSelectOverlappingBatchesIT.java | 2 +
.../index/FailForUnsupportedHBaseVersionsIT.java | 2 +
.../phoenix/iterate/PhoenixQueryTimeoutIT.java | 21 +-
.../iterate/RoundRobinResultIteratorIT.java | 10 +-
.../phoenix/iterate/ScannerLeaseRenewalIT.java | 2 +
.../jdbc/HighAvailabilityTestingUtility.java | 9 +
.../jdbc/LoggingSingleConnectionLimiterIT.java | 2 +-
.../phoenix/jdbc/ParallelPhoenixConnectionIT.java | 1 +
.../monitoring/PhoenixTableLevelMetricsIT.java | 102 +-
.../ConnectionQueryServicesMetricsIT.java | 3 +
.../phoenix/query/MaxConcurrentConnectionsIT.java | 10 +-
.../apache/phoenix/query/MetaDataCachingIT.java | 19 +-
.../rpc/UpdateCacheConnectionLevelPropIT.java | 10 +
.../java/org/apache/phoenix/rpc/UpdateCacheIT.java | 31 +-
.../phoenix/schema/stats/BaseStatsCollectorIT.java | 9 +-
.../it/resources/compatible_client_versions.json | 20 +-
.../src/it/resources/json/json_datatypes.json | 36 +
.../it/resources/json/json_functions_basic.json | 83 +
...dulerTest.java => PhoenixRpcSchedulerTest.java} | 61 +-
.../phoenix/cache/ServerCacheClientTest.java | 7 +-
.../apache/phoenix/compile/QueryCompilerTest.java | 309 ++-
.../apache/phoenix/compile/QueryOptimizerTest.java | 2 +
.../apache/phoenix/compile/ViewCompilerTest.java | 3 +
.../apache/phoenix/compile/WhereCompilerTest.java | 36 +-
.../apache/phoenix/compile/WhereOptimizerTest.java | 87 +-
.../phoenix/expression/CoerceExpressionTest.java | 32 +-
.../filter/SkipScanFilterIntersectTest.java | 2 +-
.../apache/phoenix/filter/SkipScanFilterTest.java | 4 +-
.../hbase/index/write/TestWALRecoveryCaching.java | 2 +
.../jdbc/ParallelPhoenixConnectionFailureTest.java | 7 +-
.../phoenix/jdbc/PhoenixResultSetMetadataTest.java | 2 +-
.../mapreduce/PhoenixMultiViewReaderTest.java | 4 +-
.../org/apache/phoenix/parse/QueryParserTest.java | 122 +-
.../phoenix/query/BaseConnectionlessQueryTest.java | 5 +-
.../java/org/apache/phoenix/query/BaseTest.java | 22 +
.../query/ConnectionQueryServicesImplTest.java | 45 +-
.../phoenix/query/ParallelIteratorsSplitTest.java | 9 +-
.../apache/phoenix/query/PhoenixTestBuilder.java | 127 +-
.../apache/phoenix/schema/types/PDataTypeTest.java | 1 +
.../java/org/apache/phoenix/util/CDCUtilTest.java | 62 +
.../org/apache/phoenix/util/IndexUtilTest.java | 4 +
.../apache/phoenix/util/PhoenixRuntimeTest.java | 4 +
.../org/apache/phoenix/util/RowKeyMatcherTest.java | 287 ++
.../java/org/apache/phoenix/util/ScanUtilTest.java | 2 +-
.../java/org/apache/phoenix/util/TestUtil.java | 25 +-
.../phoenix/compat/hbase/CompatDelegateHTable.java | 13 +-
.../hbase/CompatIndexHalfStoreFileReader.java | 40 +
.../compat/hbase/CompatIndexedHLogReader.java | 31 +
.../hbase/CompatLocalIndexStoreFileScanner.java | 33 +
.../compat/hbase/CompatOmidTransactionTable.java | 42 +-
.../compat/hbase/CompatPhoenixRpcScheduler.java | 13 +-
.../apache/phoenix/compat/hbase/CompatUtil.java | 15 +-
.../compat/hbase/HbaseCompatCapabilities.java | 13 +-
.../hbase/ReplicationSinkCompatEndpoint.java | 21 +-
.../phoenix/compat/hbase/CompatDelegateHTable.java | 13 +-
.../hbase/CompatIndexHalfStoreFileReader.java | 40 +
.../compat/hbase/CompatIndexedHLogReader.java | 31 +
.../hbase/CompatLocalIndexStoreFileScanner.java | 34 +
.../compat/hbase/CompatOmidTransactionTable.java | 42 +-
.../compat/hbase/CompatPhoenixRpcScheduler.java | 13 +-
.../apache/phoenix/compat/hbase/CompatUtil.java | 15 +-
.../compat/hbase/HbaseCompatCapabilities.java | 13 +-
.../hbase/ReplicationSinkCompatEndpoint.java | 21 +-
.../phoenix/compat/hbase/CompatDelegateHTable.java | 13 +-
.../hbase/CompatIndexHalfStoreFileReader.java | 40 +
.../compat/hbase/CompatIndexedHLogReader.java | 32 +
.../hbase/CompatLocalIndexStoreFileScanner.java | 33 +
.../compat/hbase/CompatOmidTransactionTable.java | 42 +-
.../compat/hbase/CompatPhoenixRpcScheduler.java | 13 +-
.../apache/phoenix/compat/hbase/CompatUtil.java | 15 +-
.../compat/hbase/HbaseCompatCapabilities.java | 13 +-
.../hbase/ReplicationSinkCompatEndpoint.java | 21 +-
phoenix-hbase-compat-2.6.0/pom.xml | 113 +
.../phoenix/compat/hbase/CompatDelegateHTable.java | 13 +-
.../hbase/CompatIndexHalfStoreFileReader.java | 42 +
.../compat/hbase/CompatIndexedHLogReader.java | 23 +
.../hbase/CompatLocalIndexStoreFileScanner.java | 35 +
.../compat/hbase/CompatOmidTransactionTable.java | 78 +
.../compat/hbase/CompatPhoenixRpcScheduler.java | 27 +-
.../apache/phoenix/compat/hbase/CompatUtil.java | 15 +-
.../compat/hbase/HbaseCompatCapabilities.java | 13 +-
.../hbase/ReplicationSinkCompatEndpoint.java | 21 +-
phoenix-mapreduce-byo-shaded-hbase/pom.xml | 12 +-
.../pherf/configuration/DataTypeMapping.java | 3 +-
.../apache/phoenix/pherf/configuration/Query.java | 15 +-
.../apache/phoenix/pherf/rules/RulesApplier.java | 215 +-
.../pherf/rules/SequentialListDataGenerator.java | 1 +
.../rules/SequentialVarcharDataGenerator.java | 1 +
.../org/apache/phoenix/pherf/util/PhoenixUtil.java | 8 +-
phoenix-server/pom.xml | 12 +-
pom.xml | 71 +-
337 files changed, 27468 insertions(+), 4255 deletions(-)
copy
phoenix-core-client/src/main/java/org/apache/hadoop/hbase/ipc/controller/{ServerSideRPCControllerFactory.java
=> InvalidateMetadataCacheController.java} (52%)
copy
phoenix-core-client/src/main/java/org/apache/hadoop/hbase/ipc/controller/{ServerSideRPCControllerFactory.java
=> InvalidateMetadataCacheControllerFactory.java} (61%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/cache/ServerMetadataCache.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/cache/ServerMetadataCacheImpl.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/InvalidateServerMetadataCacheRequest.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/RowKeyMatcher.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/TableTTLInfo.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/TableTTLInfoCache.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/metrics/MetricsMetadataCachingSource.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/coprocessorclient/metrics/MetricsMetadataCachingSourceImpl.java
copy
phoenix-core-client/src/main/java/org/apache/phoenix/{parse/TerminalParseNode.java
=> exception/StaleMetadataCacheException.java} (64%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/JsonExistsFunction.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/JsonModifyFunction.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/JsonQueryFunction.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/JsonValueFunction.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/index/CDCTableInfo.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/parse/CreateCDCStatement.java
copy
phoenix-core-client/src/main/java/org/apache/phoenix/parse/{TerminalParseNode.java
=> DropCDCStatement.java} (51%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/parse/JsonExistsParseNode.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/parse/JsonModifyParseNode.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/parse/JsonQueryParseNode.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/parse/JsonValueParseNode.java
copy
phoenix-core-client/src/main/java/org/apache/phoenix/{parse/TerminalParseNode.java
=> schema/ComparisonNotSupportedException.java} (61%)
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/schema/types/PJson.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/util/CDCChangeBuilder.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/util/CDCUtil.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/util/ValidateLastDDLTimestampUtil.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/util/json/BsonDataFormat.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/util/json/BsonJsonProvider.java
create mode 100644
phoenix-core-client/src/main/java/org/apache/phoenix/util/json/JsonDataFormat.java
copy
phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/HbaseCompatCapabilities.java
=>
phoenix-core-client/src/main/java/org/apache/phoenix/util/json/JsonDataFormatFactory.java
(71%)
copy
phoenix-core/src/it/java/org/apache/phoenix/end2end/SetPropertyOnNonEncodedTableIT.java
=> phoenix-core-client/src/main/protobuf/CDCInfo.proto (54%)
create mode 100644
phoenix-core-client/src/main/protobuf/RegionServerEndpointService.proto
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/CDCGlobalIndexRegionScanner.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixRegionServerEndpoint.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/VerifyLastDDLTimestamp.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/cache/ServerMetadataCacheIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/BaseRowKeyMatcherTestIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/BaseViewTTLIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/CDCBaseIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/CDCDefinitionIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/CDCQueryIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/FailingPhoenixRegionServerEndpoint.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/InvalidateMetadataCacheIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/LongViewIndexDisabledBaseRowKeyMatcherIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/LongViewIndexEnabledBaseRowKeyMatcherIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/MetadataGetTableReadLockIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/MoveTTLDuringUpgradeIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/OnDuplicateKey2IT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/PhoenixRegionServerEndpointIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/PhoenixRegionServerEndpointTestImpl.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/ServerMetadataCacheTestImpl.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/TTLAsPhoenixTTLIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/TTLIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/ViewTTLWithLongViewIndexEnabledIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/json/JsonFunctionsIT.java
create mode 100644 phoenix-core/src/it/resources/json/json_datatypes.json
create mode 100644 phoenix-core/src/it/resources/json/json_functions_basic.json
rename
phoenix-core/src/test/java/org/apache/hadoop/hbase/ipc/{PhoenixIndexRpcSchedulerTest.java
=> PhoenixRpcSchedulerTest.java} (75%)
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/util/CDCUtilTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/util/RowKeyMatcherTest.java
create mode 100644
phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexHalfStoreFileReader.java
create mode 100644
phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexedHLogReader.java
create mode 100644
phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/CompatLocalIndexStoreFileScanner.java
create mode 100644
phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexHalfStoreFileReader.java
create mode 100644
phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexedHLogReader.java
create mode 100644
phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/CompatLocalIndexStoreFileScanner.java
create mode 100644
phoenix-hbase-compat-2.5.4/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexHalfStoreFileReader.java
create mode 100644
phoenix-hbase-compat-2.5.4/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexedHLogReader.java
create mode 100644
phoenix-hbase-compat-2.5.4/src/main/java/org/apache/phoenix/compat/hbase/CompatLocalIndexStoreFileScanner.java
create mode 100644 phoenix-hbase-compat-2.6.0/pom.xml
copy {phoenix-hbase-compat-2.5.4 =>
phoenix-hbase-compat-2.6.0}/src/main/java/org/apache/phoenix/compat/hbase/CompatDelegateHTable.java
(72%)
create mode 100644
phoenix-hbase-compat-2.6.0/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexHalfStoreFileReader.java
create mode 100644
phoenix-hbase-compat-2.6.0/src/main/java/org/apache/phoenix/compat/hbase/CompatIndexedHLogReader.java
create mode 100644
phoenix-hbase-compat-2.6.0/src/main/java/org/apache/phoenix/compat/hbase/CompatLocalIndexStoreFileScanner.java
create mode 100644
phoenix-hbase-compat-2.6.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
copy {phoenix-hbase-compat-2.5.4 =>
phoenix-hbase-compat-2.6.0}/src/main/java/org/apache/phoenix/compat/hbase/CompatPhoenixRpcScheduler.java
(60%)
copy {phoenix-hbase-compat-2.5.4 =>
phoenix-hbase-compat-2.6.0}/src/main/java/org/apache/phoenix/compat/hbase/CompatUtil.java
(83%)
copy {phoenix-hbase-compat-2.5.0 =>
phoenix-hbase-compat-2.6.0}/src/main/java/org/apache/phoenix/compat/hbase/HbaseCompatCapabilities.java
(57%)
copy {phoenix-hbase-compat-2.4.1 =>
phoenix-hbase-compat-2.6.0}/src/main/java/org/apache/phoenix/compat/hbase/ReplicationSinkCompatEndpoint.java
(84%)
