| Class | Description |
|---|---|
| Pair<T1,T2> |
A pair of values.
|
| PairStream<K,V> |
Represents a stream of key-value pairs.
|
| ProcessorNode |
Node that wraps a processor in the stream.
|
| RefCountedTuple |
Provides reference counting of tuples.
|
| Stream<T> |
Represents a stream of values.
|
| StreamBuilder |
A builder for constructing a
StormTopology via storm streams api (DSL) |
| StreamState<K,V> |
A wrapper for the stream state which can be used to query the state via
Stream.stateQuery(StreamState) |
| StreamUtil | |
| WindowNode |
Node that captures the windowing configurations.
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.