Class and Description |
---|
Stream
Represents a stream of values.
|
Class and Description |
---|
Stream
Represents a stream of values.
|
StreamBuilder
A builder for constructing a
StormTopology via storm streams api (DSL). |
Class and Description |
---|
Pair
A pair of values.
|
Class and Description |
---|
Pair
A pair of values.
|
PairStream
Represents a stream of key-value pairs.
|
Stream
Represents a stream of values.
|
StreamBuilder
A builder for constructing a
StormTopology via storm streams api (DSL). |
StreamState
A wrapper for the stream state which can be used to query the state via
Stream.stateQuery(StreamState) . |
Class and Description |
---|
Pair
A pair of values.
|
Class and Description |
---|
Pair
A pair of values.
|
Class and Description |
---|
Pair
A pair of values.
|
ProcessorNode
Node that wraps a processor in the stream.
|
RefCountedTuple
Provides reference counting of tuples.
|
StreamState
A wrapper for the stream state which can be used to query the state via
Stream.stateQuery(StreamState) . |
Class and Description |
---|
Pair
A pair of values.
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.