Uses of Interface
org.apache.storm.grouping.CustomStreamGrouping
-
-
Uses of CustomStreamGrouping in org.apache.storm.daemon
Classes in org.apache.storm.daemon that implement CustomStreamGrouping Modifier and Type Class Description static classGrouperFactory.AllGrouperstatic classGrouperFactory.BasicLoadAwareCustomStreamGroupingA bridge between CustomStreamGrouping and LoadAwareCustomStreamGrouping.static classGrouperFactory.FieldsGrouperstatic classGrouperFactory.GlobalGrouperstatic classGrouperFactory.NoneGrouperConstructors in org.apache.storm.daemon with parameters of type CustomStreamGrouping Constructor Description BasicLoadAwareCustomStreamGrouping(CustomStreamGrouping customStreamGrouping) -
Uses of CustomStreamGrouping in org.apache.storm.drpc
Methods in org.apache.storm.drpc with parameters of type CustomStreamGrouping Modifier and Type Method Description LinearDRPCInputDeclarerLinearDRPCInputDeclarer. customGrouping(String streamId, CustomStreamGrouping grouping)LinearDRPCInputDeclarerLinearDRPCInputDeclarer. customGrouping(CustomStreamGrouping grouping) -
Uses of CustomStreamGrouping in org.apache.storm.grouping
Subinterfaces of CustomStreamGrouping in org.apache.storm.grouping Modifier and Type Interface Description interfaceLoadAwareCustomStreamGroupingClasses in org.apache.storm.grouping that implement CustomStreamGrouping Modifier and Type Class Description classLoadAwareShuffleGroupingclassPartialKeyGroupingA variation on FieldGrouping.classShuffleGrouping -
Uses of CustomStreamGrouping in org.apache.storm.testing
Classes in org.apache.storm.testing that implement CustomStreamGrouping Modifier and Type Class Description classNGrouping -
Uses of CustomStreamGrouping in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type CustomStreamGrouping Modifier and Type Method Description TInputDeclarer. customGrouping(String componentId, String streamId, CustomStreamGrouping grouping)A custom stream grouping by implementing the CustomStreamGrouping interface.TInputDeclarer. customGrouping(String componentId, CustomStreamGrouping grouping)A custom stream grouping by implementing the CustomStreamGrouping interface.BoltDeclarerTopologyBuilder.BoltGetter. customGrouping(String componentId, String streamId, CustomStreamGrouping grouping)BoltDeclarerTopologyBuilder.BoltGetter. customGrouping(String componentId, CustomStreamGrouping grouping) -
Uses of CustomStreamGrouping in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type CustomStreamGrouping Modifier and Type Method Description StreamStream. partition(CustomStreamGrouping partitioner)## Repartitioning Operation. -
Uses of CustomStreamGrouping in org.apache.storm.trident.partition
Classes in org.apache.storm.trident.partition that implement CustomStreamGrouping Modifier and Type Class Description classGlobalGroupingclassIdentityGroupingclassIndexHashGrouping
-