-
- Downloads
Changed variable name form ***Time to ***Duration to keep things consistent.
Showing
- streaming/src/main/scala/spark/streaming/Checkpoint.scala 1 addition, 1 deletionstreaming/src/main/scala/spark/streaming/Checkpoint.scala
- streaming/src/main/scala/spark/streaming/DStream.scala 45 additions, 45 deletionsstreaming/src/main/scala/spark/streaming/DStream.scala
- streaming/src/main/scala/spark/streaming/Duration.scala 1 addition, 1 deletionstreaming/src/main/scala/spark/streaming/Duration.scala
- streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala 33 additions, 37 deletions...src/main/scala/spark/streaming/PairDStreamFunctions.scala
- streaming/src/main/scala/spark/streaming/Scheduler.scala 2 additions, 2 deletionsstreaming/src/main/scala/spark/streaming/Scheduler.scala
- streaming/src/main/scala/spark/streaming/StreamingContext.scala 6 additions, 6 deletions...ing/src/main/scala/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/spark/streaming/Time.scala 8 additions, 14 deletionsstreaming/src/main/scala/spark/streaming/Time.scala
- streaming/src/main/scala/spark/streaming/dstream/CoGroupedDStream.scala 2 additions, 2 deletions...main/scala/spark/streaming/dstream/CoGroupedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/FilteredDStream.scala 1 addition, 1 deletion.../main/scala/spark/streaming/dstream/FilteredDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/FlatMapValuedDStream.scala 1 addition, 1 deletion.../scala/spark/streaming/dstream/FlatMapValuedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/FlatMappedDStream.scala 1 addition, 1 deletion...ain/scala/spark/streaming/dstream/FlatMappedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/ForEachDStream.scala 1 addition, 1 deletion...c/main/scala/spark/streaming/dstream/ForEachDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/GlommedDStream.scala 1 addition, 1 deletion...c/main/scala/spark/streaming/dstream/GlommedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/InputDStream.scala 1 addition, 1 deletion...src/main/scala/spark/streaming/dstream/InputDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/MapPartitionedDStream.scala 1 addition, 1 deletion...scala/spark/streaming/dstream/MapPartitionedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/MapValuedDStream.scala 1 addition, 1 deletion...main/scala/spark/streaming/dstream/MapValuedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/MappedDStream.scala 1 addition, 1 deletion...rc/main/scala/spark/streaming/dstream/MappedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/ReducedWindowedDStream.scala 17 additions, 17 deletions...cala/spark/streaming/dstream/ReducedWindowedDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/ShuffledDStream.scala 1 addition, 1 deletion.../main/scala/spark/streaming/dstream/ShuffledDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/StateDStream.scala 2 additions, 2 deletions...src/main/scala/spark/streaming/dstream/StateDStream.scala
Loading
Please register or sign in to comment