diff options
| author | Holden Karau <holden@pigscanfly.ca> | 2013-03-24 16:21:51 -0700 |
|---|---|---|
| committer | Holden Karau <holden@pigscanfly.ca> | 2013-03-24 19:19:40 -0700 |
| commit | 1f5381119f8c8afd0ba69bc7773c10972dd43bc1 (patch) | |
| tree | 9fe72492317447c4382738dc66d32d188e8825db /streaming/src | |
| parent | 8456d673e27ee557b2e6fc1ad93b46058e039cea (diff) | |
| download | spark-1f5381119f8c8afd0ba69bc7773c10972dd43bc1.tar.gz spark-1f5381119f8c8afd0ba69bc7773c10972dd43bc1.tar.bz2 spark-1f5381119f8c8afd0ba69bc7773c10972dd43bc1.zip | |
method first in trait IterableLike is deprecated: use `head' instead
Diffstat (limited to 'streaming/src')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala index 6b310bc0b6..da224ad6f7 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/QueueInputDStream.scala @@ -28,7 +28,7 @@ class QueueInputDStream[T: ClassManifest]( } if (buffer.size > 0) { if (oneAtATime) { - Some(buffer.first) + Some(buffer.head) } else { Some(new UnionRDD(ssc.sc, buffer.toSeq)) } |