| Constructor and Description |
|---|
TridentOperationContext(TopologyContext topoContext,
TridentTuple.Factory factory) |
TridentOperationContext(TridentOperationContext parent,
TridentTuple.Factory factory) |
| Constructor and Description |
|---|
TridentMultiReducerContext(List<TridentTuple.Factory> factories) |
| Modifier and Type | Method and Description |
|---|---|
TridentTuple.Factory |
TridentProcessor.getOutputFactory() |
TridentTuple.Factory |
SubtopologyBolt.InitialReceiver.getOutputFactory() |
| Modifier and Type | Method and Description |
|---|---|
TridentTuple.Factory |
StateQueryProcessor.getOutputFactory() |
TridentTuple.Factory |
ProjectedProcessor.getOutputFactory() |
TridentTuple.Factory |
PartitionPersistProcessor.getOutputFactory() |
TridentTuple.Factory |
MultiReducerProcessor.getOutputFactory() |
TridentTuple.Factory |
MapProcessor.getOutputFactory() |
TridentTuple.Factory |
FreshCollector.getOutputFactory() |
TridentTuple.Factory |
EachProcessor.getOutputFactory() |
TridentTuple.Factory |
AppendCollector.getOutputFactory() |
TridentTuple.Factory |
AggregateProcessor.getOutputFactory() |
| Modifier and Type | Method and Description |
|---|---|
List<TridentTuple.Factory> |
TridentContext.getParentTupleFactories() |
| 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 |
|---|---|
static class |
TridentTupleView.FreshOutputFactory |
static class |
TridentTupleView.OperationOutputFactory |
static class |
TridentTupleView.ProjectionFactory |
static class |
TridentTupleView.RootFactory |
| Constructor and Description |
|---|
OperationOutputFactory(TridentTuple.Factory parent,
Fields selfFields) |
ProjectionFactory(TridentTuple.Factory parent,
Fields projectFields) |
| Modifier and Type | Method and Description |
|---|---|
TridentTuple.Factory |
WindowTridentProcessor.getOutputFactory() |
Copyright © 2019 The Apache Software Foundation. All rights reserved.