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%)