Uses of Class
org.apache.storm.generated.Grouping

Packages that use Grouping

Package	Description
org.apache.storm
org.apache.storm.daemon
org.apache.storm.daemon.ui
org.apache.storm.generated
org.apache.storm.loadgen
org.apache.storm.task
org.apache.storm.topology
org.apache.storm.trident
org.apache.storm.trident.planner

Uses of Grouping in org.apache.storm

Methods in org.apache.storm that return Grouping

Modifier and Type	Method and Description
static Grouping	Thrift.prepareAllGrouping()
static Grouping	Thrift.prepareCustomJavaObjectGrouping(JavaObject obj)
static Grouping	Thrift.prepareCustomStreamGrouping(Object obj)
static Grouping	Thrift.prepareDirectGrouping()
static Grouping	Thrift.prepareFieldsGrouping(List<String> fields)
static Grouping	Thrift.prepareGlobalGrouping()
static Grouping	Thrift.prepareLocalOrShuffleGrouping()
static Grouping	Thrift.prepareNoneGrouping()
static Grouping	Thrift.prepareShuffleGrouping()

Methods in org.apache.storm that return types with arguments of type Grouping

Modifier and Type	Method and Description
Map<GlobalStreamId,Grouping>	Thrift.BoltDetails.getInputs()

Methods in org.apache.storm with parameters of type Grouping

Modifier and Type	Method and Description
static List<String>	Thrift.fieldGrouping(Grouping grouping)
static Grouping._Fields	Thrift.groupingType(Grouping grouping)
static boolean	Thrift.isGlobalGrouping(Grouping grouping)

Method parameters in org.apache.storm with type arguments of type Grouping

Modifier and Type	Method and Description
static Thrift.BoltDetails	Thrift.prepareBoltDetails(Map<GlobalStreamId,Grouping> inputs, Object bolt)
static Thrift.BoltDetails	Thrift.prepareBoltDetails(Map<GlobalStreamId,Grouping> inputs, Object bolt, Integer parallelismHint)
static Thrift.BoltDetails	Thrift.prepareBoltDetails(Map<GlobalStreamId,Grouping> inputs, Object bolt, Integer parallelismHint, Map<String,Object> conf)
static ComponentCommon	Thrift.prepareComponentCommon(Map<GlobalStreamId,Grouping> inputs, Map<String,StreamInfo> outputs, Integer parallelismHint)
static ComponentCommon	Thrift.prepareComponentCommon(Map<GlobalStreamId,Grouping> inputs, Map<String,StreamInfo> outputs, Integer parallelismHint, Map<String,Object> conf)
static Bolt	Thrift.prepareSerializedBoltDetails(Map<GlobalStreamId,Grouping> inputs, IBolt bolt, Map<String,StreamInfo> outputs, Integer parallelismHint, Map<String,Object> conf)

Constructor parameters in org.apache.storm with type arguments of type Grouping

Constructor and Description
BoltDetails(Object bolt, Map<String,Object> conf, Integer parallelism, Map<GlobalStreamId,Grouping> inputs)

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 and 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 and Description
static LoadAwareCustomStreamGrouping	GrouperFactory.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 and 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 and 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 and Description
static Grouping	Grouping.all(NullStruct value)
static Grouping	Grouping.custom_object(JavaObject value)
static Grouping	Grouping.custom_serialized(byte[] value)
static Grouping	Grouping.custom_serialized(ByteBuffer value)
Grouping	Grouping.deepCopy()
static Grouping	Grouping.direct(NullStruct value)
static Grouping	Grouping.fields(List<String> value)
static Grouping	Grouping.local_or_shuffle(NullStruct value)
static Grouping	Grouping.none(NullStruct value)
static Grouping	Grouping.shuffle(NullStruct value)

Methods in org.apache.storm.generated that return types with arguments of type Grouping

Modifier and Type	Method and Description
Map<GlobalStreamId,Grouping>	ComponentCommon.get_inputs()

Methods in org.apache.storm.generated with parameters of type Grouping

Modifier and Type	Method and Description
int	Grouping.compareTo(Grouping other)
boolean	Grouping.equals(Grouping other)
void	ComponentCommon.put_to_inputs(GlobalStreamId key, Grouping val)

Method parameters in org.apache.storm.generated with type arguments of type Grouping

Modifier and Type	Method and Description
void	ComponentCommon.set_inputs(Map<GlobalStreamId,Grouping> inputs)

Constructors in org.apache.storm.generated with parameters of type Grouping

Constructor and Description
Grouping(Grouping other)

Constructor parameters in org.apache.storm.generated with type arguments of type Grouping

Constructor and 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 and Description
InputStream.Builder	InputStream.Builder.withGroupingType(Grouping grouping) Add the grouping type based off of the thrift Grouping class.

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 and 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 and Description
BoltDeclarer	TopologyBuilder.BoltGetter.grouping(GlobalStreamId id, Grouping grouping)
T	InputDeclarer.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 and Description
Stream	Stream.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 and Description
Grouping	PartitionNode.thriftGrouping

Constructors in org.apache.storm.trident.planner with parameters of type Grouping

Constructor and Description
PartitionNode(String streamId, String name, Fields allOutputFields, Grouping grouping)