Class | Description |
---|---|
OnConnectedStream<IN1,IN2> |
Wraps a connected data stream, allowing to use anonymous partial functions to
perform extraction of items in a tuple, case class instance or collection
|
OnDataStream<T> |
Wraps a data stream, allowing to use anonymous partial functions to
perform extraction of items in a tuple, case class instance or collection
|
OnJoinedStream<L,R,K,W extends Window> |
Wraps a joined data stream, allowing to use anonymous partial functions to
perform extraction of items in a tuple, case class instance or collection
|
OnKeyedStream<T,K> |
Wraps a keyed data stream, allowing to use anonymous partial functions to
perform extraction of items in a tuple, case class instance or collection
|
OnWindowedStream<T,K,W extends Window> |
Wraps a joined data stream, allowing to use anonymous partial functions to
perform extraction of items in a tuple, case class instance or collection
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.