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() |
Modifier and Type | Method and Description |
---|---|
Map<GlobalStreamId,Grouping> |
Thrift.BoltDetails.getInputs() |
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) |
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 and Description |
---|
BoltDetails(Object bolt,
Map<String,Object> conf,
Integer parallelism,
Map<GlobalStreamId,Grouping> inputs) |
Modifier and Type | Method and Description |
---|---|
static Map<GlobalStreamId,Grouping> |
StormCommon.ackerInputs(StormTopology topology) |
static Map<GlobalStreamId,Grouping> |
StormCommon.eventLoggerInputs(StormTopology topology) |
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) |
Constructor and Description |
---|
FieldsGrouper(Fields outFields,
Grouping thriftGrouping) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
UIHelpers.getInputMap(Map.Entry<GlobalStreamId,Grouping> entryInput)
getInputMap.
|
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) |
Modifier and Type | Method and Description |
---|---|
Map<GlobalStreamId,Grouping> |
ComponentCommon.get_inputs() |
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) |
Modifier and Type | Method and Description |
---|---|
void |
ComponentCommon.set_inputs(Map<GlobalStreamId,Grouping> inputs) |
Constructor and Description |
---|
Grouping(Grouping other) |
Constructor and Description |
---|
ComponentCommon(Map<GlobalStreamId,Grouping> inputs,
Map<String,StreamInfo> streams) |
Modifier and Type | Method and Description |
---|---|
InputStream.Builder |
InputStream.Builder.withGroupingType(Grouping grouping)
Add the grouping type based off of the thrift Grouping class.
|
Modifier and Type | Method and Description |
---|---|
Map<GlobalStreamId,Grouping> |
Component.getInputs() |
Constructor and Description |
---|
Component(ComponentType type,
String compId,
List<ExecutorDetails> execs,
Map<GlobalStreamId,Grouping> inputs)
Create a new component.
|
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.
|
Modifier and Type | Method and Description |
---|---|
T |
InputDeclarer.grouping(GlobalStreamId id,
Grouping grouping) |
BoltDeclarer |
TopologyBuilder.BoltGetter.grouping(GlobalStreamId id,
Grouping grouping) |
Modifier and Type | Method and Description |
---|---|
Stream |
Stream.partition(Grouping grouping)
## Repartitioning Operation.
|
Modifier and Type | Field and Description |
---|---|
Grouping |
PartitionNode.thriftGrouping |
Constructor and Description |
---|
PartitionNode(String streamId,
String name,
Fields allOutputFields,
Grouping grouping) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.