2

我正在尝试结合模式匹配和条件,但是这段代码(这是一个 Samza 任务):

override def process(incomingMessageEnvelope: IncomingMessageEnvelope, messageCollector: MessageCollector, taskCoordinator: TaskCoordinator): Unit = {
    val event = (incomingMessageEnvelope getMessage).asInstanceOf[Map[String, Date]]
    val symbol = (event get "symbol").asInstanceOf[String]
    val eventDate = (event get "date").asInstanceOf[Date]

    (store get symbol) match {
      case x: java.util.Date if x.equals(eventDate) || x.after(eventDate) => _ 
      case _ => {
        this.store.put(symbol, eventDate)
      }
    }
  }

返回此错误:

Error:(30, 38) unbound placeholder parameter
  case x if isGreaterOf(x, x) => _
                                 ^

你知道错误吗?

谢谢

问候

詹卢卡

4

1 回答 1

6

异常与您的代码不匹配,但有一行会引发相同的错误:

case x: java.util.Date if x.equals(eventDate) || x.after(eventDate) => _ 

因为_是一个占位符,可以在模式中用于匹配和返回类型。它不能不用于指示Unit返回值。要在不执行代码的情况下返回Unit值,您可以这样做

case x: java.util.Date if x.equals(eventDate) || x.after(eventDate) => ()

反而。

于 2015-08-01T07:48:54.560 回答