Sorry all for my earlier messages. I just realized that I'm on the wrong
mailing list for what I'm asking. I will move my question to the user list.
On Friday, April 21, 2017 11:54 AM, Blake Essing wrote:
Sorry for the earlier incomplete email, E-mail editor issue.
I hav
Count() + b.getCount()); } })
text is just a DataStream populated from NiFi where lines are broken
up into individual strings.
WordCounter is a simple pojo that stores the word and a count with get/set
methods.
Please let me know if you have any questions about the code.
On Friday, April 21, 2017 11
I have modified the WordCounter example program to use a NiFi DataStream as
input. I would like to add checkpointing to the program to learn how it works.
I have googled and added many of the checkpointing configuration values to the
StreamExecutionEnvironment but I'm missing something critica
