removed my debug temp method

jpzk · Sep 15, 2017 · e7aa8fc · e7aa8fc
1 parent 3757c42
commit e7aa8fc
Showing 1 changed file with 0 additions and 12 deletions.
diff --git a/src/test/scala/MockedStreamsSpec.scala b/src/test/scala/MockedStreamsSpec.scala
@@ -227,18 +227,6 @@ class MockedStreamsSpec extends FlatSpec with Matchers {
           .to(strings, ints, OutputATopic)
       }
 
-      def topology1Outputbis(builder: KStreamBuilder) = {
-        val streamA = builder.stream(strings, ints, InputATopic)
-        val streamB = builder.stream(strings, ints, InputBTopic)
-
-        val table = streamB.groupByKey(strings, ints).aggregate(
-          new LastInitializer,
-          new LastAggregator, ints, StoreName)
-
-        streamA.leftJoin[Integer, Integer](table, new AddJoiner(), strings, ints)
-          .to(strings, ints, OutputATopic)
-      }
-
       def topology1WindowOutput(builder: KStreamBuilder) = {
         val streamA = builder.stream(strings, ints, InputCTopic)
         streamA.groupByKey(strings, ints).count(