This is an automated email from the ASF dual-hosted git repository.
reidchan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hbase-connectors.git
from c1eb13a HBASE-27178 Use spotless to format code (including scala
code) (#119)
add ee2b51c HBASE-28006 Run spotless:apply on code base (#120)
No new revisions were added by this update.
Summary of changes:
CHANGELOG.md | 2 -
README.md | 2 +-
RELEASENOTES.md | 1 -
dev-support/.scalafmt.conf | 27 +-
dev-support/code-coverage/README.md | 2 +-
dev-support/jenkins/Jenkinsfile | 2 +-
.../jenkins/jenkins_precommit_github_yetus.sh | 2 +-
hbase-connectors-assembly/pom.xml | 44 +-
kafka/README.md | 2 +-
kafka/hbase-kafka-model/pom.xml | 77 +-
kafka/hbase-kafka-proxy/pom.xml | 51 +-
.../org/apache/hadoop/hbase/kafka/DropRule.java | 8 +-
.../hadoop/hbase/kafka/DumpToStringListener.java | 28 +-
.../hadoop/hbase/kafka/KafkaBridgeConnection.java | 66 +-
.../org/apache/hadoop/hbase/kafka/KafkaProxy.java | 245 ++---
.../hadoop/hbase/kafka/KafkaTableForBridge.java | 116 +--
.../java/org/apache/hadoop/hbase/kafka/Rule.java | 41 +-
.../hadoop/hbase/kafka/TopicRoutingRules.java | 97 +-
.../org/apache/hadoop/hbase/kafka/TopicRule.java | 9 +-
.../hadoop/hbase/kafka/ProducerForTesting.java | 30 +-
.../apache/hadoop/hbase/kafka/TestDropRule.java | 122 ++-
.../hadoop/hbase/kafka/TestProcessMutations.java | 30 +-
.../hadoop/hbase/kafka/TestQualifierMatching.java | 30 +-
.../apache/hadoop/hbase/kafka/TestRouteRules.java | 126 ++-
kafka/pom.xml | 5 +-
pom.xml | 133 ++-
spark/README.md | 1 -
spark/hbase-spark-it/pom.xml | 292 +++---
.../hbase/spark/IntegrationTestSparkBulkLoad.java | 144 ++-
spark/hbase-spark-protocol-shaded/pom.xml | 4 +-
spark/hbase-spark-protocol/pom.xml | 4 +-
spark/hbase-spark/pom.xml | 36 +-
.../hadoop/hbase/spark/SparkSQLPushDownFilter.java | 162 ++-
.../hbasecontext/JavaHBaseBulkDeleteExample.java | 25 +-
.../hbasecontext/JavaHBaseBulkGetExample.java | 37 +-
.../hbasecontext/JavaHBaseBulkLoadExample.java | 47 +-
.../hbasecontext/JavaHBaseBulkPutExample.java | 31 +-
.../hbasecontext/JavaHBaseDistributedScan.java | 27 +-
.../hbasecontext/JavaHBaseMapGetPutExample.java | 54 +-
.../JavaHBaseStreamingBulkPutExample.java | 39 +-
.../hadoop/hbase/spark/BulkLoadPartitioner.scala | 24 +-
.../hadoop/hbase/spark/ByteArrayComparable.scala | 10 +-
.../hadoop/hbase/spark/ByteArrayWrapper.scala | 27 +-
.../spark/ColumnFamilyQualifierMapKeyWrapper.scala | 57 +-
.../apache/hadoop/hbase/spark/DefaultSource.scala | 1041 +++++++++++---------
.../hbase/spark/DynamicLogicExpression.scala | 214 ++--
.../hbase/spark/FamiliesQualifiersValues.scala | 39 +-
.../hbase/spark/FamilyHFileWriteOptions.scala | 27 +-
.../hadoop/hbase/spark/HBaseConnectionCache.scala | 83 +-
.../apache/hadoop/hbase/spark/HBaseContext.scala | 898 ++++++++---------
.../hadoop/hbase/spark/HBaseDStreamFunctions.scala | 66 +-
.../hadoop/hbase/spark/HBaseRDDFunctions.scala | 139 +--
.../hadoop/hbase/spark/JavaHBaseContext.scala | 298 +++---
.../hadoop/hbase/spark/KeyFamilyQualifier.scala | 27 +-
.../org/apache/hadoop/hbase/spark/Logging.scala | 18 +-
.../apache/hadoop/hbase/spark/NewHBaseRDD.scala | 34 +-
.../hadoop/hbase/spark/datasources/Bound.scala | 150 +--
.../spark/datasources/DataTypeParserWrapper.scala | 18 +-
.../hbase/spark/datasources/HBaseResources.scala | 38 +-
.../hbase/spark/datasources/HBaseSparkConf.scala | 40 +-
.../spark/datasources/HBaseTableCatalog.scala | 274 +++---
.../spark/datasources/HBaseTableScanRDD.scala | 198 ++--
.../hbase/spark/datasources/JavaBytesEncoder.scala | 127 +--
.../hbase/spark/datasources/NaiveEncoder.scala | 242 +++--
.../hbase/spark/datasources/SchemaConverters.scala | 324 +++---
.../hadoop/hbase/spark/datasources/SerDes.scala | 16 +-
.../datasources/SerializableConfiguration.scala | 20 +-
.../hadoop/hbase/spark/datasources/Utils.scala | 34 +-
.../hadoop/hbase/spark/datasources/package.scala | 19 +-
.../spark/example/datasources/AvroSource.scala | 59 +-
.../hbase/spark/example/datasources/DataType.scala | 82 +-
.../spark/example/datasources/HBaseSource.scala | 65 +-
.../hbasecontext/HBaseBulkDeleteExample.scala | 39 +-
.../example/hbasecontext/HBaseBulkGetExample.scala | 45 +-
.../example/hbasecontext/HBaseBulkPutExample.scala | 62 +-
.../hbasecontext/HBaseBulkPutExampleFromFile.scala | 49 +-
.../HBaseBulkPutTimestampExample.scala | 65 +-
.../hbasecontext/HBaseDistributedScanExample.scala | 28 +-
.../HBaseStreamingBulkPutExample.scala | 33 +-
.../spark/example/rdd/HBaseBulkDeleteExample.scala | 39 +-
.../spark/example/rdd/HBaseBulkGetExample.scala | 49 +-
.../spark/example/rdd/HBaseBulkPutExample.scala | 103 +-
.../example/rdd/HBaseForeachPartitionExample.scala | 68 +-
.../example/rdd/HBaseMapPartitionExample.scala | 84 +-
.../hadoop/hbase/spark/TestJavaHBaseContext.java | 98 +-
.../spark/TestJavaHBaseContextForLargeRows.java | 16 +-
.../apache/hadoop/hbase/spark/BulkLoadSuite.scala | 559 ++++++-----
.../hadoop/hbase/spark/DefaultSourceSuite.scala | 607 +++++++-----
.../hbase/spark/DynamicLogicExpressionSuite.scala | 69 +-
.../hadoop/hbase/spark/HBaseCatalogSuite.scala | 54 +-
.../hbase/spark/HBaseConnectionCacheSuite.scala | 66 +-
.../hadoop/hbase/spark/HBaseContextSuite.scala | 186 ++--
.../hbase/spark/HBaseDStreamFunctionsSuite.scala | 111 ++-
.../hbase/spark/HBaseRDDFunctionsSuite.scala | 350 ++++---
.../hadoop/hbase/spark/HBaseTestSource.scala | 49 +-
.../hadoop/hbase/spark/PartitionFilterSuite.scala | 544 +++++-----
.../hadoop/hbase/spark/StartsWithSuite.scala | 20 +-
.../hbase/spark/TableOutputFormatSuite.scala | 44 +-
spark/pom.xml | 7 +-
test-reporting/pom.xml | 2 +-
100 files changed, 5437 insertions(+), 4918 deletions(-)
