Uses of Interface
org.apache.storm.trident.tuple.TridentTuple.Factory
-
-
Uses of TridentTuple.Factory in org.apache.storm.trident.operation
Constructors in org.apache.storm.trident.operation with parameters of type TridentTuple.Factory Constructor Description TridentOperationContext(TopologyContext topoContext, TridentTuple.Factory factory)
TridentOperationContext(TridentOperationContext parent, TridentTuple.Factory factory)
Constructor parameters in org.apache.storm.trident.operation with type arguments of type TridentTuple.Factory Constructor Description TridentMultiReducerContext(List<TridentTuple.Factory> factories)
-
Uses of TridentTuple.Factory in org.apache.storm.trident.planner
Methods in org.apache.storm.trident.planner that return TridentTuple.Factory Modifier and Type Method Description TridentTuple.Factory
SubtopologyBolt.InitialReceiver. getOutputFactory()
TridentTuple.Factory
TridentProcessor. getOutputFactory()
-
Uses of TridentTuple.Factory in org.apache.storm.trident.planner.processor
Methods in org.apache.storm.trident.planner.processor that return TridentTuple.Factory Modifier and Type Method Description TridentTuple.Factory
AggregateProcessor. getOutputFactory()
TridentTuple.Factory
AppendCollector. getOutputFactory()
TridentTuple.Factory
EachProcessor. getOutputFactory()
TridentTuple.Factory
FreshCollector. getOutputFactory()
TridentTuple.Factory
MapProcessor. getOutputFactory()
TridentTuple.Factory
MultiReducerProcessor. getOutputFactory()
TridentTuple.Factory
PartitionPersistProcessor. getOutputFactory()
TridentTuple.Factory
ProjectedProcessor. getOutputFactory()
TridentTuple.Factory
StateQueryProcessor. getOutputFactory()
Methods in org.apache.storm.trident.planner.processor that return types with arguments of type TridentTuple.Factory Modifier and Type Method Description List<TridentTuple.Factory>
TridentContext. getParentTupleFactories()
Constructor parameters in org.apache.storm.trident.planner.processor with type arguments of type TridentTuple.Factory Constructor Description TridentContext(Fields selfFields, List<TridentTuple.Factory> parentFactories, List<String> parentStreams, List<TupleReceiver> receivers, String outStreamId, int stateIndex, BatchOutputCollector collector)
-
Uses of TridentTuple.Factory in org.apache.storm.trident.tuple
Classes in org.apache.storm.trident.tuple that implement TridentTuple.Factory Modifier and Type Class Description static class
TridentTupleView.FreshOutputFactory
static class
TridentTupleView.OperationOutputFactory
static class
TridentTupleView.ProjectionFactory
static class
TridentTupleView.RootFactory
Constructors in org.apache.storm.trident.tuple with parameters of type TridentTuple.Factory Constructor Description OperationOutputFactory(TridentTuple.Factory parent, Fields selfFields)
ProjectionFactory(TridentTuple.Factory parent, Fields projectFields)
-
Uses of TridentTuple.Factory in org.apache.storm.trident.windowing
Methods in org.apache.storm.trident.windowing that return TridentTuple.Factory Modifier and Type Method Description TridentTuple.Factory
WindowTridentProcessor. getOutputFactory()
-