88a3b8a08ba00350cf6378f5e01138f41224b705 - phoenix-connectors

commit	88a3b8a08ba00350cf6378f5e01138f41224b705	[log] [tgz]
author	Richard Antal <antal97richard@gmail.com>	Thu Aug 13 12:53:45 2020 +0200
committer	Istvan Toth <stoty@apache.org>	Fri Aug 28 11:52:23 2020 +0200
tree	ba25bf29c609a362bca39abd4a52a895f5957ad9
parent	cb268abbd95a3a99dcb21af7ae85c88fa72724fd [diff]

PHOENIX-6076 Refactor Phoenix Hive Connectors introduced by PHOENIX-6057

phoenix-flume-base/phoenix4-flume/pom.xml[diff]
phoenix-flume-base/phoenix5-flume/pom.xml[diff]
phoenix-flume-base/pom.xml[diff]
phoenix-hive-base/phoenix4-hive/pom.xml[Added - diff]
phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/compat/HiveCompatUtil.java[Added - diff]
phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/compat/MyResult.java[Added - diff]
phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java - diff]
phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDateObjectInspectorBase.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDateObjectInspector.java - diff]
phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixTimestampObjectInspectorBase.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixTimestampObjectInspector.java - diff]
phoenix-hive-base/phoenix5-hive/pom.xml[Added - diff]
phoenix-hive-base/phoenix5-hive/src/main/java/org/apache/phoenix/compat/HiveCompatUtil.java[Added - diff]
phoenix-hive-base/phoenix5-hive/src/main/java/org/apache/phoenix/compat/MyResult.java[Added - diff]
phoenix-hive-base/phoenix5-hive/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java[Copied from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java - diff]
phoenix-hive-base/phoenix5-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDateObjectInspectorBase.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDateObjectInspector.java - diff]
phoenix-hive-base/phoenix5-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixTimestampObjectInspectorBase.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixTimestampObjectInspector.java - diff]
phoenix-hive-base/pom.xml[Added - diff]
phoenix-hive-base/src/it/java/org/apache/hadoop/hive/ql/QTestProcessExecResult.java[Renamed from phoenix-hive3/src/it/java/org/apache/hadoop/hive/ql/QTestProcessExecResult.java - diff]
phoenix-hive-base/src/it/java/org/apache/hadoop/hive/ql/QTestUtil.java[Renamed from phoenix-hive3/src/it/java/org/apache/hadoop/hive/ql/QTestUtil.java - diff]
phoenix-hive-base/src/it/java/org/apache/hadoop/hive/ql/security/DummyAuthenticator.java[Renamed from phoenix-hive3/src/it/java/org/apache/hadoop/hive/ql/security/DummyAuthenticator.java - diff]
phoenix-hive-base/src/it/java/org/apache/phoenix/hive/BaseHivePhoenixStoreIT.java[Renamed from phoenix-hive3/src/it/java/org/apache/phoenix/hive/BaseHivePhoenixStoreIT.java - diff]
phoenix-hive-base/src/it/java/org/apache/phoenix/hive/HiveMapReduceIT.java[Renamed from phoenix-hive3/src/it/java/org/apache/phoenix/hive/HiveMapReduceIT.java - diff]
phoenix-hive-base/src/it/java/org/apache/phoenix/hive/HivePhoenixStoreIT.java[Renamed from phoenix-hive3/src/it/java/org/apache/phoenix/hive/HivePhoenixStoreIT.java - diff]
phoenix-hive-base/src/it/java/org/apache/phoenix/hive/HiveTestUtil.java[Renamed from phoenix-hive3/src/it/java/org/apache/phoenix/hive/HiveTestUtil.java - diff]
phoenix-hive-base/src/it/java/org/apache/phoenix/hive/HiveTezIT.java[Renamed from phoenix-hive/src/it/java/org/apache/phoenix/hive/HiveTezIT.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PhoenixMetaHook.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/PhoenixMetaHook.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PhoenixRecordUpdater.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixRecordUpdater.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PhoenixRow.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixRow.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PhoenixRowKey.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixRowKey.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PhoenixSerDe.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixSerDe.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PhoenixSerializer.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixSerializer.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PhoenixStorageHandler.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/PhoenixStorageHandler.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/PrimaryKeyData.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/PrimaryKeyData.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/constants/PhoenixStorageHandlerConstants.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/constants/PhoenixStorageHandlerConstants.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputFormat.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputFormat.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputSplit.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputSplit.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixOutputFormat.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixOutputFormat.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordReader.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordReader.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordWriter.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordWriter.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixResultWritable.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixResultWritable.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBinaryObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBinaryObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBooleanObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBooleanObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixByteObjectInspector.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixByteObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixCharObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixCharObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDateObjectInspector.java[Renamed from phoenix-hive3/src/it/java/org/apache/phoenix/hive/HiveTezIT.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDecimalObjectInspector.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDecimalObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDoubleObjectInspector.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDoubleObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixFloatObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixFloatObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixIntObjectInspector.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixIntObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixListObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixListObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixLongObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixLongObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixObjectInspectorFactory.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixObjectInspectorFactory.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixShortObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixShortObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixStringObjectInspector.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixStringObjectInspector.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixTimestampObjectInspector.java[Copied from phoenix-hive3/src/it/java/org/apache/phoenix/hive/HiveTezIT.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/ppd/PhoenixPredicateDecomposer.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/ppd/PhoenixPredicateDecomposer.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/ql/index/IndexPredicateAnalyzer.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/ql/index/IndexPredicateAnalyzer.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/ql/index/IndexSearchCondition.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/ql/index/IndexSearchCondition.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/ql/index/PredicateAnalyzerFactory.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/ql/index/PredicateAnalyzerFactory.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/query/PhoenixQueryBuilder.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/query/PhoenixQueryBuilder.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/util/ColumnMappingUtils.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/util/ColumnMappingUtils.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/util/PhoenixConnectionUtil.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/util/PhoenixConnectionUtil.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/util/PhoenixStorageHandlerUtil.java[Renamed from phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixStorageHandlerUtil.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java - diff]
phoenix-hive-base/src/main/java/org/apache/phoenix/hive/util/TypeInfoUtils.java[Renamed from phoenix-hive3/src/main/java/org/apache/phoenix/hive/util/TypeInfoUtils.java - diff]
phoenix-hive-base/src/test/java/org/apache/phoenix/hive/PrimaryKeyDataTest.java[Renamed from phoenix-hive/src/test/java/org/apache/phoenix/hive/PrimaryKeyDataTest.java - diff]
phoenix-hive-base/src/test/java/org/apache/phoenix/hive/query/PhoenixQueryBuilderTest.java[Renamed from phoenix-hive3/src/test/java/org/apache/phoenix/hive/query/PhoenixQueryBuilderTest.java - diff]
phoenix-hive-base/src/test/resources/hbase-site.xml[Renamed from phoenix-hive3/src/test/resources/hbase-site.xml - diff]
phoenix-hive-base/src/test/resources/hive-site.xml[Renamed from phoenix-hive3/src/test/resources/hive-site.xml - diff]
phoenix-hive-base/src/test/resources/log4j.properties[Renamed from phoenix-hive3/src/test/resources/log4j.properties - diff]
phoenix-hive-base/src/test/resources/tez-site.xml[Renamed from phoenix-hive3/src/test/resources/tez-site.xml - diff]
phoenix-hive/pom.xml[Deleted - diff]
phoenix-hive/src/it/java/org/apache/phoenix/hive/BaseHivePhoenixStoreIT.java[Deleted - diff]
phoenix-hive/src/it/java/org/apache/phoenix/hive/HiveMapReduceIT.java[Deleted - diff]
phoenix-hive/src/it/java/org/apache/phoenix/hive/HivePhoenixStoreIT.java[Deleted - diff]
phoenix-hive/src/it/java/org/apache/phoenix/hive/HiveTestUtil.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixMetaHook.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/PhoenixStorageHandler.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/constants/PhoenixStorageHandlerConstants.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputFormat.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixInputSplit.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordReader.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixRecordWriter.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixByteObjectInspector.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDecimalObjectInspector.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixDoubleObjectInspector.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixIntObjectInspector.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/ql/index/IndexPredicateAnalyzer.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/query/PhoenixQueryBuilder.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/util/ColumnMappingUtils.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixConnectionUtil.java[Deleted - diff]
phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java[Deleted - diff]
phoenix-hive/src/test/java/org/apache/phoenix/hive/query/PhoenixQueryBuilderTest.java[Deleted - diff]
phoenix-hive3/pom.xml[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/PhoenixRecordUpdater.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/PhoenixRow.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/PhoenixRowKey.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/PhoenixSerDe.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/PhoenixSerializer.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/PrimaryKeyData.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixOutputFormat.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/mapreduce/PhoenixResultWritable.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBinaryObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixBooleanObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixCharObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixFloatObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixListObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixLongObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixObjectInspectorFactory.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixShortObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/objectinspector/PhoenixStringObjectInspector.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/ppd/PhoenixPredicateDecomposer.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/ql/index/IndexSearchCondition.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/ql/index/PredicateAnalyzerFactory.java[Deleted - diff]
phoenix-hive3/src/main/java/org/apache/phoenix/hive/util/PhoenixStorageHandlerUtil.java[Deleted - diff]
phoenix-hive3/src/test/java/org/apache/phoenix/hive/PrimaryKeyDataTest.java[Deleted - diff]
phoenix-kafka-base/phoenix4-kafka/pom.xml[diff]
phoenix-kafka-base/phoenix5-kafka/pom.xml[diff]
phoenix-kafka-base/pom.xml[diff]
phoenix-pig-base/phoenix4-pig/pom.xml[diff]
phoenix-pig-base/phoenix5-pig/pom.xml[diff]
phoenix-pig-base/pom.xml[diff]
phoenix-spark-base/phoenix4-spark/pom.xml[diff]
phoenix-spark-base/phoenix5-spark/pom.xml[diff]
phoenix-spark-base/pom.xml[diff]
phoenix4-compat/src/main/java/org/apache/phoenix/compat/CompatUtil.java[diff]
phoenix5-compat/pom.xml[diff]
phoenix5-compat/src/main/java/org/apache/phoenix/compat/CompatUtil.java[diff]
pom.xml[diff]

129 files changed

tree: ba25bf29c609a362bca39abd4a52a895f5957ad9

README.md

Apache Phoenix enables OLTP and operational analytics in Hadoop for low latency applications. Visit the Apache Phoenix website here. This repo contains connectors for third party libraries to access data stored in Phoenix/HBase.