You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2016/06/10 15:24:05 UTC
[26/50] [abbrv] bahir git commit: [SPARK-12692][BUILD][STREAMING]
Scala style: Fix the style violation (Space before ", " or ":")
[SPARK-12692][BUILD][STREAMING] Scala style: Fix the style violation (Space before "," or ":")
Fix the style violation (space before , and :).
This PR is a followup for #10643.
Author: Kousuke Saruta <sa...@oss.nttdata.co.jp>
Closes #10685 from sarutak/SPARK-12692-followup-streaming.
Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/618b8620
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/618b8620
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/618b8620
Branch: refs/heads/master
Commit: 618b8620c3bbbb7c9b47240ffb20729a5185afc8
Parents: d29a61b
Author: Kousuke Saruta <sa...@oss.nttdata.co.jp>
Authored: Mon Jan 11 21:06:22 2016 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Mon Jan 11 21:06:22 2016 -0800
----------------------------------------------------------------------
.../scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala | 4 ++--
.../org/apache/spark/streaming/twitter/TwitterInputDStream.scala | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/bahir/blob/618b8620/streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala
----------------------------------------------------------------------
diff --git a/streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala b/streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala
index 116c170..079bd8a 100644
--- a/streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala
+++ b/streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala
@@ -38,11 +38,11 @@ import org.apache.spark.streaming.receiver.Receiver
private[streaming]
class MQTTInputDStream(
- ssc_ : StreamingContext,
+ _ssc: StreamingContext,
brokerUrl: String,
topic: String,
storageLevel: StorageLevel
- ) extends ReceiverInputDStream[String](ssc_) {
+ ) extends ReceiverInputDStream[String](_ssc) {
private[streaming] override def name: String = s"MQTT stream [$id]"
http://git-wip-us.apache.org/repos/asf/bahir/blob/618b8620/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
----------------------------------------------------------------------
diff --git a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
index a48eec7..bdd57fd 100644
--- a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
+++ b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
@@ -39,11 +39,11 @@ import org.apache.spark.streaming.receiver.Receiver
*/
private[streaming]
class TwitterInputDStream(
- ssc_ : StreamingContext,
+ _ssc: StreamingContext,
twitterAuth: Option[Authorization],
filters: Seq[String],
storageLevel: StorageLevel
- ) extends ReceiverInputDStream[Status](ssc_) {
+ ) extends ReceiverInputDStream[Status](_ssc) {
private def createOAuthAuthorization(): Authorization = {
new OAuthAuthorization(new ConfigurationBuilder().build())