Implement NiFi v1.1 RecordWriter interface.
@@ -42,6 +42,11 @@ public class ThinkbigRecordWriterDelegate implements RecordWriter {
}
+ @Override
+ public void flush() throws IOException {
+ recordWriter.flush();
+ }
+
@Override
public int getRecordsWritten() {
return recordWriter.getRecordsWritten();
