A stream-processing and analytics miniframework