Thursday 12 October 2017

How to Create Get and Put Processors in NiFi (Intellij/Windows)

Put: Takes input and puts it in a format eg, putSQL will take the Flowfile from the input and put it into SQL
@Overridepublic void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {
    FlowFile flowFile = session.get();
    if ( flowFile == null ) {
        return;
    }

Get: Takes raw input and puts it into a Flowfile
@Overridepublic void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {
    FlowFile flowFile = session.create();

No comments:

Post a Comment