Uses of Class
org.apache.storm.generated.Grouping
Packages that use Grouping
Package
Description
-
Uses of Grouping in org.apache.storm
Methods in org.apache.storm that return GroupingModifier and TypeMethodDescriptionstatic GroupingThrift.prepareAllGrouping()static GroupingThrift.prepareCustomJavaObjectGrouping(JavaObject obj) static GroupingThrift.prepareCustomStreamGrouping(Object obj) static GroupingThrift.prepareDirectGrouping()static GroupingThrift.prepareFieldsGrouping(List<String> fields) static GroupingThrift.prepareGlobalGrouping()static GroupingThrift.prepareLocalOrShuffleGrouping()static GroupingThrift.prepareNoneGrouping()static GroupingThrift.prepareShuffleGrouping()Methods in org.apache.storm that return types with arguments of type GroupingMethods in org.apache.storm with parameters of type GroupingModifier and TypeMethodDescriptionThrift.fieldGrouping(Grouping grouping) static Grouping._FieldsThrift.groupingType(Grouping grouping) static booleanThrift.isGlobalGrouping(Grouping grouping) Method parameters in org.apache.storm with type arguments of type GroupingModifier and TypeMethodDescriptionstatic Thrift.BoltDetailsThrift.prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt) static Thrift.BoltDetailsThrift.prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint) static Thrift.BoltDetailsThrift.prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint, Map<String, Object> conf) static ComponentCommonThrift.prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint) static ComponentCommonThrift.prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) static BoltThrift.prepareSerializedBoltDetails(Map<GlobalStreamId, Grouping> inputs, IBolt bolt, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) -
Uses of Grouping in org.apache.storm.daemon
Methods in org.apache.storm.daemon that return types with arguments of type GroupingModifier and TypeMethodDescriptionstatic Map<GlobalStreamId,Grouping> StormCommon.ackerInputs(StormTopology topology) static Map<GlobalStreamId,Grouping> StormCommon.eventLoggerInputs(StormTopology topology) Methods in org.apache.storm.daemon with parameters of type GroupingModifier and TypeMethodDescriptionGrouperFactory.mkGrouper(WorkerTopologyContext context, String componentId, String streamId, Fields outFields, Grouping thriftGrouping, List<Integer> unsortedTargetTasks, Map<String, Object> topoConf) Constructors in org.apache.storm.daemon with parameters of type Grouping -
Uses of Grouping in org.apache.storm.daemon.ui
Method parameters in org.apache.storm.daemon.ui with type arguments of type GroupingModifier and TypeMethodDescriptionUIHelpers.getInputMap(Map.Entry<GlobalStreamId, Grouping> entryInput) getInputMap. -
Uses of Grouping in org.apache.storm.generated
Methods in org.apache.storm.generated that return GroupingModifier and TypeMethodDescriptionstatic GroupingGrouping.all(NullStruct value) static GroupingGrouping.custom_object(JavaObject value) static GroupingGrouping.custom_serialized(byte[] value) static GroupingGrouping.custom_serialized(ByteBuffer value) Grouping.deepCopy()static GroupingGrouping.direct(NullStruct value) static Groupingstatic GroupingGrouping.local_or_shuffle(NullStruct value) static GroupingGrouping.none(NullStruct value) static GroupingGrouping.shuffle(NullStruct value) Methods in org.apache.storm.generated that return types with arguments of type GroupingMethods in org.apache.storm.generated with parameters of type GroupingModifier and TypeMethodDescriptionintbooleanvoidComponentCommon.put_to_inputs(GlobalStreamId key, Grouping val) Method parameters in org.apache.storm.generated with type arguments of type GroupingModifier and TypeMethodDescriptionvoidComponentCommon.set_inputs(Map<GlobalStreamId, Grouping> inputs) Constructors in org.apache.storm.generated with parameters of type GroupingConstructor parameters in org.apache.storm.generated with type arguments of type GroupingModifierConstructorDescriptionComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> streams) -
Uses of Grouping in org.apache.storm.loadgen
Methods in org.apache.storm.loadgen with parameters of type GroupingModifier and TypeMethodDescriptionInputStream.Builder.withGroupingType(Grouping grouping) Add the grouping type based off of the thrift Grouping class. -
Uses of Grouping in org.apache.storm.scheduler
Methods in org.apache.storm.scheduler that return types with arguments of type GroupingConstructor parameters in org.apache.storm.scheduler with type arguments of type GroupingModifierConstructorDescriptionComponent(ComponentType type, String compId, List<ExecutorDetails> execs, Map<GlobalStreamId, Grouping> inputs) Create a new component. -
Uses of Grouping in org.apache.storm.task
Methods in org.apache.storm.task that return types with arguments of type GroupingModifier and TypeMethodDescriptionGeneralTopologyContext.getSources(String componentId) Gets the declared inputs to the specified component.GeneralTopologyContext.getTargets(String componentId) Gets information about who is consuming the outputs of the specified component, and how.TopologyContext.getThisSources()Gets the declared inputs to this component.TopologyContext.getThisTargets()Gets information about who is consuming the outputs of this component, and how. -
Uses of Grouping in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type GroupingModifier and TypeMethodDescriptionInputDeclarer.grouping(GlobalStreamId id, Grouping grouping) TopologyBuilder.BoltGetter.grouping(GlobalStreamId id, Grouping grouping) -
Uses of Grouping in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type Grouping -
Uses of Grouping in org.apache.storm.trident.planner
Fields in org.apache.storm.trident.planner declared as GroupingConstructors in org.apache.storm.trident.planner with parameters of type GroupingModifierConstructorDescriptionPartitionNode(String streamId, String name, Fields allOutputFields, Grouping grouping)