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.
|