【发布时间】:2019-01-20 12:26:43
【问题描述】:
谁能向我解释一下 private[streaming] 的使用以及 _ssc 的含义(为什么下面代码的 sn-p 中使用了下划线):
private[streaming]
class PubsubInputDStream(
_ssc: StreamingContext,
val project: String,
val topic: Option[String],
val subscription: String,
val credential: SparkGCPCredentials,
val _storageLevel: StorageLevel
) extends ReceiverInputDStream[SparkPubsubMessage](_ssc) {
override def getReceiver(): Receiver[SparkPubsubMessage] = {
new PubsubReceiver(project, topic, subscription, credential, _storageLevel)
}
}
【问题讨论】:
-
下划线没有特殊含义——我怀疑它只是流包的内部名称簿记
标签: scala apache-spark