A collection of streams operators and functions to faciliate a predictive analysis algorithm written in IBM Infosphere.