Scala Spark streaming: Trigger

Jak zaimportować trait Trigger?

Ten plik, który masz otwarty, kilka linijek dalej:

 * Scala Example:
 * {{{
 *   df.write.trigger(ProcessingTime("10 seconds"))
 *
 *   import scala.concurrent.duration._
 *   df.write.trigger(ProcessingTime(10.seconds))
 * }}}

Według docsów wygląda na to, że ProcessingTime w to faktycznie metoda statyczna w klasie Trigger w nowszej wersji, ale w tej co masz (2.0? 2.1?) to jest wydzielona case klasa.

Edit: a, no i błąd jest jaki jest, bo Trigger to tylko trait. Na nich nie można bezpośrednio operować.