本文整理了Java中backtype.storm.tuple.Tuple.getString()方法的一些代码示例，展示了Tuple.getString()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Tuple.getString()方法的具体详情如下：
包路径：backtype.storm.tuple.Tuple
类名称：Tuple
方法名：getString

Tuple.getString介绍

[英]Returns the String at position i in the tuple. If that field is not a String, you will get a runtime error.
[中]返回元组中位置i处的字符串。如果该字段不是字符串，则会出现运行时错误。

代码示例

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, Object state, TimeWindow window) {
  Map<String, Integer> counts = (Map<String, Integer>) state;
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, Object state, TimeWindow window) {
  HashMap<String, Integer> counts = (HashMap<String, Integer>) state;
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple) {
  String key = tuple.getString(1);
  Integer curr = _counts.get(key);
  if (curr == null)
    curr = 0;
  _counts.put(key, curr + 1);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, Object state, TimeWindow window) {
  Map<String, Integer> counts = (Map<String, Integer>) state;
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, Object state, TimeWindow window) {
  Map<String, Integer> counts = (Map<String, Integer>) state;
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple) {
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, Object state, TimeWindow window) {
  Map<String, Integer> counts = (Map<String, Integer>) state;
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, Object state, TimeWindow window) {
  Map<String, Integer> counts = (Map<String, Integer>) state;
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, Object state, TimeWindow window) {
  Map<String, Integer> counts = (Map<String, Integer>) state;
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple) {
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  counts.put(word, ++count);
  if (isSlowdown == true) {
    JStormUtils.sleepMs(100);
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple) {
  if (tuple.getSourceComponent().equals(_wordComponent)) {
    this.word = tuple.getString(1);
  } else {
    intSet.add(tuple.getInteger(1));
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  String word = tuple.getString(0);
  Integer count = counts.get(word);
  if (count == null)
    count = 0;
  count++;
  counts.put(word, count);
  collector.emit(new Values(word, count));
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple) {
  String sentence = tuple.getString(0);
  for (String word : sentence.split("\\s+")) {
    collector.emit(new Values(word));
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple) {
  String sentence = tuple.getString(0);
  for (String word : sentence.split("\\s+")) {
    collector.emit(new Values(word));
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple) {
  String sentence = tuple.getString(0);
  for (String word : sentence.split("\\s+")) {
    collector.emit(new Values(word));
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple input, BasicOutputCollector collector) {
  String name = input.getString(0);
  collector.emit(new Values(name, _conf.get(name)));
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  Object id = tuple.getValue(0);
  String url = tuple.getString(1);
  List<String> tweeters = TWEETERS_DB.get(url);
  if (tweeters != null) {
    for (String tweeter : tweeters) {
      collector.emit(new Values(id, tweeter));
    }
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  Object id = tuple.getValue(0);
  String tweeter = tuple.getString(1);
  List<String> followers = FOLLOWERS_DB.get(tweeter);
  if (followers != null) {
    for (String follower : followers) {
      collector.emit(new Values(id, follower));
    }
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  String args = tuple.getString(0);
  String returnInfo = tuple.getString(1);
  long requestId = rand.nextLong();
  collector.emit(ARGS_STREAM, new Values(requestId, args));
  collector.emit(RETURN_STREAM, new Values(requestId, returnInfo));
  collector.emit(ID_STREAM, new Values(requestId));
}

代码示例来源：origin: alibaba/jstorm

@Override
public void execute(Tuple input, BasicOutputCollector collector) {
  Object id = input.getValue(0);
  String word = input.getString(1);
  for (int i = 0; i < word.length(); i++) {
    if (word.charAt(i) == 'a') {
      collector.emit("multi", new Values(id, word.substring(0, i)));
    }
  }
  collector.emit("single", new Values(id, word));
}