Modifier and Type | Method and Description |
---|---|
Map<GlobalStreamId,Grouping> |
Thrift.BoltDetails.getInputs() |
Constructor and Description |
---|
BoltDetails(Object bolt,
Map<String,Object> conf,
Integer parallelism,
Map<GlobalStreamId,Grouping> inputs) |
Modifier and Type | Method and Description |
---|---|
void |
Murmur3StreamGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks)
Tells the stream grouping at runtime the tasks in the target bolt.
|
Modifier and Type | Method and Description |
---|---|
GlobalStreamId |
CoordinatedBolt.IdStreamSpec.getGlobalStreamId() |
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 |
---|---|
void |
GrouperFactory.BasicLoadAwareCustomStreamGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
void |
GrouperFactory.FieldsGrouper.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
void |
GrouperFactory.GlobalGrouper.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
void |
GrouperFactory.NoneGrouper.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
void |
GrouperFactory.AllGrouper.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
UIHelpers.getInputMap(Map.Entry<GlobalStreamId,Grouping> entryInput)
getInputMap.
|
Modifier and Type | Method and Description |
---|---|
GlobalStreamId |
GlobalStreamId.deepCopy() |
Modifier and Type | Method and Description |
---|---|
Map<String,Map<GlobalStreamId,Long>> |
BoltStats.get_acked() |
Map<String,Map<GlobalStreamId,Double>> |
BoltStats.get_execute_ms_avg() |
Map<String,Map<GlobalStreamId,Long>> |
BoltStats.get_executed() |
Map<String,Map<GlobalStreamId,Long>> |
BoltStats.get_failed() |
Map<GlobalStreamId,ComponentAggregateStats> |
ComponentPageInfo.get_gsid_to_input_stats() |
Map<GlobalStreamId,Grouping> |
ComponentCommon.get_inputs() |
Map<String,Map<GlobalStreamId,Double>> |
BoltStats.get_process_ms_avg() |
Modifier and Type | Method and Description |
---|---|
int |
GlobalStreamId.compareTo(GlobalStreamId other) |
boolean |
GlobalStreamId.equals(GlobalStreamId that) |
void |
ComponentPageInfo.put_to_gsid_to_input_stats(GlobalStreamId key,
ComponentAggregateStats val) |
void |
ComponentCommon.put_to_inputs(GlobalStreamId key,
Grouping val) |
Constructor and Description |
---|
GlobalStreamId(GlobalStreamId other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
void |
ShuffleGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
void |
LoadAwareShuffleGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
void |
CustomStreamGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks)
Tells the stream grouping at runtime the tasks in the target bolt.
|
void |
PartialKeyGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
Modifier and Type | Method and Description |
---|---|
GlobalStreamId |
InputStream.gsid()
Get the global stream id for this input stream.
|
Modifier and Type | Method and Description |
---|---|
InputStream |
InputStream.remap(Map<String,String> remappedComponents,
Map<GlobalStreamId,GlobalStreamId> remappedStreams)
Remap the names of components.
|
InputStream |
InputStream.remap(Map<String,String> remappedComponents,
Map<GlobalStreamId,GlobalStreamId> remappedStreams)
Remap the names of components.
|
LoadCompConf |
LoadCompConf.remap(Map<String,String> remappedComponents,
Map<GlobalStreamId,GlobalStreamId> remappedStreams)
Chenge the name of components and streams according to the parameters passed in.
|
LoadCompConf |
LoadCompConf.remap(Map<String,String> remappedComponents,
Map<GlobalStreamId,GlobalStreamId> remappedStreams)
Chenge the name of components and streams according to the parameters passed in.
|
OutputStream |
OutputStream.remap(String origId,
Map<GlobalStreamId,GlobalStreamId> remappedStreams) |
OutputStream |
OutputStream.remap(String origId,
Map<GlobalStreamId,GlobalStreamId> remappedStreams) |
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<GlobalStreamId,Grouping> |
TopologyContext.getThisSources()
Gets the declared inputs to this component.
|
Modifier and Type | Method and Description |
---|---|
Fields |
GeneralTopologyContext.getComponentOutputFields(GlobalStreamId id)
Gets the declared output fields for the specified global stream id.
|
Modifier and Type | Method and Description |
---|---|
void |
NGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
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 |
---|---|
void |
GlobalGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targets) |
void |
IndexHashGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks) |
void |
IdentityGrouping.prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> tasks) |
Modifier and Type | Field and Description |
---|---|
GlobalStreamId |
TridentBoltExecutor.CoordSpec.commitStream |
GlobalStreamId |
TridentBoltExecutor.CoordCondition.commitStream |
Constructor and Description |
---|
TridentBoltExecutor(ITridentBatchBolt bolt,
Map<GlobalStreamId,String> batchGroupIds,
Map<String,TridentBoltExecutor.CoordSpec> coordinationSpecs) |
Modifier and Type | Method and Description |
---|---|
GlobalStreamId |
Tuple.getSourceGlobalStreamId()
Returns the global stream id (component + stream) of this tuple.
|
GlobalStreamId |
TupleImpl.getSourceGlobalStreamId() |
Modifier and Type | Method and Description |
---|---|
static GlobalStreamId |
Utils.getGlobalStreamId(String componentId,
String streamId) |
Modifier and Type | Method and Description |
---|---|
boolean |
WaterMarkEventGenerator.track(GlobalStreamId stream,
long ts)
Tracks the timestamp of the event in the stream, returns true if the event can be considered for processing or false if its a late
event.
|
Constructor and Description |
---|
WaterMarkEventGenerator(WindowManager<T> windowManager,
int intervalMs,
int eventTsLagMs,
Set<GlobalStreamId> inputStreams)
Creates a new WatermarkEventGenerator.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.