We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1d7194c commit 19087bfCopy full SHA for 19087bf
build.sbt
@@ -1,4 +1,3 @@
1
-
2
// Copyright (C) 2011-2012 the original author or authors.
3
// See the LICENCE.txt file distributed with this work for additional
4
// information regarding copyright ownership.
src/main/scala/example/WordCount.scala
@@ -37,7 +37,7 @@ object WordCount {
37
): DStream[WordCount] = {
38
39
import scala.language.implicitConversions
40
- implicit def finiteDurationToSparkDuration(value: FiniteDuration): Duration = new Duration(value.toMillis)
+ implicit def finiteDurationToSparkDuration(value: FiniteDuration): Duration = Duration(value.toMillis)
41
42
val sc = ssc.sparkContext
43
0 commit comments