Uses of Class
org.apache.storm.generated.Grouping
-
-
Uses of Grouping in org.apache.storm
Methods in org.apache.storm that return Grouping Modifier and Type Method Description static 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 Grouping Modifier and Type Method Description Map<GlobalStreamId,Grouping>Thrift.BoltDetails. getInputs()Methods in org.apache.storm with parameters of type Grouping Modifier and Type Method Description static List<String>Thrift. fieldGrouping(Grouping grouping)static Grouping._FieldsThrift. groupingType(Grouping grouping)static booleanThrift. isGlobalGrouping(Grouping grouping) -
Uses of Grouping in org.apache.storm.daemon
Methods in org.apache.storm.daemon that return types with arguments of type Grouping Modifier and Type Method Description static 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 Grouping Modifier and Type Method Description static LoadAwareCustomStreamGroupingGrouperFactory. 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 Constructor Description FieldsGrouper(Fields outFields, Grouping thriftGrouping) -
Uses of Grouping in org.apache.storm.daemon.ui
Method parameters in org.apache.storm.daemon.ui with type arguments of type Grouping Modifier and Type Method Description static Map<String,Object>UIHelpers. getInputMap(Map.Entry<GlobalStreamId,Grouping> entryInput)getInputMap. -
Uses of Grouping in org.apache.storm.generated
Methods in org.apache.storm.generated that return Grouping Modifier and Type Method Description static GroupingGrouping. all(NullStruct value)static GroupingGrouping. custom_object(JavaObject value)static GroupingGrouping. custom_serialized(byte[] value)static GroupingGrouping. custom_serialized(ByteBuffer value)GroupingGrouping. deepCopy()static GroupingGrouping. direct(NullStruct value)static GroupingGrouping. fields(List<String> value)static 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 Grouping Modifier and Type Method Description Map<GlobalStreamId,Grouping>ComponentCommon. get_inputs()Methods in org.apache.storm.generated with parameters of type Grouping Modifier and Type Method Description intGrouping. compareTo(Grouping other)booleanGrouping. equals(Grouping other)voidComponentCommon. put_to_inputs(GlobalStreamId key, Grouping val)Method parameters in org.apache.storm.generated with type arguments of type Grouping Modifier and Type Method Description voidComponentCommon. set_inputs(Map<GlobalStreamId,Grouping> inputs)Constructors in org.apache.storm.generated with parameters of type Grouping Constructor Description Grouping(Grouping other)Constructor parameters in org.apache.storm.generated with type arguments of type Grouping Constructor Description ComponentCommon(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 Grouping Modifier and Type Method Description InputStream.BuilderInputStream.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 Grouping Modifier and Type Method Description Map<GlobalStreamId,Grouping>Component. getInputs()Constructor parameters in org.apache.storm.scheduler with type arguments of type Grouping Constructor Description Component(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 Grouping Modifier and Type Method Description Map<GlobalStreamId,Grouping>GeneralTopologyContext. getSources(String componentId)Gets the declared inputs to the specified component.Map<String,Map<String,Grouping>>GeneralTopologyContext. getTargets(String componentId)Gets information about who is consuming the outputs of the specified component, and how.Map<GlobalStreamId,Grouping>TopologyContext. getThisSources()Gets the declared inputs to this component.Map<String,Map<String,Grouping>>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 Grouping Modifier and Type Method Description TInputDeclarer. grouping(GlobalStreamId id, Grouping grouping)BoltDeclarerTopologyBuilder.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 Modifier and Type Method Description StreamStream. partition(Grouping grouping)## Repartitioning Operation. -
Uses of Grouping in org.apache.storm.trident.planner
Fields in org.apache.storm.trident.planner declared as Grouping Modifier and Type Field Description GroupingPartitionNode. thriftGroupingConstructors in org.apache.storm.trident.planner with parameters of type Grouping Constructor Description PartitionNode(String streamId, String name, Fields allOutputFields, Grouping grouping)
-