Skip to content

O
orders-monitoring-dashboard
Commit 8b1837aa authored by rani0808's avatar rani0808
Browse files
Options

spark save mongo data change

parent c96170dd
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
omd-stream-processor/src/main/java/com/nisum/omd/mongo/repository/OmdSparkStreamRepositoryImpl.java
View file @ 8b1837aa
......@@ -16,7 +16,7 @@ public class OmdSparkStreamRepositoryImpl {
JavaDStream<ConsumerRecord<String, String>> recordJavaDStream =
orderStream.filter(f -> !f.value().contains("\"guests\":0"));
orderStream.filter(f -> !f.value().contains("\"orderNum\":0"));
recordJavaDStream.foreachRDD((JavaRDD<ConsumerRecord<String, String>> r) -> {
MongoSpark.save(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment