Java Datastream Management