Skip to content

Commit 1a3055e

Browse files
committed
Fix scala style.
1 parent d863516 commit 1a3055e

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

core/src/main/scala/org/apache/spark/util/CheckpointingIterator.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -40,16 +40,16 @@ private[spark] class CheckpointingIterator[A: ClassTag, +I <: Iterator[A]](
4040
partitionId: Int,
4141
context: TaskContext,
4242
blockSize: Int = -1) extends Iterator[A] with Logging {
43-
43+
4444
val env = SparkEnv.get
45-
var fs: FileSystem = null
45+
var fs: FileSystem = null
4646
val bufferSize = env.conf.getInt("spark.buffer.size", 65536)
4747
var serializeStream: SerializationStream = null
48-
48+
4949
var finalOutputPath: Path = null
5050
var tempOutputPath: Path = null
5151

52-
def init(): this.type = {
52+
def init(): this.type = {
5353
val outputDir = new Path(path)
5454
fs = outputDir.getFileSystem(broadcastedConf.value.value)
5555

@@ -100,7 +100,7 @@ private[spark] class CheckpointingIterator[A: ClassTag, +I <: Iterator[A]](
100100
def checkpointing(item: A): Unit = {
101101
serializeStream.writeObject(item)
102102
}
103-
103+
104104
override def next(): A = {
105105
val item = sub.next()
106106
if (doCheckpoint) {

0 commit comments

Comments
 (0)