Refactor more streaming json splitting
Abstract push to a directory