modifications for ingestion, which doesn't work anyway as storm doesn't call
cleanup() for bolts in distributed mode, hence the files are not closed