progress on input csw stream processing