Skip to content

Instantly share code, notes, and snippets.

@ijokarumawak
ijokarumawak / .gitignore
Last active April 27, 2017 17:42
Examples utilizing RollbackOnFailure added by NIFI-3415.
.DS_Store
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
import os, sys, imp, traceback, time
parser_path = '/scripts/parsers/'
class PyStreamCallback(StreamCallback):
def __init__(self, result):
self.result = result