Merge pull request #7 from CodelyTV/update/scalafmt-core-3.8.3

Update scalafmt-core to 3.8.3

Author: cherrera20

.git-blame-ignore-revs

@@ -0,0 +1,2 @@
+# Scala Steward: Reformat with scalafmt 3.8.3
+51ae86836c4b4dae7b615a16f3380fe0459f83fa

.scalafmt.conf

@@ -1,4 +1,4 @@
-version = 3.8.2
+version = 3.8.3
 runner.dialect = scala213
 style = default
 maxColumn = 120

src/main/com/codely/lesson_04__spark_streaming_rabbitmq/video_01__rabbitmq_receiver/RabbitMQReceiver.scala

@@ -5,10 +5,10 @@ import org.apache.spark.storage.StorageLevel
 import org.apache.spark.streaming.receiver.Receiver
 
 class RabbitMQReceiver(queueName: String, host: String, port: Int, username: String, password: String)
-  extends Receiver[String](StorageLevel.MEMORY_AND_DISK_2) {
+    extends Receiver[String](StorageLevel.MEMORY_AND_DISK_2) {
 
   @transient var connection: Connection = _
-  @transient var channel: Channel = _
+  @transient var channel: Channel       = _
 
   override def onStart(): Unit = {
 
@@ -33,11 +33,11 @@ class RabbitMQReceiver(queueName: String, host: String, port: Int, username: Str
     try {
       val consumer = new DefaultConsumer(channel) {
         override def handleDelivery(
-                                     consumerTag: String,
-                                     envelope: Envelope,
-                                     properties: AMQP.BasicProperties,
-                                     body: Array[Byte]
-                                   ): Unit = {
+            consumerTag: String,
+            envelope: Envelope,
+            properties: AMQP.BasicProperties,
+            body: Array[Byte]
+        ): Unit = {
           val message = new String(body, "UTF-8")
           store(message)
         }

src/main/com/codely/lesson_04__spark_streaming_rabbitmq/video_03__rabbitmq_custom_provider/RabbitMQPartitionReaderFactory.scala

@@ -6,6 +6,5 @@ import org.apache.spark.sql.types.StructType
 
 case class RabbitMQPartitionReaderFactory(schema: StructType) extends PartitionReaderFactory {
   override def createReader(partition: InputPartition): PartitionReader[InternalRow] =
-
     RabbitMQPartitionReader(schema, partition.asInstanceOf[RabbitMQInputPartition])
 }

src/test/com/codely/SparkTestHelper.scala

@@ -11,18 +11,14 @@ import java.io.File
 import java.nio.file.Files
 import scala.reflect.io.Directory
 
-trait SparkTestHelper
-  extends AnyWordSpec
-    with BeforeAndAfterEach
-    with BeforeAndAfterAll
-    with Matchers {
+trait SparkTestHelper extends AnyWordSpec with BeforeAndAfterEach with BeforeAndAfterAll with Matchers {
 
   private val sparkSession = SparkSession
     .builder()
     .master("local[*]")
     .appName("test-spark-session")
     .config(sparkConfiguration)
-    //.enableHiveSupport() uncomment this if you want to use Hive
+    // .enableHiveSupport() uncomment this if you want to use Hive
     .getOrCreate()
 
   protected var tempDir: String = _
@@ -33,14 +29,14 @@ trait SparkTestHelper
 
   protected def sparkConfiguration: SparkConf =
     new SparkConf()
-    /* Uncomment this if you want to use Delta Lake
+  /* Uncomment this if you want to use Delta Lake
 
       .set("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension")
       .set(
         "spark.sql.catalog.spark_catalog",
         "org.apache.spark.sql.delta.catalog.DeltaCatalog"
       )
-    */
+   */
 
   override protected def beforeAll(): Unit = {
     super.beforeAll()