IN
public class ContextRealTimeWindowFunction<IN> extends Object implements Function<Stream<IN>,Stream<Context>>
ContextRealTimeWindowFunction(long waitTime)
Stream<Context>
apply(Stream<IN> inner)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ContextRealTimeWindowFunction(long waitTime)
waitTime
public Stream<Context> apply(Stream<IN> inner)
Function
apply
Function<Stream<IN>,Stream<Context>>
inner