From deaa798c50ac0c1f0dfd453a4033e57deca19d81 Mon Sep 17 00:00:00 2001 From: Jeff Chao Date: Fri, 10 Nov 2017 13:32:20 -0800 Subject: [PATCH] Code cleanup. --- .../io/jeffchao/streams/textprocessor/TextProcessor.java | 9 --------- 1 file changed, 9 deletions(-) diff --git a/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java b/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java index d5c6557..e638f7b 100644 --- a/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java +++ b/streams-text-processor/src/main/java/io/jeffchao/streams/textprocessor/TextProcessor.java @@ -48,15 +48,6 @@ public static void main(String[] args) throws CertificateException, NoSuchAlgori .flatMapValues(value -> Arrays.asList(pattern.split(value.toLowerCase()))) .to(String.format("%swords", TOPIC_PREFIX), Produced.with(stringSerde, stringSerde)); - // final KTable wordCounts = textLines - // .flatMapValues(value -> Arrays.asList(pattern.split(value.toLowerCase()))) - // .groupBy((key, word) -> word) - // .count(Materialized.as("counts")); - - // wordCounts.toStream() - // .to(String.format("%swordswithcounts", TOPIC_PREFIX), - // Produced.with(stringSerde, longSerde)); - final KafkaStreams streams = new KafkaStreams(builder.build(), streamsConfig); streams.cleanUp();