5bd23ae2a0f70c3b3edf92a53780dafa643faf26 - phoenix-connectors

commit	5bd23ae2a0f70c3b3edf92a53780dafa643faf26	[log] [tgz]
author	Richard Antal <antal97richard@gmail.com>	Mon Aug 03 15:49:37 2020 +0200
committer	Istvan Toth <stoty@apache.org>	Thu Aug 13 08:42:00 2020 +0200
tree	68f26f865aaf4377781d57ce5cb902cd9a02d496
parent	51d3afe8bf3bba76d49b6aa5eb5f9c93c02e1932 [diff]

PHOENIX-6057 Create phoenix-connector for spark, kafka, pig, flume that works with Phoenix5

phoenix-flume-base/phoenix4-flume/pom.xml[Added - diff]
phoenix-flume-base/phoenix5-flume/pom.xml[Added - diff]
phoenix-flume-base/pom.xml[Renamed from phoenix-flume/pom.xml - diff]
phoenix-flume-base/src/it/java/org/apache/phoenix/flume/CsvEventSerializerIT.java[Renamed from phoenix-flume/src/it/java/org/apache/phoenix/flume/CsvEventSerializerIT.java - diff]
phoenix-flume-base/src/it/java/org/apache/phoenix/flume/JsonEventSerializerIT.java[Renamed from phoenix-flume/src/it/java/org/apache/phoenix/flume/JsonEventSerializerIT.java - diff]
phoenix-flume-base/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java[Renamed from phoenix-flume/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java - diff]
phoenix-flume-base/src/it/java/org/apache/phoenix/flume/RegexEventSerializerIT.java[Renamed from phoenix-flume/src/it/java/org/apache/phoenix/flume/RegexEventSerializerIT.java - diff]
phoenix-flume-base/src/it/java/org/apache/phoenix/flume/serializer/CustomSerializer.java[Renamed from phoenix-flume/src/it/java/org/apache/phoenix/flume/serializer/CustomSerializer.java - diff]
phoenix-flume-base/src/it/java/org/apache/phoenix/flume/sink/NullPhoenixSink.java[Renamed from phoenix-flume/src/it/java/org/apache/phoenix/flume/sink/NullPhoenixSink.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/DefaultKeyGenerator.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/DefaultKeyGenerator.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/FlumeConstants.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/FlumeConstants.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/KeyGenerator.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/KeyGenerator.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/SchemaHandler.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/SchemaHandler.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/serializer/BaseEventSerializer.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/BaseEventSerializer.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/serializer/CsvEventSerializer.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/CsvEventSerializer.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/serializer/EventSerializer.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/EventSerializer.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/serializer/EventSerializers.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/EventSerializers.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/serializer/JsonEventSerializer.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/JsonEventSerializer.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/serializer/RegexEventSerializer.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/serializer/RegexEventSerializer.java - diff]
phoenix-flume-base/src/main/java/org/apache/phoenix/flume/sink/PhoenixSink.java[Renamed from phoenix-flume/src/main/java/org/apache/phoenix/flume/sink/PhoenixSink.java - diff]
phoenix-hive/pom.xml[diff]
phoenix-hive3/pom.xml[diff]
phoenix-hive3/src/test/resources/tez-site.xml[diff]
phoenix-kafka-base/phoenix4-kafka/pom.xml[Added - diff]
phoenix-kafka-base/phoenix5-kafka/pom.xml[Added - diff]
phoenix-kafka-base/pom.xml[Renamed from phoenix-kafka/pom.xml - diff]
phoenix-kafka-base/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java[Renamed from phoenix-kafka/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java - diff]
phoenix-kafka-base/src/it/resources/consumer.props[Renamed from phoenix-kafka/src/it/resources/consumer.props - diff]
phoenix-kafka-base/src/it/resources/producer.props[Renamed from phoenix-kafka/src/it/resources/producer.props - diff]
phoenix-kafka-base/src/main/java/org/apache/phoenix/kafka/KafkaConstants.java[Renamed from phoenix-kafka/src/main/java/org/apache/phoenix/kafka/KafkaConstants.java - diff]
phoenix-kafka-base/src/main/java/org/apache/phoenix/kafka/consumer/PhoenixConsumer.java[Renamed from phoenix-kafka/src/main/java/org/apache/phoenix/kafka/consumer/PhoenixConsumer.java - diff]
phoenix-kafka-base/src/main/java/org/apache/phoenix/kafka/consumer/PhoenixConsumerTool.java[Renamed from phoenix-kafka/src/main/java/org/apache/phoenix/kafka/consumer/PhoenixConsumerTool.java - diff]
phoenix-pig-base/phoenix4-pig/pom.xml[Added - diff]
phoenix-pig-base/phoenix5-pig/pom.xml[Added - diff]
phoenix-pig-base/pom.xml[Renamed from phoenix-pig/pom.xml - diff]
phoenix-pig-base/src/it/java/org/apache/phoenix/pig/BasePigIT.java[Renamed from phoenix-pig/src/it/java/org/apache/phoenix/pig/BasePigIT.java - diff]
phoenix-pig-base/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java[Renamed from phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java - diff]
phoenix-pig-base/src/it/java/org/apache/phoenix/pig/PhoenixHBaseStorerIT.java[Renamed from phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseStorerIT.java - diff]
phoenix-pig-base/src/it/java/org/apache/phoenix/pig/udf/ReserveNSequenceTestIT.java[Renamed from phoenix-pig/src/it/java/org/apache/phoenix/pig/udf/ReserveNSequenceTestIT.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/PhoenixHBaseLoader.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/PhoenixHBaseLoader.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/PhoenixHBaseStorage.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/PhoenixHBaseStorage.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/util/PhoenixPigSchemaUtil.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/util/PhoenixPigSchemaUtil.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/util/QuerySchemaParserFunction.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/util/QuerySchemaParserFunction.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/util/SqlQueryToColumnInfoFunction.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/util/SqlQueryToColumnInfoFunction.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/util/TableSchemaParserFunction.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/util/TableSchemaParserFunction.java - diff]
phoenix-pig-base/src/main/java/org/apache/phoenix/pig/util/TypeUtil.java[Renamed from phoenix-pig/src/main/java/org/apache/phoenix/pig/util/TypeUtil.java - diff]
phoenix-pig-base/src/test/java/org/apache/phoenix/pig/util/PhoenixPigSchemaUtilTest.java[Renamed from phoenix-pig/src/test/java/org/apache/phoenix/pig/util/PhoenixPigSchemaUtilTest.java - diff]
phoenix-pig-base/src/test/java/org/apache/phoenix/pig/util/QuerySchemaParserFunctionTest.java[Renamed from phoenix-pig/src/test/java/org/apache/phoenix/pig/util/QuerySchemaParserFunctionTest.java - diff]
phoenix-pig-base/src/test/java/org/apache/phoenix/pig/util/SqlQueryToColumnInfoFunctionTest.java[Renamed from phoenix-pig/src/test/java/org/apache/phoenix/pig/util/SqlQueryToColumnInfoFunctionTest.java - diff]
phoenix-pig-base/src/test/java/org/apache/phoenix/pig/util/TableSchemaParserFunctionTest.java[Renamed from phoenix-pig/src/test/java/org/apache/phoenix/pig/util/TableSchemaParserFunctionTest.java - diff]
phoenix-pig-base/src/test/java/org/apache/phoenix/pig/util/TypeUtilTest.java[Renamed from phoenix-pig/src/test/java/org/apache/phoenix/pig/util/TypeUtilTest.java - diff]
phoenix-spark-base/README.md[Renamed from phoenix-spark/README.md - diff]
phoenix-spark-base/phoenix4-spark/pom.xml[Added - diff]
phoenix-spark-base/phoenix5-spark/pom.xml[Added - diff]
phoenix-spark-base/pom.xml[Added - diff]
phoenix-spark-base/src/it/java/org/apache/phoenix/spark/AggregateIT.java[Renamed from phoenix-spark/src/it/java/org/apache/phoenix/spark/AggregateIT.java - diff]
phoenix-spark-base/src/it/java/org/apache/phoenix/spark/OrderByIT.java[Renamed from phoenix-spark/src/it/java/org/apache/phoenix/spark/OrderByIT.java - diff]
phoenix-spark-base/src/it/java/org/apache/phoenix/spark/SaltedTableIT.java[Renamed from phoenix-spark/src/it/java/org/apache/phoenix/spark/SaltedTableIT.java - diff]
phoenix-spark-base/src/it/java/org/apache/phoenix/spark/SparkUtil.java[Renamed from phoenix-spark/src/it/java/org/apache/phoenix/spark/SparkUtil.java - diff]
phoenix-spark-base/src/it/resources/globalSetup.sql[Renamed from phoenix-spark/src/it/resources/globalSetup.sql - diff]
phoenix-spark-base/src/it/resources/log4j.xml[Renamed from phoenix-spark/src/it/resources/log4j.xml - diff]
phoenix-spark-base/src/it/resources/tenantSetup.sql[Renamed from phoenix-spark/src/it/resources/tenantSetup.sql - diff]
phoenix-spark-base/src/it/scala/org/apache/phoenix/spark/AbstractPhoenixSparkIT.scala[Renamed from phoenix-spark/src/it/scala/org/apache/phoenix/spark/AbstractPhoenixSparkIT.scala - diff]
phoenix-spark-base/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala[Renamed from phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala - diff]
phoenix-spark-base/src/it/scala/org/apache/phoenix/spark/PhoenixSparkITTenantSpecific.scala[Renamed from phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkITTenantSpecific.scala - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/SparkResultSet.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/SparkResultSet.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/PhoenixDataSource.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/PhoenixDataSource.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixDataSourceReadOptions.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixDataSourceReadOptions.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixDataSourceReader.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixDataSourceReader.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixInputPartition.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixInputPartition.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixInputPartitionReader.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixInputPartitionReader.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataSourceWriteOptions.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataSourceWriteOptions.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataSourceWriter.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataSourceWriter.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataWriter.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataWriter.java - diff]
phoenix-spark-base/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataWriterFactory.java[Renamed from phoenix-spark/src/main/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixDataWriterFactory.java - diff]
phoenix-spark-base/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister[Renamed from phoenix-spark/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister - diff]
phoenix-spark-base/src/main/resources/log4j.xml[Renamed from phoenix-spark/src/main/resources/log4j.xml - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/DefaultSource.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/DefaultSource.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/FilterExpressionCompiler.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/FilterExpressionCompiler.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/PhoenixRecordWritable.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRecordWritable.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/PhoenixRelation.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRelation.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/ProductRDDFunctions.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/ProductRDDFunctions.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/SparkContextFunctions.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/SparkContextFunctions.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/SparkSchemaUtil.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/SparkSchemaUtil.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/phoenix/spark/package.scala[Renamed from phoenix-spark/src/main/scala/org/apache/phoenix/spark/package.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/PhoenixJdbcDialect.scala[Renamed from phoenix-spark/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/PhoenixJdbcDialect.scala - diff]
phoenix-spark-base/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/SparkJdbcUtil.scala[Renamed from phoenix-spark/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/SparkJdbcUtil.scala - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/PhoenixDataSourceTest.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/PhoenixDataSourceTest.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/PhoenixTestingDataSource.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/PhoenixTestingDataSource.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixTestingDataSourceReader.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixTestingDataSourceReader.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixTestingInputPartition.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixTestingInputPartition.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixTestingInputPartitionReader.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/reader/PhoenixTestingInputPartitionReader.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingDataSourceWriter.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingDataSourceWriter.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingDataWriter.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingDataWriter.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingDataWriterFactory.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingDataWriterFactory.java - diff]
phoenix-spark-base/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingWriterCommitMessage.java[Renamed from phoenix-spark/src/test/java/org/apache/phoenix/spark/datasource/v2/writer/PhoenixTestingWriterCommitMessage.java - diff]
phoenix-spark-base/src/test/resources/log4j.xml[Renamed from phoenix-spark/src/test/resources/log4j.xml - diff]
phoenix-spark/pom.xml[Deleted - diff]
phoenix4-compat/pom.xml[Added - diff]
phoenix4-compat/src/main/java/org/apache/phoenix/compat/CompatUtil.java[Added - diff]
phoenix5-compat/pom.xml[Added - diff]
phoenix5-compat/src/main/java/org/apache/phoenix/compat/CompatUtil.java[Added - diff]
pom.xml[diff]

108 files changed

tree: 68f26f865aaf4377781d57ce5cb902cd9a02d496

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.