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 |
SubtopologyBolt.InitialReceiver.getOutputFactory() |
TridentTuple.Factory |
TridentProcessor.getOutputFactory() |
Modifier and Type | Method and Description |
---|---|
TridentTuple.Factory |
AggregateProcessor.getOutputFactory() |
TridentTuple.Factory |
ProjectedProcessor.getOutputFactory() |
TridentTuple.Factory |
StateQueryProcessor.getOutputFactory() |
TridentTuple.Factory |
PartitionPersistProcessor.getOutputFactory() |
TridentTuple.Factory |
MapProcessor.getOutputFactory() |
TridentTuple.Factory |
AppendCollector.getOutputFactory() |
TridentTuple.Factory |
EachProcessor.getOutputFactory() |
TridentTuple.Factory |
FreshCollector.getOutputFactory() |
TridentTuple.Factory |
MultiReducerProcessor.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 © 2020 The Apache Software Foundation. All rights reserved.