making all incremental transforms take (stream_item, context) as input
making all incremental transforms take (stream_item, context) as input

trec-kba/streamcorpus-pipeline,trec-kba/streamcorpus-pipeline,trec-kba/streamcorpus-pipeline