integration to run fatorie language analysis as a BatchTransform in streamcorpus.pipeline