Package | Description |
---|---|
org.apache.storm.trident.operation | |
org.apache.storm.trident.state |
Modifier and Type | Interface and Description |
---|---|
interface |
Aggregator<T> |
interface |
EachOperation |
interface |
Filter
Filters take in a tuple as input and decide whether or not to keep that tuple or not.
|
interface |
Function
A function takes in a set of input fields and emits zero or more tuples as output.
|
interface |
OperationAwareFlatMapFunction
A one to many transformation function which is aware of Operation (lifecycle of the Trident component).
|
interface |
OperationAwareMapFunction
A one-one transformation function which is aware of Operation (lifecycle of the Trident component).
|
Modifier and Type | Interface and Description |
---|---|
interface |
QueryFunction<S extends State,T> |
interface |
StateUpdater<S extends State> |
Copyright © 2019 The Apache Software Foundation. All rights reserved.