This is an automated email from the ASF dual-hosted git repository. pboado pushed a change to branch 5.x-cdh6 in repository https://gitbox.apache.org/repos/asf/phoenix.git.
from 16248b3 PHOENIX-4956 Distribution of Apache Phoenix 5.1 for CDH 6.1 new e62d061 PHOENIX-5089 Add tenantId parameter to IndexScrunityTool new aef34e6 PHOENIX-374 Enable access to dynamic columns in * or cf.* selection (Addendum) new d066f40 PHOENIX-5141 Use HBaseFactoryProvider.getConfigurationFactory to get the config in PhoenixRDD (addendum) new c9447c6 PHOENIX-5141 Use HBaseFactoryProvider.getConfigurationFactory (addendum) new e899c3b PHOENIX-5141 Use HBaseFactoryProvider.getConfigurationFactory (addendum) new 597ee03 PHOENIX-2265 Disallow creation of view over HBase table if PK not specified new 8348457 PHOENIX-4345 Error message for incorrect index is not accurate new 855cb66 PHOENIX-5063 Create a new repo for the phoenix query server (#422) new 57df4c8 PHOENIX-5063 Create a new repo for the phoenix query server (#454) new 4cb9269 PHOENIX-4929 IndexOutOfBoundsException when casting timestamp to date new 3c2b20b PHOENIX-5122: PHOENIX-4322 breaks client backward compatibility new ee22c65 PHOENIX-5175 Separate client settings for disabling server side mutations for upserts and deletes new 3b52902 PHOENIX-5182: Deprecate getTotalSum API of the GlobalMetric interface new 1468979 PHOENIX-5178 SYSTEM schema is not getting cached at MetaData server new e612d97 PHOENIX-5178 SYSTEM schema is not getting cached at MetaData server(addendum) new ae45a00 PHOENIX-5188 IndexedKeyValue should populate KeyValue fields new 61924e5 PHOENIX-5196 Fix rat check in pre commit new a26f6fc PHOENIX-5185 support Math PI function (#461) new b6ce5c0 PHOENIX-5131 Make spilling to disk for order/group by configurable new 3920a21 PHOENIX-5148 Improve OrderPreservingTracker to optimize OrderBy/GroupBy for ClientScanPlan and ClientAggregatePlan new 814999c PHOENIX-5062 Create a new repo for the phoenix connectors new cfaea97 PHOENIX-4900 Modify MAX_MUTATION_SIZE_EXCEEDED and MAX_MUTATION_SIZE_BYTES_EXCEEDED exception message to recommend turning autocommit on for deletes new 02ec040 PHOENIX-5184 HBase and Phoenix connection leaks in Indexing code path, OrphanViewTool and PhoenixConfigurationUtil new 5171199 PHOENIX-5172 Harden the PQS canary synth test tool with retry mechanism and more logging new 2ddfa02 PHOENIX-1614 ALTER TABLE ADD IF NOT EXISTS doesn't work as expected new 4a7cc09 PHOENIX-5180 Add API to PhoenixRunTime to get ptable of a tenant using a global connection new 263245f PHOENIX-5062 Create a new repo for the phoenix connectors (addendum) new fabe30d PHOENIX-5207 Create index if not exists fails incorrectly if table has 'maxIndexesPerTable' indexes already new fe6e767 PHOENIX-5219 Fix ConcurrentMutationsIT testLockUntilMVCCAdvanced and testRowLockDuringPreBatchMutateWhenIndexed failures on the master branch new d3e5aef PHOENIX-5169 Query logger is still initialized for each query if the log level is off new 8a5879d PHOENIX-5169 Query logger is still initialized for each query if the log level is off(addendum) new 6419394 PHOENIX-5101 ScanningResultIterator getScanMetrics throws NPE new 8cedf24 PHOENIX-5190 Implement TaskRegionObserver for Index rebuild new 1d8240f PHOENIX-4956 Distribution of Apache Phoenix 5.1 for CDH 6.1 (addendum) The 34 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: bin/omid-server-configuration.yml | 16 + phoenix-assembly/pom.xml | 28 - phoenix-client/pom.xml | 18 - .../org/apache/phoenix/end2end/AlterTableIT.java | 43 +- .../org/apache/phoenix/end2end/DateTimeIT.java | 28 + .../java/org/apache/phoenix/end2end/DeleteIT.java | 32 +- .../org/apache/phoenix/end2end/DerivedTableIT.java | 2002 +++++++++--------- .../phoenix/end2end/DropTableWithViewsIT.java | 37 +- .../end2end/GlobalConnectionTenantTableIT.java | 188 ++ .../phoenix/end2end/IndexBuildTimestampIT.java | 3 +- .../apache/phoenix/end2end/IndexRebuildTaskIT.java | 176 ++ .../phoenix/end2end/IndexScrutinyToolIT.java | 1398 +++++++------ .../phoenix/end2end/LnLogFunctionEnd2EndIT.java | 16 - .../phoenix/end2end/MathPIFunctionEnd2EndIT.java | 61 + .../apache/phoenix/end2end/MutationStateIT.java | 50 +- .../java/org/apache/phoenix/end2end/OrderByIT.java | 193 ++ ...OrderByWithServerClientSpoolingDisabledIT.java} | 17 +- .../end2end/OrderByWithServerMemoryLimitIT.java | 81 + .../phoenix/end2end/OrderByWithSpillingIT.java | 3 +- .../phoenix/end2end/PowerFunctionEnd2EndIT.java | 16 - .../org/apache/phoenix/end2end/QueryLoggerIT.java | 22 +- .../phoenix/end2end/SortMergeJoinMoreIT.java | 126 +- .../phoenix/end2end/SpooledTmpFileDeleteIT.java | 2 +- .../phoenix/end2end/SystemTablePermissionsIT.java | 43 + .../phoenix/end2end/UpsertSelectAutoCommitIT.java | 15 +- .../org/apache/phoenix/end2end/UpsertSelectIT.java | 65 +- .../it/java/org/apache/phoenix/end2end/ViewIT.java | 51 +- .../apache/phoenix/end2end/index/BaseIndexIT.java | 37 + .../apache/phoenix/end2end/index/IndexUsageIT.java | 40 + .../end2end/join/SortMergeJoinGlobalIndexIT.java | 3 +- .../end2end/join/SortMergeJoinLocalIndexIT.java | 3 +- .../end2end/join/SortMergeJoinNoSpoolingIT.java | 83 + .../end2end/join/SubqueryUsingSortMergeJoinIT.java | 26 +- .../apache/phoenix/execute/PartialCommitIT.java | 3 +- .../monitoring/PhoenixMetricsDisabledIT.java | 2 +- .../phoenix/monitoring/PhoenixMetricsIT.java | 100 +- .../phoenix/compile/CreateTableCompiler.java | 17 + .../org/apache/phoenix/compile/DeleteCompiler.java | 4 +- .../apache/phoenix/compile/ExpressionCompiler.java | 19 +- .../org/apache/phoenix/compile/FromCompiler.java | 12 +- .../apache/phoenix/compile/GroupByCompiler.java | 35 +- .../apache/phoenix/compile/ListJarsQueryPlan.java | 5 + .../apache/phoenix/compile/OrderByCompiler.java | 104 +- .../phoenix/compile/OrderPreservingTracker.java | 556 +++-- .../org/apache/phoenix/compile/QueryCompiler.java | 90 +- .../java/org/apache/phoenix/compile/QueryPlan.java | 20 +- .../compile/StatelessExpressionCompiler.java | 57 + .../org/apache/phoenix/compile/TraceQueryPlan.java | 5 + .../org/apache/phoenix/compile/UnionCompiler.java | 2 +- .../org/apache/phoenix/compile/UpsertCompiler.java | 4 +- .../phoenix/coprocessor/MetaDataEndpointImpl.java | 10 +- .../phoenix/coprocessor/MetaDataProtocol.java | 7 + .../phoenix/coprocessor/ScanRegionObserver.java | 4 +- .../phoenix/coprocessor/TaskRegionObserver.java | 293 ++- .../UngroupedAggregateRegionObserver.java | 22 +- .../apache/phoenix/coprocessor/tasks/BaseTask.java | 17 + .../coprocessor/tasks/DropChildViewsTask.java | 81 + .../coprocessor/tasks/IndexRebuildTask.java | 151 ++ .../apache/phoenix/exception/SQLExceptionCode.java | 15 +- .../org/apache/phoenix/execute/AggregatePlan.java | 61 +- .../phoenix/execute/ClientAggregatePlan.java | 61 +- .../org/apache/phoenix/execute/ClientScanPlan.java | 38 +- .../apache/phoenix/execute/CursorFetchPlan.java | 6 +- .../apache/phoenix/execute/DelegateQueryPlan.java | 5 + .../execute/LiteralResultIterationPlan.java | 5 + .../java/org/apache/phoenix/execute/ScanPlan.java | 34 +- .../apache/phoenix/execute/SortMergeJoinPlan.java | 253 +-- .../phoenix/execute/TupleProjectionPlan.java | 112 +- .../java/org/apache/phoenix/execute/UnionPlan.java | 13 + .../apache/phoenix/execute/UnnestArrayPlan.java | 7 + .../apache/phoenix/expression/ExpressionType.java | 1 + .../phoenix/expression/OrderByExpression.java | 85 +- .../expression/RowValueConstructorExpression.java | 53 +- ...tValueBaseFunction.java => MathPIFunction.java} | 45 +- .../org/apache/phoenix/hbase/index/Indexer.java | 9 +- .../phoenix/hbase/index/util/VersionUtil.java | 12 + .../phoenix/hbase/index/wal/IndexedKeyValue.java | 25 + .../hbase/index/write/RecoveryIndexWriter.java | 30 +- .../org/apache/phoenix/iterate/BufferedQueue.java | 20 +- .../phoenix/iterate/BufferedSortedQueue.java | 33 +- .../apache/phoenix/iterate/BufferedTupleQueue.java | 134 ++ .../iterate/NonAggregateRegionScannerFactory.java | 45 +- .../iterate/OrderedAggregatingResultIterator.java | 5 +- .../phoenix/iterate/OrderedResultIterator.java | 72 +- .../org/apache/phoenix/iterate/PhoenixQueues.java | 96 + .../phoenix/iterate/ScanningResultIterator.java | 85 +- .../org/apache/phoenix/iterate/SizeAwareQueue.java | 11 +- .../org/apache/phoenix/iterate/SizeBoundQueue.java | 96 + .../phoenix/iterate/SpoolingResultIterator.java | 5 +- .../phoenix/jdbc/PhoenixDatabaseMetaData.java | 5 + .../org/apache/phoenix/jdbc/PhoenixStatement.java | 10 + .../phoenix/mapreduce/AbstractBulkLoadTool.java | 114 +- .../apache/phoenix/mapreduce/OrphanViewTool.java | 73 +- .../phoenix/mapreduce/PhoenixRecordWriter.java | 18 +- .../mapreduce/index/DirectHTableWriter.java | 19 +- .../mapreduce/index/IndexScrutinyMapper.java | 25 +- .../mapreduce/index/IndexScrutinyTableOutput.java | 1 + .../phoenix/mapreduce/index/IndexScrutinyTool.java | 61 +- .../apache/phoenix/mapreduce/index/IndexTool.java | 148 +- .../index/PhoenixIndexImportDirectMapper.java | 26 +- .../index/PhoenixIndexImportDirectReducer.java | 43 + .../mapreduce/index/PhoenixIndexImportMapper.java | 16 +- .../index/PhoenixIndexPartialBuildMapper.java | 25 +- .../phoenix/mapreduce/util/IndexColumnNames.java | 3 + .../mapreduce/util/PhoenixConfigurationUtil.java | 45 +- .../apache/phoenix/monitoring/GlobalMetric.java | 1 + .../phoenix/query/ConnectionQueryServicesImpl.java | 30 +- .../org/apache/phoenix/query/QueryConstants.java | 6 + .../org/apache/phoenix/query/QueryServices.java | 14 +- .../apache/phoenix/query/QueryServicesOptions.java | 22 +- ...dException.java => IndexNotFoundException.java} | 35 +- .../org/apache/phoenix/schema/MetaDataClient.java | 38 +- .../java/org/apache/phoenix/schema/PTable.java | 26 +- .../java/org/apache/phoenix/schema/PTableImpl.java | 4 +- .../phoenix/schema/TableNotFoundException.java | 4 + .../java/org/apache/phoenix/schema/task/Task.java | 369 ++++ .../org/apache/phoenix/tool/PhoenixCanaryTool.java | 212 +- .../org/apache/phoenix/util/ExpressionUtil.java | 294 +++ .../org/apache/phoenix/util/PhoenixRuntime.java | 68 +- .../regionserver/wal/IndexedKeyValueTest.java | 66 + .../apache/phoenix/compile/QueryCompilerTest.java | 458 +++++ .../apache/phoenix/expression/ExpFunctionTest.java | 19 +- .../phoenix/expression/LnLogFunctionTest.java | 23 +- .../MathPIFunctionTest.java} | 32 +- .../phoenix/expression/PowerFunctionTest.java | 22 +- .../phoenix/expression/SqrtFunctionTest.java | 20 +- .../phoenix/iterate/OrderedResultIteratorTest.java | 55 +- .../java/org/apache/phoenix/query/BaseTest.java | 17 +- .../phoenix/query/ParallelIteratorsSplitTest.java | 6 +- .../phoenix/query/QueryServicesTestImpl.java | 3 +- .../tool/ParameterizedPhoenixCanaryToolIT.java | 280 +++ .../apache/phoenix/tool/PhoenixCanaryToolTest.java | 53 +- .../org/apache/phoenix/util/MetaDataUtilTest.java | 10 +- .../resources/phoenix-canary-file-sink.properties | 13 +- phoenix-flume/pom.xml | 203 -- .../apache/phoenix/flume/CsvEventSerializerIT.java | 416 ---- .../phoenix/flume/JsonEventSerializerIT.java | 541 ----- .../org/apache/phoenix/flume/PhoenixSinkIT.java | 272 --- .../phoenix/flume/RegexEventSerializerIT.java | 417 ---- .../phoenix/flume/serializer/CustomSerializer.java | 43 - .../apache/phoenix/flume/sink/NullPhoenixSink.java | 21 - .../apache/phoenix/flume/DefaultKeyGenerator.java | 69 - .../org/apache/phoenix/flume/FlumeConstants.java | 94 - .../org/apache/phoenix/flume/SchemaHandler.java | 47 - .../flume/serializer/BaseEventSerializer.java | 245 --- .../flume/serializer/CsvEventSerializer.java | 196 -- .../phoenix/flume/serializer/EventSerializer.java | 42 - .../phoenix/flume/serializer/EventSerializers.java | 36 - .../flume/serializer/JsonEventSerializer.java | 226 -- .../flume/serializer/RegexEventSerializer.java | 145 -- .../org/apache/phoenix/flume/sink/PhoenixSink.java | 212 -- phoenix-hive/pom.xml | 294 --- .../org/apache/hadoop/hive/llap/LlapItUtils.java | 90 - .../hadoop/hive/ql/QTestProcessExecResult.java | 66 - .../java/org/apache/hadoop/hive/ql/QTestUtil.java | 2173 -------------------- .../org/apache/hadoop/hive/ql/WindowsPathUtil.java | 57 - .../hive/ql/security/DummyAuthenticator.java | 70 - .../phoenix/hive/BaseHivePhoenixStoreIT.java | 180 -- .../org/apache/phoenix/hive/HiveMapReduceIT.java | 63 - .../apache/phoenix/hive/HivePhoenixStoreIT.java | 344 ---- .../java/org/apache/phoenix/hive/HiveTestUtil.java | 40 - .../it/java/org/apache/phoenix/hive/HiveTezIT.java | 34 - .../org/apache/phoenix/hive/PhoenixMetaHook.java | 229 --- .../apache/phoenix/hive/PhoenixRecordUpdater.java | 336 --- .../java/org/apache/phoenix/hive/PhoenixRow.java | 64 - .../org/apache/phoenix/hive/PhoenixRowKey.java | 62 - .../java/org/apache/phoenix/hive/PhoenixSerDe.java | 152 -- .../org/apache/phoenix/hive/PhoenixSerializer.java | 173 -- .../apache/phoenix/hive/PhoenixStorageHandler.java | 276 --- .../org/apache/phoenix/hive/PrimaryKeyData.java | 88 - .../constants/PhoenixStorageHandlerConstants.java | 108 - .../phoenix/hive/mapreduce/PhoenixInputFormat.java | 271 --- .../phoenix/hive/mapreduce/PhoenixInputSplit.java | 160 -- .../hive/mapreduce/PhoenixOutputFormat.java | 112 - .../hive/mapreduce/PhoenixRecordReader.java | 217 -- .../hive/mapreduce/PhoenixRecordWriter.java | 356 ---- .../hive/mapreduce/PhoenixResultWritable.java | 217 -- .../AbstractPhoenixObjectInspector.java | 59 - .../PhoenixBinaryObjectInspector.java | 58 - .../PhoenixBooleanObjectInspector.java | 55 - .../PhoenixByteObjectInspector.java | 59 - .../PhoenixCharObjectInspector.java | 56 - .../PhoenixDateObjectInspector.java | 63 - .../PhoenixDecimalObjectInspector.java | 72 - .../PhoenixDoubleObjectInspector.java | 59 - .../PhoenixFloatObjectInspector.java | 60 - .../objectinspector/PhoenixIntObjectInspector.java | 62 - .../PhoenixListObjectInspector.java | 105 - .../PhoenixLongObjectInspector.java | 56 - .../PhoenixObjectInspectorFactory.java | 148 -- .../PhoenixShortObjectInspector.java | 56 - .../PhoenixStringObjectInspector.java | 72 - .../PhoenixTimestampObjectInspector.java | 61 - .../hive/ppd/PhoenixPredicateDecomposer.java | 95 - .../hive/ql/index/IndexPredicateAnalyzer.java | 521 ----- .../hive/ql/index/IndexSearchCondition.java | 143 -- .../hive/ql/index/PredicateAnalyzerFactory.java | 40 - .../phoenix/hive/query/PhoenixQueryBuilder.java | 849 -------- .../phoenix/hive/util/ColumnMappingUtils.java | 76 - .../phoenix/hive/util/PhoenixConnectionUtil.java | 119 -- .../hive/util/PhoenixStorageHandlerUtil.java | 321 --- .../org/apache/phoenix/hive/util/PhoenixUtil.java | 210 -- .../apache/phoenix/hive/PrimaryKeyDataTest.java | 79 - .../hive/query/PhoenixQueryBuilderTest.java | 173 -- phoenix-hive/src/test/resources/hive-site.xml | 123 -- phoenix-hive/src/test/resources/tez-site.xml | 69 - phoenix-kafka/pom.xml | 421 ---- .../apache/phoenix/kafka/PhoenixConsumerIT.java | 279 --- phoenix-kafka/src/it/resources/consumer.props | 32 - .../org/apache/phoenix/kafka/KafkaConstants.java | 52 - .../phoenix/kafka/consumer/PhoenixConsumer.java | 276 --- .../kafka/consumer/PhoenixConsumerTool.java | 107 - phoenix-load-balancer/pom.xml | 96 - .../phoenix/end2end/LoadBalancerEnd2EndIT.java | 144 -- .../service/LoadBalanceZookeeperConfImpl.java | 103 - .../phoenix/loadbalancer/service/LoadBalancer.java | 178 -- .../queryserver/register/ZookeeperRegistry.java | 72 - ...x.loadbalancer.service.LoadBalanceZookeeperConf | 1 - ...rg.apache.phoenix.queryserver.register.Registry | 1 - phoenix-parcel/pom.xml | 12 - .../src/build/components/all-common-jars.xml | 150 -- phoenix-pig/pom.xml | 463 ----- .../it/java/org/apache/phoenix/pig/BasePigIT.java | 87 - .../apache/phoenix/pig/PhoenixHBaseLoaderIT.java | 838 -------- .../apache/phoenix/pig/PhoenixHBaseStorerIT.java | 292 --- .../phoenix/pig/udf/ReserveNSequenceTestIT.java | 306 --- .../org/apache/phoenix/pig/PhoenixHBaseLoader.java | 265 --- .../apache/phoenix/pig/PhoenixHBaseStorage.java | 236 --- .../apache/phoenix/pig/udf/ReserveNSequence.java | 129 -- .../phoenix/pig/util/PhoenixPigSchemaUtil.java | 90 - .../pig/util/QuerySchemaParserFunction.java | 118 -- .../pig/util/SqlQueryToColumnInfoFunction.java | 82 - .../pig/util/TableSchemaParserFunction.java | 52 - .../java/org/apache/phoenix/pig/util/TypeUtil.java | 349 ---- .../phoenix/pig/util/PhoenixPigSchemaUtilTest.java | 92 - .../pig/util/QuerySchemaParserFunctionTest.java | 97 - .../pig/util/SqlQueryToColumnInfoFunctionTest.java | 63 - .../pig/util/TableSchemaParserFunctionTest.java | 54 - .../org/apache/phoenix/pig/util/TypeUtilTest.java | 83 - phoenix-queryserver-client/pom.xml | 203 -- .../apache/phoenix/queryserver/client/Driver.java | 49 - .../phoenix/queryserver/client/SqllineWrapper.java | 97 - .../phoenix/queryserver/client/ThinClientUtil.java | 42 - .../resources/META-INF/services/java.sql.Driver | 1 - .../org-apache-phoenix-remote-jdbc.properties | 25 - phoenix-queryserver/pom.xml | 225 -- .../src/build/query-server-runnable.xml | 52 - phoenix-queryserver/src/it/bin/test_phoenixdb.py | 39 - phoenix-queryserver/src/it/bin/test_phoenixdb.sh | 79 - .../HttpParamImpersonationQueryServerIT.java | 438 ---- .../phoenix/end2end/QueryServerBasicsIT.java | 346 ---- .../phoenix/end2end/QueryServerTestUtil.java | 187 -- .../apache/phoenix/end2end/QueryServerThread.java | 45 - .../phoenix/end2end/SecureQueryServerIT.java | 323 --- .../end2end/SecureQueryServerPhoenixDBIT.java | 424 ---- .../phoenix/end2end/ServerCustomizersIT.java | 149 -- .../src/it/resources/log4j.properties | 68 - .../service/LoadBalanceZookeeperConf.java | 42 - .../phoenix/queryserver/register/Registry.java | 48 - .../server/AvaticaServerConfigurationFactory.java | 37 - .../queryserver/server/PhoenixMetaFactory.java | 28 - .../queryserver/server/PhoenixMetaFactoryImpl.java | 76 - .../phoenix/queryserver/server/QueryServer.java | 606 ------ .../server/RemoteUserExtractorFactory.java | 36 - .../server/ServerCustomizersFactory.java | 52 - .../org/apache/phoenix/DriverCohabitationTest.java | 65 - .../CustomAvaticaServerConfigurationTest.java | 37 - .../server/PhoenixDoAsCallbackTest.java | 89 - .../server/PhoenixRemoteUserExtractorTest.java | 108 - .../server/QueryServerConfigurationTest.java | 92 - .../server/RemoteUserExtractorFactoryTest.java | 35 - .../queryserver/server/ServerCustomizersTest.java | 92 - phoenix-spark/README.md | 164 -- phoenix-spark/pom.xml | 607 ------ .../java/org/apache/phoenix/spark/AggregateIT.java | 91 - .../java/org/apache/phoenix/spark/OrderByIT.java | 432 ---- .../org/apache/phoenix/spark/SaltedTableIT.java | 53 - .../java/org/apache/phoenix/spark/SparkUtil.java | 80 - phoenix-spark/src/it/resources/globalSetup.sql | 64 - phoenix-spark/src/it/resources/hbase-site.xml | 40 - phoenix-spark/src/it/resources/log4j.xml | 70 - phoenix-spark/src/it/resources/tenantSetup.sql | 18 - .../phoenix/spark/AbstractPhoenixSparkIT.scala | 117 -- .../org/apache/phoenix/spark/PhoenixSparkIT.scala | 733 ------- .../spark/PhoenixSparkITTenantSpecific.scala | 135 -- .../org/apache/phoenix/spark/SparkResultSet.java | 1056 ---------- .../spark/datasource/v2/PhoenixDataSource.java | 82 - .../v2/reader/PhoenixDataSourceReadOptions.java | 51 - .../v2/reader/PhoenixDataSourceReader.java | 201 -- .../v2/reader/PhoenixInputPartition.java | 44 - .../v2/reader/PhoenixInputPartitionReader.java | 169 -- .../v2/writer/PhoenixDataSourceWriteOptions.java | 109 - .../datasource/v2/writer/PhoenixDataWriter.java | 100 - .../v2/writer/PhoenixDataWriterFactory.java | 19 - .../v2/writer/PhoenixDatasourceWriter.java | 34 - ...org.apache.spark.sql.sources.DataSourceRegister | 1 - .../apache/phoenix/spark/ConfigurationUtil.scala | 97 - .../apache/phoenix/spark/DataFrameFunctions.scala | 79 - .../org/apache/phoenix/spark/DefaultSource.scala | 60 - .../phoenix/spark/FilterExpressionCompiler.scala | 135 -- .../org/apache/phoenix/spark/PhoenixRDD.scala | 150 -- .../phoenix/spark/PhoenixRecordWritable.scala | 115 -- .../org/apache/phoenix/spark/PhoenixRelation.scala | 69 - .../apache/phoenix/spark/ProductRDDFunctions.scala | 64 - .../phoenix/spark/SparkContextFunctions.scala | 42 - .../org/apache/phoenix/spark/SparkSchemaUtil.scala | 84 - .../phoenix/spark/SparkSqlContextFunctions.scala | 42 - .../scala/org/apache/phoenix/spark/package.scala | 36 - .../datasources/jdbc/PhoenixJdbcDialect.scala | 21 - .../execution/datasources/jdbc/SparkJdbcUtil.scala | 309 --- pom.xml | 13 - 311 files changed, 7726 insertions(+), 32137 deletions(-) create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/GlobalConnectionTenantTableIT.java create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexRebuildTaskIT.java create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/MathPIFunctionEnd2EndIT.java copy phoenix-core/src/it/java/org/apache/phoenix/end2end/{OrderByWithSpillingIT.java => OrderByWithServerClientSpoolingDisabledIT.java} (66%) create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/OrderByWithServerMemoryLimitIT.java create mode 100644 phoenix-core/src/it/java/org/apache/phoenix/end2end/join/SortMergeJoinNoSpoolingIT.java create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/compile/StatelessExpressionCompiler.java create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/tasks/BaseTask.java create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/tasks/DropChildViewsTask.java create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/coprocessor/tasks/IndexRebuildTask.java copy phoenix-core/src/main/java/org/apache/phoenix/expression/function/{FirstLastValueBaseFunction.java => MathPIFunction.java} (61%) create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/iterate/BufferedTupleQueue.java create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/iterate/PhoenixQueues.java rename phoenix-flume/src/main/java/org/apache/phoenix/flume/KeyGenerator.java => phoenix-core/src/main/java/org/apache/phoenix/iterate/SizeAwareQueue.java (81%) create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/iterate/SizeBoundQueue.java copy phoenix-core/src/main/java/org/apache/phoenix/schema/{TableNotFoundException.java => IndexNotFoundException.java} (52%) create mode 100644 phoenix-core/src/main/java/org/apache/phoenix/schema/task/Task.java create mode 100644 phoenix-core/src/test/java/org/apache/hadoop/hbase/regionserver/wal/IndexedKeyValueTest.java copy phoenix-core/src/test/java/org/apache/phoenix/{util/LikeExpressionTest.java => expression/MathPIFunctionTest.java} (55%) create mode 100644 phoenix-core/src/test/java/org/apache/phoenix/tool/ParameterizedPhoenixCanaryToolIT.java rename phoenix-kafka/src/it/resources/producer.props => phoenix-core/src/test/resources/phoenix-canary-file-sink.properties (64%) delete mode 100644 phoenix-flume/pom.xml delete mode 100644 phoenix-flume/src/it/java/org/apache/phoenix/flume/CsvEventSerializerIT.java delete mode 100644 phoenix-flume/src/it/java/org/apache/phoenix/flume/JsonEventSerializerIT.java delete mode 100644 phoenix-flume/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java delete mode 100644 phoenix-flume/src/it/java/org/apache/phoenix/flume/RegexEventSerializerIT.java delete mode 100644 phoenix-flume/src/it/java/org/apache/phoenix/flume/serializer/CustomSerializer.java delete mode 100644 phoenix-flume/src/it/java/org/apache/phoenix/flume/sink/NullPhoenixSink.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/DefaultKeyGenerator.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/FlumeConstants.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/SchemaHandler.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/BaseEventSerializer.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/CsvEventSerializer.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/EventSerializer.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/EventSerializers.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/JsonEventSerializer.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/RegexEventSerializer.java delete mode 100644 phoenix-flume/src/main/java/org/apache/phoenix/flume/sink/PhoenixSink.java delete mode 100644 phoenix-hive/pom.xml delete mode 100644 phoenix-hive/src/it/java/org/apache/hadoop/hive/llap/LlapItUtils.java delete mode 100644 phoenix-hive/src/it/java/org/apache/hadoop/hive/ql/QTestProcessExecResult.java delete mode 100644 phoenix-hive/src/it/java/org/apache/hadoop/hive/ql/QTestUtil.java delete mode 100644 phoenix-hive/src/it/java/org/apache/hadoop/hive/ql/WindowsPathUtil.java delete mode 100644 phoenix-hive/src/it/java/org/apache/hadoop/hive/ql/security/DummyAuthenticator.java delete mode 100644 phoenix-hive/src/it/java/org/apache/phoenix/hive/BaseHivePhoenixStoreIT.java delete mode 100644 phoenix-hive/src/it/java/org/apache/phoenix/hive/HiveMapReduceIT.java delete mode 100644 phoenix-hive/src/it/java/org/apache/phoenix/hive/HivePhoenixStoreIT.java delete mode 100644 phoenix-hive/src/it/java/org/apache/phoenix/hive/HiveTestUtil.java delete mode 100644 phoenix-hive/src/it/java/org/apache/phoenix/hive/HiveTezIT.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixMetaHook.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixRecordUpdater.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixRow.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixRowKey.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixSerDe.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixSerializer.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixStorageHandler.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/PrimaryKeyData.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/constants/PhoenixStorageHandlerConstants.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputFormat.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputSplit.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixOutputFormat.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordReader.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordWriter.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixResultWritable.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBinaryObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBooleanObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixByteObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixCharObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDateObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDecimalObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDoubleObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixFloatObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixIntObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixListObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixLongObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixObjectInspectorFactory.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixShortObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixStringObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixTimestampObjectInspector.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/ppd/PhoenixPredicateDecomposer.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/ql/index/IndexPredicateAnalyzer.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/ql/index/IndexSearchCondition.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/ql/index/PredicateAnalyzerFactory.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/query/PhoenixQueryBuilder.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/util/ColumnMappingUtils.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixConnectionUtil.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixStorageHandlerUtil.java delete mode 100644 phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java delete mode 100644 phoenix-hive/src/test/java/org/apache/phoenix/hive/PrimaryKeyDataTest.java delete mode 100644 phoenix-hive/src/test/java/org/apache/phoenix/hive/query/PhoenixQueryBuilderTest.java delete mode 100644 phoenix-hive/src/test/resources/hive-site.xml delete mode 100644 phoenix-hive/src/test/resources/tez-site.xml delete mode 100644 phoenix-kafka/pom.xml delete mode 100644 phoenix-kafka/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java delete mode 100644 phoenix-kafka/src/it/resources/consumer.props delete mode 100644 phoenix-kafka/src/main/java/org/apache/phoenix/kafka/KafkaConstants.java delete mode 100644 phoenix-kafka/src/main/java/org/apache/phoenix/kafka/consumer/PhoenixConsumer.java delete mode 100644 phoenix-kafka/src/main/java/org/apache/phoenix/kafka/consumer/PhoenixConsumerTool.java delete mode 100644 phoenix-load-balancer/pom.xml delete mode 100644 phoenix-load-balancer/src/it/java/org/apache/phoenix/end2end/LoadBalancerEnd2EndIT.java delete mode 100644 phoenix-load-balancer/src/main/java/org/apache/phoenix/loadbalancer/service/LoadBalanceZookeeperConfImpl.java delete mode 100644 phoenix-load-balancer/src/main/java/org/apache/phoenix/loadbalancer/service/LoadBalancer.java delete mode 100644 phoenix-load-balancer/src/main/java/org/apache/phoenix/queryserver/register/ZookeeperRegistry.java delete mode 100644 phoenix-load-balancer/src/main/resources/META-INF/services/org.apache.phoenix.loadbalancer.service.LoadBalanceZookeeperConf delete mode 100644 phoenix-load-balancer/src/main/resources/META-INF/services/org.apache.phoenix.queryserver.register.Registry delete mode 100644 phoenix-pig/pom.xml delete mode 100644 phoenix-pig/src/it/java/org/apache/phoenix/pig/BasePigIT.java delete mode 100644 phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java delete mode 100644 phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseStorerIT.java delete mode 100644 phoenix-pig/src/it/java/org/apache/phoenix/pig/udf/ReserveNSequenceTestIT.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/PhoenixHBaseLoader.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/PhoenixHBaseStorage.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/util/PhoenixPigSchemaUtil.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/util/QuerySchemaParserFunction.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/util/SqlQueryToColumnInfoFunction.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/util/TableSchemaParserFunction.java delete mode 100644 phoenix-pig/src/main/java/org/apache/phoenix/pig/util/TypeUtil.java delete mode 100644 phoenix-pig/src/test/java/org/apache/phoenix/pig/util/PhoenixPigSchemaUtilTest.java delete mode 100644 phoenix-pig/src/test/java/org/apache/phoenix/pig/util/QuerySchemaParserFunctionTest.java delete mode 100644 phoenix-pig/src/test/java/org/apache/phoenix/pig/util/SqlQueryToColumnInfoFunctionTest.java delete mode 100644 phoenix-pig/src/test/java/org/apache/phoenix/pig/util/TableSchemaParserFunctionTest.java delete mode 100644 phoenix-pig/src/test/java/org/apache/phoenix/pig/util/TypeUtilTest.java delete mode 100644 phoenix-queryserver-client/pom.xml delete mode 100644 phoenix-queryserver-client/src/main/java/org/apache/phoenix/queryserver/client/Driver.java delete mode 100644 phoenix-queryserver-client/src/main/java/org/apache/phoenix/queryserver/client/SqllineWrapper.java delete mode 100644 phoenix-queryserver-client/src/main/java/org/apache/phoenix/queryserver/client/ThinClientUtil.java delete mode 100644 phoenix-queryserver-client/src/main/resources/META-INF/services/java.sql.Driver delete mode 100644 phoenix-queryserver-client/src/main/resources/version/org-apache-phoenix-remote-jdbc.properties delete mode 100644 phoenix-queryserver/pom.xml delete mode 100644 phoenix-queryserver/src/build/query-server-runnable.xml delete mode 100644 phoenix-queryserver/src/it/bin/test_phoenixdb.py delete mode 100755 phoenix-queryserver/src/it/bin/test_phoenixdb.sh delete mode 100644 phoenix-queryserver/src/it/java/org/apache/phoenix/end2end/HttpParamImpersonationQueryServerIT.java delete mode 100644 phoenix-queryserver/src/it/java/org/apache/phoenix/end2end/QueryServerBasicsIT.java delete mode 100644 phoenix-queryserver/src/it/java/org/apache/phoenix/end2end/QueryServerTestUtil.java delete mode 100644 phoenix-queryserver/src/it/java/org/apache/phoenix/end2end/QueryServerThread.java delete mode 100644 phoenix-queryserver/src/it/java/org/apache/phoenix/end2end/SecureQueryServerIT.java delete mode 100644 phoenix-queryserver/src/it/java/org/apache/phoenix/end2end/SecureQueryServerPhoenixDBIT.java delete mode 100644 phoenix-queryserver/src/it/java/org/apache/phoenix/end2end/ServerCustomizersIT.java delete mode 100644 phoenix-queryserver/src/it/resources/log4j.properties delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/loadbalancer/service/LoadBalanceZookeeperConf.java delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/register/Registry.java delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/AvaticaServerConfigurationFactory.java delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/PhoenixMetaFactory.java delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/PhoenixMetaFactoryImpl.java delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/QueryServer.java delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/RemoteUserExtractorFactory.java delete mode 100644 phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/ServerCustomizersFactory.java delete mode 100644 phoenix-queryserver/src/test/java/org/apache/phoenix/DriverCohabitationTest.java delete mode 100644 phoenix-queryserver/src/test/java/org/apache/phoenix/queryserver/server/CustomAvaticaServerConfigurationTest.java delete mode 100644 phoenix-queryserver/src/test/java/org/apache/phoenix/queryserver/server/PhoenixDoAsCallbackTest.java delete mode 100644 phoenix-queryserver/src/test/java/org/apache/phoenix/queryserver/server/PhoenixRemoteUserExtractorTest.java delete mode 100644 phoenix-queryserver/src/test/java/org/apache/phoenix/queryserver/server/QueryServerConfigurationTest.java delete mode 100644 phoenix-queryserver/src/test/java/org/apache/phoenix/queryserver/server/RemoteUserExtractorFactoryTest.java delete mode 100644 phoenix-queryserver/src/test/java/org/apache/phoenix/queryserver/server/ServerCustomizersTest.java delete mode 100644 phoenix-spark/README.md delete mode 100644 phoenix-spark/pom.xml delete mode 100644 phoenix-spark/src/it/java/org/apache/phoenix/spark/AggregateIT.java delete mode 100644 phoenix-spark/src/it/java/org/apache/phoenix/spark/OrderByIT.java delete mode 100644 phoenix-spark/src/it/java/org/apache/phoenix/spark/SaltedTableIT.java delete mode 100644 phoenix-spark/src/it/java/org/apache/phoenix/spark/SparkUtil.java delete mode 100644 phoenix-spark/src/it/resources/globalSetup.sql delete mode 100644 phoenix-spark/src/it/resources/hbase-site.xml delete mode 100644 phoenix-spark/src/it/resources/log4j.xml delete mode 100644 phoenix-spark/src/it/resources/tenantSetup.sql delete mode 100644 phoenix-spark/src/it/scala/org/apache/phoenix/spark/AbstractPhoenixSparkIT.scala delete mode 100644 phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala delete mode 100644 phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkITTenantSpecific.scala delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/SparkResultSet.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/PhoenixDataSource.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixDataSourceReadOptions.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixDataSourceReader.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixInputPartition.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixInputPartitionReader.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataSourceWriteOptions.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataWriter.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataWriterFactory.java delete mode 100644 phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDatasourceWriter.java delete mode 100644 phoenix-spark/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/DefaultSource.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/FilterExpressionCompiler.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRecordWritable.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRelation.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/ProductRDDFunctions.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/SparkContextFunctions.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/SparkSchemaUtil.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/phoenix/spark/package.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/PhoenixJdbcDialect.scala delete mode 100644 phoenix-spark/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/SparkJdbcUtil.scala