This is an automated email from the ASF dual-hosted git repository.
gjacoby pushed a change to branch PHOENIX-5138-2
in repository https://gitbox.apache.org/repos/asf/phoenix.git.
discard c62b301 PHOENIX-5138 - ViewIndexId sequences created after
PHOENIX-5132 shouldn't collide with ones created before it
add 6e3cb31 PHOENIX-5196 Fix rat check in pre commit
add c73947a PHOENIX-5185 support Math PI function (#461)
add 05b9901 PHOENIX-5131 Make spilling to disk for order/group by
configurable
add dd8789b PHOENIX-5148 Improve OrderPreservingTracker to optimize
OrderBy/GroupBy for ClientScanPlan and ClientAggregatePlan
add 43609f8 PHOENIX-5062 Create a new repo for the phoenix connectors
add 3c7b108 PHOENIX-4900 Modify MAX_MUTATION_SIZE_EXCEEDED and
MAX_MUTATION_SIZE_BYTES_EXCEEDED exception message to recommend turning
autocommit on for deletes
add f256004 PHOENIX-5184: HBase and Phoenix connection leaks in Indexing
code path, OrphanViewTool and PhoenixConfigurationUtil
add c06bb59 PHOENIX-5172: Harden the PQS canary synth test tool with
retry mechanism and more logging
add 69e5bb0 PHOENIX-1614 ALTER TABLE ADD IF NOT EXISTS doesn't work as
expected
new e357c6b PHOENIX-5138 - ViewIndexId sequences created after
PHOENIX-5132 shouldn't collide with ones created before it
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 (c62b301)
\
N -- N -- N refs/heads/PHOENIX-5138-2 (e357c6b)
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.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
bin/omid-server-configuration.yml | 16 +
phoenix-assembly/pom.xml | 16 -
phoenix-client/pom.xml | 18 -
.../org/apache/phoenix/end2end/AlterTableIT.java | 43 +-
.../org/apache/phoenix/end2end/DerivedTableIT.java | 2 -
.../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 -
.../phoenix/end2end/SortMergeJoinMoreIT.java | 126 ++-
.../phoenix/end2end/SpooledTmpFileDeleteIT.java | 2 +-
.../end2end/join/SortMergeJoinGlobalIndexIT.java | 3 +-
.../end2end/join/SortMergeJoinLocalIndexIT.java | 3 +-
.../end2end/join/SortMergeJoinNoSpoolingIT.java | 83 ++
.../end2end/join/SubqueryUsingSortMergeJoinIT.java | 26 +-
.../apache/phoenix/compile/ExpressionCompiler.java | 6 +-
.../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 +-
.../phoenix/coprocessor/MetaDataProtocol.java | 7 +
.../phoenix/coprocessor/ScanRegionObserver.java | 4 +-
.../UngroupedAggregateRegionObserver.java | 22 +-
.../apache/phoenix/exception/SQLExceptionCode.java | 8 +-
.../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 +-
...tValueBaseFunction.java => MathPIFunction.java} | 45 +-
.../phoenix/hbase/index/util/VersionUtil.java | 12 +
.../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 ++
.../org/apache/phoenix/iterate/SizeAwareQueue.java | 11 +-
.../org/apache/phoenix/iterate/SizeBoundQueue.java | 96 ++
.../phoenix/iterate/SpoolingResultIterator.java | 5 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 5 +
.../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 +-
.../apache/phoenix/mapreduce/index/IndexTool.java | 85 +-
.../index/PhoenixIndexImportDirectMapper.java | 26 +-
.../mapreduce/index/PhoenixIndexImportMapper.java | 16 +-
.../index/PhoenixIndexPartialBuildMapper.java | 25 +-
.../mapreduce/util/PhoenixConfigurationUtil.java | 45 +-
.../org/apache/phoenix/query/QueryServices.java | 11 +-
.../apache/phoenix/query/QueryServicesOptions.java | 19 +-
.../org/apache/phoenix/schema/MetaDataClient.java | 29 +-
.../org/apache/phoenix/tool/PhoenixCanaryTool.java | 212 ++--
.../org/apache/phoenix/util/ExpressionUtil.java | 294 ++++++
.../apache/phoenix/compile/QueryCompilerTest.java | 451 +++++++++
.../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 +-
.../apache/phoenix/flume/CsvEventSerializerIT.java | 416 --------
.../phoenix/flume/JsonEventSerializerIT.java | 541 ----------
.../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 ----
.../org/apache/phoenix/hive/PhoenixMetaHook.java | 229 -----
.../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 ----
.../org/apache/phoenix/hive/PrimaryKeyData.java | 88 --
.../phoenix/hive/mapreduce/PhoenixInputSplit.java | 160 ---
.../hive/mapreduce/PhoenixOutputFormat.java | 112 ---
.../hive/mapreduce/PhoenixRecordReader.java | 217 ----
.../hive/mapreduce/PhoenixResultWritable.java | 217 ----
.../AbstractPhoenixObjectInspector.java | 59 --
.../PhoenixBinaryObjectInspector.java | 58 --
.../PhoenixBooleanObjectInspector.java | 55 -
.../PhoenixCharObjectInspector.java | 56 --
.../PhoenixDateObjectInspector.java | 63 --
.../PhoenixDecimalObjectInspector.java | 72 --
.../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/IndexSearchCondition.java | 143 ---
.../hive/ql/index/PredicateAnalyzerFactory.java | 40 -
.../phoenix/hive/util/ColumnMappingUtils.java | 76 --
.../apache/phoenix/hive/PrimaryKeyDataTest.java | 79 --
.../apache/phoenix/kafka/PhoenixConsumerIT.java | 276 -----
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 --
.../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 ------
.../apache/phoenix/pig/PhoenixHBaseStorage.java | 236 -----
.../apache/phoenix/pig/udf/ReserveNSequence.java | 129 ---
.../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-spark/README.md | 164 ---
.../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/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/PhoenixInputPartition.java | 44 -
.../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 | 100 --
.../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 | 5 -
188 files changed, 3921 insertions(+), 15105 deletions(-)
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
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/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/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/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/src/main/java/org/apache/phoenix/hive/PhoenixMetaHook.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/PrimaryKeyData.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/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/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/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/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/util/ColumnMappingUtils.java
delete mode 100644
phoenix-hive/src/test/java/org/apache/phoenix/hive/PrimaryKeyDataTest.java
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-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/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/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-spark/README.md
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/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/PhoenixInputPartition.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
