Package | Description |
---|---|
org.apache.storm.trident.planner | |
org.apache.storm.trident.planner.processor | |
org.apache.storm.trident.windowing |
Modifier and Type | Interface and Description |
---|---|
interface |
TridentProcessor |
Modifier and Type | Class and Description |
---|---|
class |
BridgeReceiver |
Modifier and Type | Class and Description |
---|---|
class |
AggregateProcessor |
class |
EachProcessor |
class |
MapProcessor
Processor for executing
Stream.map(MapFunction) and Stream.flatMap(FlatMapFunction) functions. |
class |
MultiReducerProcessor |
class |
PartitionPersistProcessor |
class |
ProjectedProcessor |
class |
StateQueryProcessor |
Modifier and Type | Method and Description |
---|---|
List<TupleReceiver> |
TridentContext.getReceivers() |
Constructor and Description |
---|
TridentContext(Fields selfFields,
List<TridentTuple.Factory> parentFactories,
List<String> parentStreams,
List<TupleReceiver> receivers,
String outStreamId,
int stateIndex,
BatchOutputCollector collector) |
Modifier and Type | Class and Description |
---|---|
class |
WindowTridentProcessor
TridentProcessor implementation for windowing operations on trident stream. |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.