Skip to content

Commit c8efdcf

Browse files
committed
scala coding style fixes, one line per param
1 parent 82499bc commit c8efdcf

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -201,8 +201,10 @@ class KinesisSequenceRangeIterator(
201201
/**
202202
* Get records starting from or after the given sequence number.
203203
*/
204-
private def getRecords(iteratorType: ShardIteratorType, seqNum: String,
205-
recordCount: Int): Iterator[Record] = {
204+
private def getRecords(
205+
iteratorType: ShardIteratorType,
206+
seqNum: String,
207+
recordCount: Int): Iterator[Record] = {
206208
val shardIterator = getKinesisIterator(iteratorType, seqNum)
207209
val result = getRecordsAndNextKinesisIterator(shardIterator, recordCount)
208210
result._1

0 commit comments

Comments
 (0)