0

我有一个 flink 应用程序。我在 map 函数中使用了一个对象。像这样：

.map(value => {
    import spray.json._
    import com.webtrekk.sObjects._
    import com.webtrekk.jsonProtocol._
    import com.webtrekk.salesforce._

    implicit val effortProcessing = streamProcessor.Effort
    implicit val effortConsulting = effortConsultingFormat
    var effort = value.toString.parseJson.convertTo[effortConsulting]

    streamProcessor.Effort.mapping(
        value.toString.parseJson.convertTo[effortConsulting]
    )

    effort
  })

streamProcessor 是一个对象。该对象内部是数据库的另一个服务对象。每当应用程序有事件发生时，Flink 都会执行这个 map 函数。我想知道的是：每次对象都是相同的单例对象吗？

一个例子：

-> 事件到达应用程序 -> map 函数将执行并创建一个单例对象

-> 下一个事件到达应用程序 -> 地图函数将再次执行 -> 对象将再次调用

第二个对象是相同的实例吗？

4

1 回答 1

2

是和不是。对象是其范围内的单例：

scala> List(1, 2).map(i => { object foo { def bar: Int = i }; foo }).map(_.bar)
res2: List[Int] = List(1, 2)

这意味着以下内容大致等效：

object foo extends Thing { ... }
lazy val foo = new Thing { ... }

在您的情况下，因为对象是在map函数之外声明的，所以每次都是同一个实例。

于 2016-05-20T15:41:59.477 回答