You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by sk...@apache.org on 2020/12/17 01:06:11 UTC
[phoenix] branch 4.x-PHOENIX-5182 updated (8af9cd8 -> 71056dc)
This is an automated email from the ASF dual-hosted git repository.
skadam pushed a change to branch 4.x-PHOENIX-5182
in repository https://gitbox.apache.org/repos/asf/phoenix.git.
discard 8af9cd8 PHOENIX-6200 Add counters for extra index rows, log results to PIT and PIT_RESULT table (#995)
omit 92c8579 PHOENIX-6199 Generate different query plan depending upon if the source (#958)
omit 0d33ce9 PHOENIX-6198 Add option to IndexTool to specify the source table for scan (#937)
add 8c5d7a8 PHOENIX-6197 AggregateIT and StoreNullsIT hangs (addendum: switch StoreNullsIT to NeedsOwnMiniClusterTest)
add 135692c PHOENIX-6192 : Use tenant connection to resolve tenant views in syncUpdateCacheFreqAllIndexes()
add 1872f5f PHOENIX-6129 : Optimize tableExists() call while retrieving correct MUTEX table
add ac0538b PHOENIX-6124 : Addendum for JDK7 compatibility
add 2aaf2e2 PHOENIX-6158 create table/view should not update VIEW_INDEX_ID_DATA_TYPE column
add fc46ca0 PHOENIX-6002 : Resolve connection leak through QueryUtil.getConnectionOnServer()
add 7cbebb4 PHOENIX-6171 Child views should not be allowed to override the parent view PHOENIX_TTL attribute.
add 9ffd740 PHOENIX-6179 : Relax maxLookBackAge check during an upgrade
add a8a9699 PHOENIX-6087 : Resolve Phoenix Connection leak in UpgradeUtil.addViewIndexToParentLinks() and Admin leak in UpgradeUtil.syncTableAndIndexProperties()
add 8aa243d PHOENIX-5210 NullPointerException when alter options of a table that is appendOnlySchema
add 11575c0 PHOENIX-6032: When phoenix.allow.system.catalog.rollback=true, a view still sees data from a column that was dropped
add 519da9a PHOENIX-6126 : All createViewAddChildLink requests should go to corresponding region of SYSTEM.CHILD_LINK
add b84121d PHOENIX-6208 Backport the assembly changes in PHOENIX-6178 to 4.x
add 20d2a6d PHOENIX-6086 : Take snapshot of all SYSTEM tables before attempting to upgrade them
add 9f91707 PHOENIX-6083 View index creation does a checkAndPut on an incorrect row key
add 2fec392 PHOENIX-6209 Remove unused estimateParallelLevel()
add 31c9912 PHOENIX-6184 : Emit ageOfUnverifiedRow metric during read repairs
add 893a050 Revert "PHOENIX-6179 : Relax maxLookBackAge check during an upgrade"
add 50edcc9 PHOENIX-6179 : Relax maxLookBackAge check during an upgrade
add 47b8046 PHOENIX-6091 Calling MetaDataProtocol.getVersion() on a 4.16 timestamp gives version as 4.15.x
add 63ace25 PHOENIX-5940 Pre-4.15 client cannot connect to 4.15+ server after SYSTEM.CATALOG region has split
add f0f2f74 PHOENIX-6203 : Add new CQS method to return Table instance only if table exists
add 068d94e PHOENIX-5669 : Remove hack for PHOENIX-3121
add 21e729f PHOENIX-5472 Fix few typos in the javadocs
add c9c80b2 PHOENIX-5955 OrphanViewToolIT is flapping
add 565b0ea PHOENIX-6212: Improve SystemCatalogIT.testSystemTableSplit() to ensure no splitting occurs when splitting is disabled
add b97696b PHOENIX-6218 Rows deleted count is incorrect for immutable tables with indexes (#961)
add 110f5b7 PHOENIX-5998 Paged server side ungrouped aggregate operations
add e58b758 PHOENIX-6191: Creating a view which has its own new columns should also do checkAndPut checks on SYSTEM.MUTEX
add 2169994 PHOENIX-6221 Getting CNF while creating transactional table with Omid(Rajeshbabu)
add cd657db fixing white spaces
add 510ca96 PHOENIX-5601 Add a new coprocessor for PHOENIX_TTL - PhoenixTTLRegionObserver
add ed7f1a6 PHOENIX-6155 : Provide a coprocessor endpoint to avoid direct upserts into SYSTEM.TASK from the client
add ce9450d PHOENIX-6207 Paged server side grouped aggregate operations
add 9084190 PHOENIX-6207 Addendum
add 55c41f7 PHOENIX-6186 - Store last DDL timestamp in System.Catalog (#935)
add 6600c07 PHOENIX-6078 Remove Internal Phoenix Connections from parent LinkedQueue when closed
add 3246b6c PHOENIX-6230: IT suite hangs on ViewConcurrencyAndFailureIT
add e57fcc8 PHOENIX-6228 : Close Admin resources for certain workflows
add 1c055e3 PHOENIX-6155 : Use CompatRegionCoprocessorEnvironment (ADDENDUM)
add dbfa24e PHOENIX-5895 Leverage WALCellFilter in the SystemCatalogWALEntryFilter to replicate system catalog table
add a0471a6 PHOENIX-6224 Support Correlated IN Subquery
add c3818ee PHOENIX-6231 Update Omid to 1.0.2
add 864d110 PHOENIX-6233 QueryTimeoutIT fails sometimes.
add e351543 PHOENIX-4412 Tephra transaction context visibility level returns null instead of SNAPSHOT_ALL
add 7ac4dff PHOENIX-5920 Skip SYSTEM TABLE checks while creating phoenix connection if client has set the DoNotUpgrade config
add 6195621 PHOENIX-6223 could not find or load main class sqline.SqLine
add 277b6fd PHOENIX-5960 : Creating view on non-existent table should throw TNFE
add a38518d Revert "PHOENIX-6223 could not find or load main class sqline.SqLine"
add 18b9f76 PHOENIX-6223 could not find or load main class sqline.SqLine
add 160153c PHOENIX-6237 Relocate javax. classes in phoenix-client
add f604877 PHOENIX-5860 Throw exception which region is closing or splitting when delete data
add 0b69306 PHOENIX-6239: NullPointerException when index table does not use COLUMN_ENCODED_BYTES (#994)
add b8cb658 PHOENIX-6086 : Avoid restoring snapshots of System tables
add 5e70f76 PHOENIX-6232 Correlated subquery should not push to RegionServer as the probe side of the Hash join
add 4f8eab9 PHOENIX-6242 Remove remaining commons-logging references
add b4cf108 PHOENIX-6082 : Avoid checkAndPut when altering properties for a table or view with column-encoding enabled
add 2b9455c PHOENIX-6245 Update tephra dependency version to 0.16.0
add e281ec6 PHOENIX-5728 : ExplainPlan with plan as attributes object
add bc11dfb PHOENIX-5712 Got SYSCAT ILLEGAL_DATA exception after created tenant index on view
add 1261c3f PHOENIX-6246 : Remove flakes from PointInTimeQueryIT
add e648b04 PHOENIX-6246 : Remove flakes from PointInTimeQueryIT (ADDENDUM)
add e1ee29d [PHOENIX-6213] Extend Cell Tags to Delete object to store source of operation.
add adb5263 PHOENIX-5140 TableNotFoundException occurs when we create local asynchronous index get parent physical table name with colon seperator
add 535a839 PHOENIX-6241 ViewIndexId sequences collide with ones created on the pre-4.15 version
add 432474e PHOENIX-6058 When maxLookback is not enabled, IndexTool should not do deep verification (#901)
add a3b6d0b Revert "PHOENIX-5140 TableNotFoundException occurs when we create local asynchronous index"
add 0641bef PHOENIX-6251 : Remove flakes from ConcurrentMutationsExtendedIT
add d43c362 PHOENIX-6252 Fix BackwardCompatibilityIT test flapper
add 4b272b1 PHOENIX-6232 (addendum)Correlated subquery should not push to RegionServer as the probe side of the Hash join
add dcb49f4 PHOENIX-6263 : Close Table resources for certain workflows
add c0dd428 PHOENIX-6256: Fix MaxConcurrentConnectionsIT test flapper
add d0639de PHOENIX-5435 - Annotate HBase WALs with Phoenix Metadata
add 0ca2231 PHOENIX-6250 Fix ViewMetadataIT test flapper
add 5877936 PHOENIX-5592 MapReduce job to asynchronously delete rows where the VIEW_TTL has expired
add aa468e3 PHOENIX-6261 Reorganise project structure to make mvn versions:set work
add d7597a1 PHOENIX-6198 Add option to IndexTool to specify the source table for scan (#937)
add 1496765 PHOENIX-6199 Generate different query plan depending upon if the source (#958)
add 71056dc PHOENIX-6200 Add counters for extra index rows, log results to PIT and PIT_RESULT table (#995)
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 (8af9cd8)
\
N -- N -- N refs/heads/4.x-PHOENIX-5182 (71056dc)
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.
No new revisions were added by this update.
Summary of changes:
bin/phoenix_utils.py | 2 +-
phoenix-assembly/pom.xml | 19 +-
.../src/build/components/all-common-files.xml | 12 +-
phoenix-assembly/src/build/src.xml | 127 -
phoenix-client-parent/pom.xml | 15 +-
phoenix-core/pom.xml | 47 +
.../phoenix/end2end/AlterAddCascadeIndexIT.java | 7 +-
.../AlterParentTableWithSysCatRollbackIT.java | 142 --
.../org/apache/phoenix/end2end/AlterTableIT.java | 139 +-
.../phoenix/end2end/AlterTableWithViewsIT.java | 256 +-
.../apache/phoenix/end2end/AppendOnlySchemaIT.java | 24 +
...BackwardCompatibilityForSplittableSyscatIT.java | 100 +
.../phoenix/end2end/BackwardCompatibilityIT.java | 455 ++--
.../end2end/BackwardCompatibilityTestUtil.java | 325 +++
.../apache/phoenix/end2end/BasePermissionsIT.java | 2 +-
.../org/apache/phoenix/end2end/BaseQueryIT.java | 40 +-
.../end2end/ConcurrentMutationsExtendedIT.java | 64 +-
.../ConcurrentUpsertsWithoutIndexedColsIT.java | 134 +
.../org/apache/phoenix/end2end/CreateTableIT.java | 71 +-
.../DefaultPhoenixMultiViewListProviderIT.java | 205 ++
.../java/org/apache/phoenix/end2end/DeleteIT.java | 178 +-
.../org/apache/phoenix/end2end/EmptyColumnIT.java | 6 +-
.../java/org/apache/phoenix/end2end/GroupByIT.java | 2 -
.../apache/phoenix/end2end/IndexExtendedIT.java | 2 +
.../apache/phoenix/end2end/IndexRebuildTaskIT.java | 17 +-
.../end2end/IndexVerificationOldDesignIT.java | 2 +
.../org/apache/phoenix/end2end/MaxLookbackIT.java | 6 +-
.../end2end/MergeViewIndexIdSequencesToolIT.java | 93 +
.../apache/phoenix/end2end/OrphanViewToolIT.java | 9 +-
.../apache/phoenix/end2end/PhoenixTTLToolIT.java | 848 +++++++
.../apache/phoenix/end2end/PointInTimeQueryIT.java | 130 +-
.../phoenix/end2end/PointInTimeScanQueryIT.java | 178 ++
.../apache/phoenix/end2end/PropertiesInSyncIT.java | 2 +-
.../org/apache/phoenix/end2end/QueryTimeoutIT.java | 2 +-
.../apache/phoenix/end2end/SpillableGroupByIT.java | 1 +
.../phoenix/end2end/SplitSystemCatalogIT.java | 14 +-
.../org/apache/phoenix/end2end/StoreNullsIT.java | 2 +
.../phoenix/end2end/SyncUpdateCacheFreqIT.java | 239 ++
.../apache/phoenix/end2end/SystemCatalogIT.java | 140 --
.../end2end/SystemCatalogRollbackEnabledIT.java | 294 +++
.../SystemTablesCreationOnConnectionIT.java | 40 +-
.../phoenix/end2end/SystemTablesUpgradeIT.java | 10 +-
.../java/org/apache/phoenix/end2end/UpgradeIT.java | 343 +--
.../apache/phoenix/end2end/UpgradeNamespaceIT.java | 300 +++
.../org/apache/phoenix/end2end/UpsertSelectIT.java | 1 -
.../end2end/ViewConcurrencyAndFailureIT.java | 795 ++++++
.../it/java/org/apache/phoenix/end2end/ViewIT.java | 1065 +++-----
.../phoenix/end2end/ViewIndexIdRetrieveIT.java | 177 ++
.../org/apache/phoenix/end2end/ViewMetadataIT.java | 872 ++++---
.../java/org/apache/phoenix/end2end/ViewTTLIT.java | 2573 ++++++++++++++++++--
.../apache/phoenix/end2end/WALAnnotationIT.java | 551 +++++
.../end2end/index/GlobalIndexCheckerIT.java | 7 +-
.../phoenix/end2end/index/ImmutableIndexIT.java | 107 +-
.../phoenix/end2end/index/IndexMetadataIT.java | 18 +-
.../phoenix/end2end/index/MutableIndexIT.java | 99 +
.../apache/phoenix/end2end/index/ViewIndexIT.java | 641 +++--
.../phoenix/end2end/join/HashJoinMoreIT.java | 116 +
.../apache/phoenix/end2end/join/SubqueryIT.java | 128 +-
.../end2end/join/SubqueryUsingSortMergeJoinIT.java | 106 +
.../apache/phoenix/iterate/MockResultIterator.java | 7 +
.../apache/phoenix/monitoring/IndexMetricsIT.java | 15 +-
.../phoenix/query/MaxConcurrentConnectionsIT.java | 70 +-
.../replication/SystemCatalogWALEntryFilterIT.java | 17 +-
.../java/org/apache/phoenix/rpc/UpdateCacheIT.java | 121 +-
.../phoenix/schema/stats/BaseStatsCollectorIT.java | 129 +-
..._query_add_delete.txt => gold_query_delete.txt} | 12 +-
... => gold_query_delete_for_splitable_syscat.txt} | 12 +-
.../gold_files/gold_query_index_rebuild_async.txt} | 9 +-
...te.txt => gold_query_select_and_drop_table.txt} | 12 +-
...ry_add_delete.txt => gold_query_view_index.txt} | 10 +-
.../sql_files/add_view_index.sql} | 13 +-
...eate_diverged_view.sql => create_tmp_table.sql} | 7 +-
.../sql_files/index_rebuild_async.sql} | 19 +-
.../{query_add_delete.sql => query_delete.sql} | 11 +-
...e.sql => query_delete_for_splitable_syscat.sql} | 13 +-
.../sql_files/query_index_rebuild_async.sql} | 6 +-
.../sql_files/query_select_and_drop_table.sql} | 8 +-
.../resources/sql_files/query_view_index.sql} | 6 +-
.../hbase/PhoenixTagType.java} | 22 +-
.../regionserver/IndexHalfStoreFileReader.java | 2 +-
.../IndexHalfStoreFileReaderGenerator.java | 16 +-
.../java/org/apache/phoenix/call/CallRunner.java | 1 -
.../phoenix/compile/CreateTableCompiler.java | 75 +-
.../org/apache/phoenix/compile/DeleteCompiler.java | 76 +-
.../org/apache/phoenix/compile/ExplainPlan.java | 19 +-
.../phoenix/compile/ExplainPlanAttributes.java | 598 +++++
.../apache/phoenix/compile/GroupByCompiler.java | 51 +-
.../org/apache/phoenix/compile/JoinCompiler.java | 244 +-
.../apache/phoenix/compile/ListJarsQueryPlan.java | 7 +
.../compile/MutatingParallelIteratorFactory.java | 11 +
.../org/apache/phoenix/compile/QueryCompiler.java | 105 +-
.../phoenix/compile/ServerBuildIndexCompiler.java | 3 +-
.../apache/phoenix/compile/SubqueryRewriter.java | 309 ++-
.../apache/phoenix/compile/SubselectRewriter.java | 7 +-
.../org/apache/phoenix/compile/TraceQueryPlan.java | 7 +
.../org/apache/phoenix/compile/UpsertCompiler.java | 32 +-
.../phoenix/coprocessor/AddColumnMutator.java | 17 +-
.../coprocessor/BaseMetaDataEndpointObserver.java | 6 +
.../coprocessor/BaseScannerRegionObserver.java | 17 +-
.../apache/phoenix/coprocessor/ColumnMutator.java | 3 +-
.../phoenix/coprocessor/DropColumnMutator.java | 52 +-
.../coprocessor/GlobalIndexRegionScanner.java | 8 +-
.../GroupedAggregateRegionObserver.java | 361 +--
.../phoenix/coprocessor/MetaDataEndpointImpl.java | 279 ++-
.../coprocessor/MetaDataEndpointObserver.java | 3 +
.../phoenix/coprocessor/MetaDataProtocol.java | 18 +-
.../PhoenixMetaDataCoprocessorHost.java | 14 +
.../coprocessor/PhoenixTTLRegionObserver.java | 307 +++
.../coprocessor/SystemCatalogRegionObserver.java | 59 +
...DataEndpoint.java => TaskMetaDataEndpoint.java} | 74 +-
.../phoenix/coprocessor/TaskRegionObserver.java | 34 +-
.../UngroupedAggregateRegionObserver.java | 563 +----
.../UngroupedAggregateRegionScanner.java | 672 +++++
.../coprocessor/generated/MetaDataProtos.java | 222 +-
.../coprocessor/generated/PTableProtos.java | 197 +-
.../coprocessor/generated/ServerCachingProtos.java | 204 +-
...MetaDataProtos.java => TaskMetaDataProtos.java} | 192 +-
.../MetricsPhoenixCoprocessorSourceFactory.java | 45 +
.../metrics/MetricsPhoenixTTLSource.java | 61 +
.../metrics/MetricsPhoenixTTLSourceImpl.java | 58 +
.../coprocessor/tasks/IndexRebuildTask.java | 18 +-
.../apache/phoenix/exception/SQLExceptionCode.java | 8 +
.../org/apache/phoenix/execute/BaseQueryPlan.java | 26 +-
.../phoenix/execute/ClientAggregatePlan.java | 34 +-
.../org/apache/phoenix/execute/ClientScanPlan.java | 23 +-
.../org/apache/phoenix/execute/CorrelatePlan.java | 37 +-
.../org/apache/phoenix/execute/HashJoinPlan.java | 3 +-
.../execute/LiteralResultIterationPlan.java | 9 +-
.../org/apache/phoenix/execute/MutationState.java | 50 +
.../apache/phoenix/execute/SortMergeJoinPlan.java | 44 +-
.../phoenix/execute/TupleProjectionPlan.java | 14 +-
.../java/org/apache/phoenix/execute/UnionPlan.java | 12 +-
.../apache/phoenix/execute/UnnestArrayPlan.java | 13 +-
.../filter/SystemCatalogViewIndexIdFilter.java | 160 ++
.../phoenix/hbase/index/IndexRegionObserver.java | 107 +-
.../index/metrics/GlobalIndexCheckerSource.java | 11 +
.../metrics/GlobalIndexCheckerSourceImpl.java | 15 +
.../AbstractParallelWriterIndexCommitter.java | 7 +-
.../write/LazyParallelWriterIndexCommitter.java | 4 -
.../apache/phoenix/index/GlobalIndexChecker.java | 24 +-
.../org/apache/phoenix/index/IndexMaintainer.java | 21 +-
.../BaseGroupedAggregatingResultIterator.java | 7 +
.../apache/phoenix/iterate/BaseResultIterator.java | 7 +
.../phoenix/iterate/BaseResultIterators.java | 67 +-
.../phoenix/iterate/ChunkedResultIterator.java | 14 +
.../ClientHashAggregatingResultIterator.java | 8 +
.../phoenix/iterate/ConcatResultIterator.java | 10 +
.../phoenix/iterate/CursorResultIterator.java | 10 +
.../phoenix/iterate/DelegateResultIterator.java | 8 +
.../iterate/DistinctAggregatingResultIterator.java | 11 +
.../org/apache/phoenix/iterate/ExplainTable.java | 91 +-
.../iterate/FilterAggregatingResultIterator.java | 20 +-
.../phoenix/iterate/FilterResultIterator.java | 20 +-
.../phoenix/iterate/LimitingResultIterator.java | 22 +-
.../phoenix/iterate/LookAheadResultIterator.java | 8 +
.../MaterializedComparableResultIterator.java | 8 +
.../iterate/MaterializedResultIterator.java | 7 +
.../iterate/MergeSortRowKeyResultIterator.java | 20 +-
.../iterate/MergeSortTopNResultIterator.java | 30 +-
.../phoenix/iterate/OffsetResultIterator.java | 10 +
.../phoenix/iterate/OrderedResultIterator.java | 20 +
.../phoenix/iterate/PeekingResultIterator.java | 7 +
.../org/apache/phoenix/iterate/ResultIterator.java | 24 +
.../apache/phoenix/iterate/ResultIterators.java | 20 +
.../phoenix/iterate/RoundRobinResultIterator.java | 16 +
.../RowKeyOrderedAggregateResultIterator.java | 10 +
.../phoenix/iterate/ScanningResultIterator.java | 11 +
.../phoenix/iterate/SequenceResultIterator.java | 22 +-
.../apache/phoenix/iterate/SerialIterators.java | 7 +
.../phoenix/iterate/SpoolingResultIterator.java | 17 +
.../phoenix/iterate/TableResultIterator.java | 16 +-
.../iterate/TableSnapshotResultIterator.java | 17 +-
.../UngroupedAggregatingResultIterator.java | 43 +-
.../phoenix/iterate/UnionResultIterators.java | 30 +-
.../org/apache/phoenix/jdbc/PhoenixConnection.java | 36 +-
.../phoenix/jdbc/PhoenixDatabaseMetaData.java | 23 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 49 +-
.../phoenix/mapreduce/FormatToKeyValueReducer.java | 4 +-
.../apache/phoenix/mapreduce/OrphanViewTool.java | 11 +-
.../mapreduce/PhoenixMultiViewInputFormat.java | 113 +
.../mapreduce/PhoenixMultiViewInputSplit.java | 77 +
.../phoenix/mapreduce/PhoenixMultiViewReader.java | 86 +
.../mapreduce/PhoenixTTLDeleteJobMapper.java | 241 ++
.../apache/phoenix/mapreduce/PhoenixTTLTool.java | 320 +++
.../mapreduce/index/IndexScrutinyMapper.java | 7 +-
.../apache/phoenix/mapreduce/index/IndexTool.java | 17 +-
.../phoenix/mapreduce/index/IndexUpgradeTool.java | 4 +-
.../index/IndexVerificationOutputRepository.java | 24 +-
.../index/IndexVerificationResultRepository.java | 92 +-
.../util/DefaultMultiViewJobStatusTracker.java | 50 +
.../util/DefaultMultiViewSplitStrategy.java | 79 +
.../util/DefaultPhoenixMultiViewListProvider.java | 200 ++
.../mapreduce/util/MultiViewJobStatusTracker.java} | 19 +-
.../util/MultiViewSplitStrategy.java} | 14 +-
.../mapreduce/util/PhoenixConfigurationUtil.java | 55 +-
.../mapreduce/util/PhoenixMapReduceUtil.java | 17 +
.../mapreduce/util/PhoenixMultiInputUtil.java | 114 +
.../util/PhoenixMultiViewListProvider.java} | 11 +-
.../phoenix/mapreduce/util/ViewInfoTracker.java | 108 +
.../util/ViewInfoWritable.java} | 42 +-
.../apache/phoenix/optimize/QueryOptimizer.java | 19 +-
.../org/apache/phoenix/parse/ParseNodeFactory.java | 11 +
.../org/apache/phoenix/parse/SelectStatement.java | 2 +-
.../org/apache/phoenix/protobuf/ProtobufUtil.java | 7 +
.../query/ChildLinkMetaDataServiceCallBack.java | 68 +
.../phoenix/query/ConnectionQueryServices.java | 27 +-
.../phoenix/query/ConnectionQueryServicesImpl.java | 583 +++--
.../query/ConnectionlessQueryServicesImpl.java | 6 +
.../query/DelegateConnectionQueryServices.java | 6 +
.../org/apache/phoenix/query/QueryConstants.java | 4 +
.../org/apache/phoenix/query/QueryServices.java | 13 +-
.../apache/phoenix/query/QueryServicesOptions.java | 8 +-
.../replication/SystemCatalogWALEntryFilter.java | 54 +-
.../org/apache/phoenix/schema/DelegateTable.java | 10 +
.../org/apache/phoenix/schema/MetaDataClient.java | 383 ++-
.../java/org/apache/phoenix/schema/PTable.java | 14 +-
.../java/org/apache/phoenix/schema/PTableImpl.java | 51 +-
.../org/apache/phoenix/schema/TableProperty.java | 22 +
.../phoenix/schema/task/SystemTaskParams.java | 188 ++
.../java/org/apache/phoenix/schema/task/Task.java | 152 +-
.../transaction/OmidTransactionProvider.java | 8 +-
.../transaction/TephraTransactionContext.java | 1 +
.../java/org/apache/phoenix/util/IndexUtil.java | 154 +-
.../util/MergeViewIndexIdSequencesTool.java | 117 +
.../java/org/apache/phoenix/util/MetaDataUtil.java | 23 +
.../org/apache/phoenix/util/ParseNodeUtil.java | 45 +
.../org/apache/phoenix/util/SQLCloseables.java | 3 +
.../java/org/apache/phoenix/util/ScanUtil.java | 350 ++-
.../java/org/apache/phoenix/util/SchemaUtil.java | 12 +-
.../phoenix/util/TaskMetaDataServiceCallBack.java | 67 +
.../java/org/apache/phoenix/util/UpgradeUtil.java | 427 ++--
.../phoenix/util/ViewIndexIdRetrieveUtil.java | 66 +
.../java/org/apache/phoenix/util/ViewUtil.java | 30 +-
.../org/apache/phoenix/util/WALAnnotationUtil.java | 74 +
.../phoenix/compile/JoinQueryCompilerTest.java | 48 +-
.../apache/phoenix/compile/QueryCompilerTest.java | 337 ++-
.../apache/phoenix/compile/QueryOptimizerTest.java | 4 +-
.../coprocessor/TaskMetaDataEndpointTest.java | 187 ++
.../UngroupedAggregateRegionObserverTest.java | 58 +
.../phoenix/iterate/ConcatResultIteratorTest.java | 8 +
.../iterate/MaterializedResultIterators.java | 7 +
.../iterate/MergeSortResultIteratorTest.java | 17 +
.../DefaultMultiViewSplitStrategyTest.java | 110 +
.../mapreduce/PhoenixMultiViewInputFormatTest.java | 86 +
.../mapreduce/PhoenixMultiViewReaderTest.java | 86 +
.../phoenix/mapreduce/PhoenixTTLToolTest.java | 81 +
.../java/org/apache/phoenix/query/BaseTest.java | 19 +-
.../query/ConnectionQueryServicesImplTest.java | 42 +
.../apache/phoenix/query/PhoenixTestBuilder.java | 705 +++++-
.../apache/phoenix/schema/MetaDataClientTest.java | 7 +
.../org/apache/phoenix/util/MetaDataUtilTest.java | 27 +-
.../java/org/apache/phoenix/util/ScanUtilTest.java | 106 +-
.../java/org/apache/phoenix/util/TestDDLUtil.java | 107 +
.../java/org/apache/phoenix/util/TestUtil.java | 505 ++--
phoenix-hbase-compat-1.3.0/pom.xml | 44 +-
.../compat/hbase/HbaseCompatCapabilities.java | 3 +
.../coprocessor/CompatIndexRegionObserver.java | 49 +
phoenix-hbase-compat-1.4.0/pom.xml | 44 +-
.../compat/hbase/HbaseCompatCapabilities.java | 4 +
.../coprocessor/CompatIndexRegionObserver.java | 48 +
phoenix-hbase-compat-1.5.0/pom.xml | 45 +-
.../compat/hbase/HbaseCompatCapabilities.java | 3 +
.../coprocessor/CompatIndexRegionObserver.java | 22 +-
phoenix-protocol/src/main/MetaDataService.proto | 2 +
phoenix-protocol/src/main/PTable.proto | 2 +
.../src/main/ServerCachingService.proto | 1 +
.../{PSchema.proto => TaskMetaDataService.proto} | 14 +-
.../phoenix/schema/SchemaExtractionProcessor.java | 7 +-
.../src/main/webapp/js/lib/angular.js | 4 +-
pom.xml | 97 +-
270 files changed, 21187 insertions(+), 5693 deletions(-)
delete mode 100644 phoenix-assembly/src/build/src.xml
delete mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/AlterParentTableWithSysCatRollbackIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/BackwardCompatibilityForSplittableSyscatIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/BackwardCompatibilityTestUtil.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentUpsertsWithoutIndexedColsIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/DefaultPhoenixMultiViewListProviderIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/MergeViewIndexIdSequencesToolIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/PhoenixTTLToolIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/PointInTimeScanQueryIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/SyncUpdateCacheFreqIT.java
delete mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/SystemCatalogIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/SystemCatalogRollbackEnabledIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/UpgradeNamespaceIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/ViewConcurrencyAndFailureIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/ViewIndexIdRetrieveIT.java
create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/WALAnnotationIT.java
copy phoenix-core/src/it/resources/gold_files/{gold_query_add_delete.txt => gold_query_delete.txt} (94%)
copy phoenix-core/src/it/resources/gold_files/{gold_query_add_delete.txt => gold_query_delete_for_splitable_syscat.txt} (94%)
copy phoenix-core/src/{main/java/org/apache/phoenix/log/LogLevel.java => it/resources/gold_files/gold_query_index_rebuild_async.txt} (87%)
copy phoenix-core/src/it/resources/gold_files/{gold_query_add_delete.txt => gold_query_select_and_drop_table.txt} (94%)
copy phoenix-core/src/it/resources/gold_files/{gold_query_add_delete.txt => gold_query_view_index.txt} (95%)
copy phoenix-core/src/it/{java/org/apache/phoenix/end2end/SplitSystemCatalogTests.java => resources/sql_files/add_view_index.sql} (67%)
copy phoenix-core/src/it/resources/sql_files/{query_create_diverged_view.sql => create_tmp_table.sql} (80%)
copy phoenix-core/src/it/{java/org/apache/phoenix/end2end/SplitSystemCatalogTests.java => resources/sql_files/index_rebuild_async.sql} (66%)
copy phoenix-core/src/it/resources/sql_files/{query_add_delete.sql => query_delete.sql} (84%)
copy phoenix-core/src/it/resources/sql_files/{query_add_delete.sql => query_delete_for_splitable_syscat.sql} (76%)
copy phoenix-core/src/{main/java/org/apache/phoenix/log/LogLevel.java => it/resources/sql_files/query_index_rebuild_async.sql} (89%)
copy phoenix-core/src/{main/java/org/apache/phoenix/expression/BaseDecimalAddSubtractExpression.java => it/resources/sql_files/query_select_and_drop_table.sql} (85%)
copy phoenix-core/src/{main/java/org/apache/phoenix/expression/BaseDecimalAddSubtractExpression.java => it/resources/sql_files/query_view_index.sql} (85%)
copy phoenix-core/src/main/java/org/apache/{phoenix/parse/UnaryParseNode.java => hadoop/hbase/PhoenixTagType.java} (69%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/compile/ExplainPlanAttributes.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/PhoenixTTLRegionObserver.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/SystemCatalogRegionObserver.java
copy phoenix-core/src/main/java/org/apache/phoenix/coprocessor/{ChildLinkMetaDataEndpoint.java => TaskMetaDataEndpoint.java} (60%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionScanner.java
copy phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/{ChildLinkMetaDataProtos.java => TaskMetaDataProtos.java} (72%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/metrics/MetricsPhoenixCoprocessorSourceFactory.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/metrics/MetricsPhoenixTTLSource.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/metrics/MetricsPhoenixTTLSourceImpl.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/filter/SystemCatalogViewIndexIdFilter.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixMultiViewInputFormat.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixMultiViewInputSplit.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixMultiViewReader.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixTTLDeleteJobMapper.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixTTLTool.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/DefaultMultiViewJobStatusTracker.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/DefaultMultiViewSplitStrategy.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/DefaultPhoenixMultiViewListProvider.java
copy phoenix-core/src/main/java/org/apache/{hadoop/hbase/ipc/RpcUtil.java => phoenix/mapreduce/util/MultiViewJobStatusTracker.java} (72%)
copy phoenix-core/src/main/java/org/apache/phoenix/{parse/UDFParseNode.java => mapreduce/util/MultiViewSplitStrategy.java} (75%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMultiInputUtil.java
copy phoenix-core/src/main/java/org/apache/phoenix/{hbase/index/covered/update/IndexedColumnGroup.java => mapreduce/util/PhoenixMultiViewListProvider.java} (79%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/ViewInfoTracker.java
copy phoenix-core/src/main/java/org/apache/phoenix/{hbase/index/builder/BaseIndexCodec.java => mapreduce/util/ViewInfoWritable.java} (51%)
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/query/ChildLinkMetaDataServiceCallBack.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/schema/task/SystemTaskParams.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/util/MergeViewIndexIdSequencesTool.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/util/TaskMetaDataServiceCallBack.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/util/ViewIndexIdRetrieveUtil.java
create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/util/WALAnnotationUtil.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/coprocessor/TaskMetaDataEndpointTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserverTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/mapreduce/DefaultMultiViewSplitStrategyTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixMultiViewInputFormatTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixMultiViewReaderTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/mapreduce/PhoenixTTLToolTest.java
create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/util/TestDDLUtil.java
create mode 100644 phoenix-hbase-compat-1.3.0/src/main/java/org/apache/phoenix/compat/hbase/coprocessor/CompatIndexRegionObserver.java
create mode 100644 phoenix-hbase-compat-1.4.0/src/main/java/org/apache/phoenix/compat/hbase/coprocessor/CompatIndexRegionObserver.java
copy phoenix-core/src/main/java/org/apache/hadoop/hbase/regionserver/LocalIndexSplitter.java => phoenix-hbase-compat-1.5.0/src/main/java/org/apache/phoenix/compat/hbase/coprocessor/CompatIndexRegionObserver.java (56%)
copy phoenix-protocol/src/main/{PSchema.proto => TaskMetaDataService.proto} (78%)