From 409869fb114680cccd0c04a32573fa37811e7ea4 Mon Sep 17 00:00:00 2001
From: acezen <qiaozi.zwb@alibaba-inc.com>
Date: Fri, 19 Jan 2024 11:43:19 +0800
Subject: [PATCH] Format

---
 .../main/scala/com/alibaba/graphar/writer/EdgeWriter.scala  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/spark/src/main/scala/com/alibaba/graphar/writer/EdgeWriter.scala b/spark/src/main/scala/com/alibaba/graphar/writer/EdgeWriter.scala
index 787d00592..fb1eb88b4 100644
--- a/spark/src/main/scala/com/alibaba/graphar/writer/EdgeWriter.scala
+++ b/spark/src/main/scala/com/alibaba/graphar/writer/EdgeWriter.scala
@@ -151,8 +151,8 @@ object EdgeWriter {
       val offsetDfSchema = StructType(
         Seq(StructField(GeneralParams.offsetCol, IntegerType))
       )
-      val offsetDfArray: ParSeq[(Int, DataFrame)] = (0 until vertexChunkNum).par.map {
-        i =>
+      val offsetDfArray: ParSeq[(Int, DataFrame)] =
+        (0 until vertexChunkNum).par.map { i =>
           {
             val filterRDD = edgeCountsByPrimaryKey
               .filter(v => v._1 / vertexChunkSize == i)
@@ -179,7 +179,7 @@ object EdgeWriter {
             offsetChunk.persist(GeneralParams.defaultStorageLevel)
             (i, offsetChunk)
           }
-      }
+        }
       edgeCountsByPrimaryKey.unpersist() // unpersist the edgeCountsByPrimaryKey
       return (
         partitionEdgeDf,