Advertisement
Guest User

Untitled

a guest
Aug 24th, 2016
63
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.55 KB | None | 0 0
  1. //perform avg/groupby operation on DF return result DF
  2. DataFrame outputDF = dataOperationService.performOperation(dataFrame);
  3. List<Row> rows = outputDF.collectAsList();
  4. KafkaProducer<String, String> producer = initKafkaProducer();
  5. try {
  6. for (Row row : rows) {
  7. String deptName = row.getString(0);
  8. double salary = row.getDouble(1);
  9. producer.send(new ProducerRecord<>(topicName, deptName+ "," + salary)).get();
  10. }
  11. } catch (Exception ignored) {
  12. System.out.println("Something went wrong.");
  13. } finally {
  14. producer.close();
  15. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement