diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-03-26 15:05:13 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-03-26 15:05:13 -0700 |
| commit | bc36ee4fbbe3ad3b7e15fbdba53de42a29b81a9f (patch) | |
| tree | 40e825bea310e1240932873efebbdffc417a8152 /streaming | |
| parent | 6c18131487e8537da19e2daf45b385c5af494ea3 (diff) | |
| parent | 1f5381119f8c8afd0ba69bc7773c10972dd43bc1 (diff) | |
| download | spark-bc36ee4fbbe3ad3b7e15fbdba53de42a29b81a9f.tar.gz spark-bc36ee4fbbe3ad3b7e15fbdba53de42a29b81a9f.tar.bz2 spark-bc36ee4fbbe3ad3b7e15fbdba53de42a29b81a9f.zip | |
Merge pull request #543 from holdenk/master
Re-enable deprecation warnings and fix deprecated warning.
Diffstat (limited to 'streaming')
| -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)) } |