Skip to content

O
orders-monitoring-dashboard
Commit 96c532dd authored by Ramakanth Dhane's avatar Ramakanth Dhane
Browse files
Options

Merge branch 'master' into 'master' 

spark save mongo data change

See merge request !18
parents c6cd8a62 8b1837aa
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 @ 96c532dd
...@@ -16,7 +16,7 @@ public class OmdSparkStreamRepositoryImpl { ...@@ -16,7 +16,7 @@ public class OmdSparkStreamRepositoryImpl {
JavaDStream<ConsumerRecord<String, String>> recordJavaDStream = 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) -> { recordJavaDStream.foreachRDD((JavaRDD<ConsumerRecord<String, String>> r) -> {
MongoSpark.save( 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