This is RouteOnAttribute processor. As you can see I have 2 properties defined. I want to use fileTransfer property to route to GetFile processor. And this is connection dialog box for one of the existing connections, and it lists 'fileTransfer' as a relationship.   ... View more

Its a script processor to run a groovy script. If a functional error is detected, I need to send original input file over FTP. ... View more

Error is in processor. Basically a functional error, nothing to do with nifi. ... View more

My attempt so far: List<RecordField> fields = new ArrayList<>(); RecordField field1= new RecordField("field1", RecordFieldType.STRING.getDataType()); fields.add(field1); .... .... SimpleRecordSchema schema = new SimpleRecordSchema(fields); final Record mapRecord = new MapRecord(schema, new HashMap<>()); final List<FieldValue> selectedFields = new ArrayList<>(); //TODO how to create corresponding FieldValue instances from raw values for (final FieldValue selectedField : selectedFields) { mapRecord.setValue(selectedField.getField(), selectedField.getValue()); } ... View more

So my requirement is that I have to take some selected fields from input record, do some computations with them, create a new Record with new fields which are populated with these computed values, and write this new record into output flow file. I have to do it all in a custom processor I am writing. ... View more