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
