Does NiFi have the concept of an "end of stream" or is it designed to pretty
much always be running? For example if I use a GetFile processor pointing at
a single directory (with remove files = true), once all the files have been
processed, can downstream processors know that?
I'm working on a ReservoirSampling processor, and I have it successfully
building the reservoir from all incoming FlowFiles. However it never gets to
the logic that sends the sampled FlowFiles to the downstream processor (just
a PutFile at this point). I have the logic in a block like:
FlowFile flowFile = session.get();
if(flowFile == null) {
// send reservoir
}
else {
// build reservoir
}
But the if-clause never gets entered. Is there a different approach and/or
am I misunderstanding how the data flow works?
Thanks in advance,
Matt
