本文整理了Java中backtype.storm.task.TopologyContext.getThisSourceComponentTasks()
方法的一些代码示例,展示了TopologyContext.getThisSourceComponentTasks()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TopologyContext.getThisSourceComponentTasks()
方法的具体详情如下:
包路径:backtype.storm.task.TopologyContext
类名称:TopologyContext
方法名:getThisSourceComponentTasks
暂无
代码示例来源:origin: alibaba/jstorm
public void prepare(Map conf, TopologyContext context, OutputCollector collector) {
_collector = collector;
_sourceTasks = context.getThisSourceComponentTasks();
_targetTasks = context.getThisTargetComponentTasks();
for (List<Integer> tasks : _sourceTasks.values()) {
_expectExcevieNum += tasks.size();
}
this.context = context;
timeout = ConfigExtension.getTaskCleanupTimeoutSec(conf) / 2;
LOG.info("this component's sourceTasks is {}, and the target tasks is {}", _sourceTasks, _targetTasks);
}
代码示例来源:origin: alibaba/jstorm
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
_rand = new Random();
this.context = context;
_collector = collector;
final int differentMessages = 100;
_messages = new String[differentMessages];
for (int i = 0; i < differentMessages; i++) {
StringBuilder sb = new StringBuilder(_sizeInBytes);
//Even though java encodes strings in UCS2, the serialized version sent by the tuples
// is UTF8, so it should be a single byte
for (int j = 0; j < _sizeInBytes; j++) {
sb.append(_rand.nextInt(9));
}
_messages[i] = sb.toString();
}
_sourceTasks = context.getThisSourceComponentTasks();
_targetTasks = context.getThisTargetComponentTasks();
LOG.info("this component's sourceTasks is {}, and the target tasks is {}", _sourceTasks, _targetTasks);
}
代码示例来源:origin: alibaba/jstorm
Map<String, List<Integer>> sourceCompTasks = context.getThisSourceComponentTasks();
for (Map.Entry<String, List<Integer>> entry : sourceCompTasks.entrySet()) {
String comp = entry.getKey();
内容来源于网络,如有侵权,请联系作者删除!