IN
- public class ContextRealTimeWindowFunction<IN> extends Object implements Function<Stream<IN>,Stream<Context>>
Constructor and Description |
---|
ContextRealTimeWindowFunction(long waitTime) |
Modifier and Type | Method and Description |
---|---|
Stream<Context> |
apply(Stream<IN> inner)
Apply the function to the input argument and return the result.
|