You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2018/11/02 23:24:05 UTC
[hbase-connectors] 01/01: Merge pull request #4 from
saintstack/master
This is an automated email from the ASF dual-hosted git repository.
stack pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase-connectors.git
commit 4c9cb9e6a6eb363b56dc74a5bb0105d8a7d2f858
Merge: 824edc7 8d5dd9b
Author: Michael Stack <sa...@users.noreply.github.com>
AuthorDate: Fri Nov 2 16:24:00 2018 -0700
Merge pull request #4 from saintstack/master
HBASE-21430 [hbase-connectors] Move hbase-spark* modules to hbase-connectors repo
README.md | 1 +
kafka/hbase-kafka-proxy/pom.xml | 20 -
kafka/pom.xml | 9 +-
pom.xml | 271 ++++-
spark/README.md | 1 +
spark/hbase-spark-it/pom.xml | 355 ++++++
.../hbase/spark/IntegrationTestSparkBulkLoad.java | 677 +++++++++++
.../src/test/resources/hbase-site.xml | 32 +
spark/hbase-spark/README.txt | 6 +
spark/hbase-spark/pom.xml | 764 ++++++++++++
.../hadoop/hbase/spark/SparkSQLPushDownFilter.java | 309 +++++
.../hbasecontext/JavaHBaseBulkDeleteExample.java | 81 ++
.../hbasecontext/JavaHBaseBulkGetExample.java | 116 ++
.../hbasecontext/JavaHBaseBulkLoadExample.java | 109 ++
.../hbasecontext/JavaHBaseBulkPutExample.java | 91 ++
.../hbasecontext/JavaHBaseDistributedScan.java | 81 ++
.../hbasecontext/JavaHBaseMapGetPutExample.java | 105 ++
.../JavaHBaseStreamingBulkPutExample.java | 92 ++
.../src/main/protobuf/SparkFilter.proto | 40 +
.../hadoop/hbase/spark/BulkLoadPartitioner.scala | 63 +
.../hadoop/hbase/spark/ByteArrayComparable.scala | 49 +
.../hadoop/hbase/spark/ByteArrayWrapper.scala | 47 +
.../spark/ColumnFamilyQualifierMapKeyWrapper.scala | 75 ++
.../apache/hadoop/hbase/spark/DefaultSource.scala | 1222 ++++++++++++++++++++
.../hbase/spark/DynamicLogicExpression.scala | 259 +++++
.../hbase/spark/FamiliesQualifiersValues.scala | 68 ++
.../hbase/spark/FamilyHFileWriteOptions.scala | 38 +
.../hadoop/hbase/spark/HBaseConnectionCache.scala | 270 +++++
.../apache/hadoop/hbase/spark/HBaseContext.scala | 1126 ++++++++++++++++++
.../hadoop/hbase/spark/HBaseDStreamFunctions.scala | 160 +++
.../hadoop/hbase/spark/HBaseRDDFunctions.scala | 253 ++++
.../hadoop/hbase/spark/JavaHBaseContext.scala | 404 +++++++
.../hadoop/hbase/spark/KeyFamilyQualifier.scala | 48 +
.../org/apache/hadoop/hbase/spark/Logging.scala | 121 ++
.../apache/hadoop/hbase/spark/NewHBaseRDD.scala | 38 +
.../hadoop/hbase/spark/datasources/Bound.scala | 120 ++
.../spark/datasources/DataTypeParserWrapper.scala | 32 +
.../hbase/spark/datasources/HBaseResources.scala | 171 +++
.../hbase/spark/datasources/HBaseSparkConf.scala | 62 +
.../spark/datasources/HBaseTableCatalog.scala | 372 ++++++
.../spark/datasources/HBaseTableScanRDD.scala | 311 +++++
.../hbase/spark/datasources/JavaBytesEncoder.scala | 116 ++
.../hbase/spark/datasources/NaiveEncoder.scala | 261 +++++
.../hbase/spark/datasources/SchemaConverters.scala | 430 +++++++
.../hadoop/hbase/spark/datasources/SerDes.scala | 37 +
.../datasources/SerializableConfiguration.scala | 47 +
.../hadoop/hbase/spark/datasources/Utils.scala | 100 ++
.../hadoop/hbase/spark/datasources/package.scala | 39 +
.../spark/example/datasources/AvroSource.scala | 163 +++
.../hbase/spark/example/datasources/DataType.scala | 172 +++
.../spark/example/datasources/HBaseSource.scala | 109 ++
.../hbasecontext/HBaseBulkDeleteExample.scala | 66 ++
.../example/hbasecontext/HBaseBulkGetExample.scala | 97 ++
.../example/hbasecontext/HBaseBulkPutExample.scala | 78 ++
.../hbasecontext/HBaseBulkPutExampleFromFile.scala | 79 ++
.../HBaseBulkPutTimestampExample.scala | 79 ++
.../hbasecontext/HBaseDistributedScanExample.scala | 62 +
.../HBaseStreamingBulkPutExample.scala | 77 ++
.../spark/example/rdd/HBaseBulkDeleteExample.scala | 67 ++
.../spark/example/rdd/HBaseBulkGetExample.scala | 94 ++
.../spark/example/rdd/HBaseBulkPutExample.scala | 80 ++
.../example/rdd/HBaseForeachPartitionExample.scala | 87 ++
.../example/rdd/HBaseMapPartitionExample.scala | 93 ++
.../hadoop/hbase/spark/TestJavaHBaseContext.java | 538 +++++++++
.../hbase-spark/src/test/resources/hbase-site.xml | 157 +++
.../src/test/resources/log4j.properties | 76 ++
.../apache/hadoop/hbase/spark/BulkLoadSuite.scala | 956 +++++++++++++++
.../hadoop/hbase/spark/DefaultSourceSuite.scala | 1063 +++++++++++++++++
.../hbase/spark/DynamicLogicExpressionSuite.scala | 338 ++++++
.../hadoop/hbase/spark/HBaseCatalogSuite.scala | 109 ++
.../hbase/spark/HBaseConnectionCacheSuite.scala | 236 ++++
.../hadoop/hbase/spark/HBaseContextSuite.scala | 356 ++++++
.../hbase/spark/HBaseDStreamFunctionsSuite.scala | 142 +++
.../hbase/spark/HBaseRDDFunctionsSuite.scala | 398 +++++++
.../hadoop/hbase/spark/HBaseTestSource.scala | 62 +
.../hadoop/hbase/spark/PartitionFilterSuite.scala | 522 +++++++++
.../hbase/spark/TableOutputFormatSuite.scala | 131 +++
spark/pom.xml | 120 ++
78 files changed, 16077 insertions(+), 29 deletions(-)