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

Tuple.getString介绍

[英]Returns the String at position i in the tuple.
[中]返回元组中位置i处的字符串。

代码示例

代码示例来源：origin: apache/storm

@Override
  public String getTopic(Tuple tuple) {
    if (fieldIndex < tuple.size()) {
      return tuple.getString(fieldIndex);
    } else {
      LOG.warn("Field index {} is out of bounds. Using default topic {}", fieldIndex, defaultTopicName);
      return defaultTopicName;
    }
  }
}

代码示例来源：origin: apache/storm

@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: apache/storm

@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: apache/storm

@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: apache/storm

@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: apache/storm

@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: apache/storm

@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: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

@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: apache/storm

@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: apache/storm

@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: apache/storm

@Override
public void execute(Tuple tuple) {
  _collector.emit(tuple, new Values(tuple.getString(0) + "!!!"));
  _collector.ack(tuple);
}

代码示例来源：origin: apache/storm

@Override
public void execute(Tuple input, BasicOutputCollector collector) {
  for (String word : splitSentence(input.getString(0))) {
    collector.emit(new Values(word));
  }
}

代码示例来源：origin: apache/storm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  String arg = tuple.getString(0);
  Object retInfo = tuple.getValue(1);
  collector.emit(new Values(arg + "!!!", retInfo));
}

代码示例来源：origin: apache/storm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  sleep.simulateProcessAndExecTime(executorIndex, Time.nanoTime(), null , () -> {
    String sentence = tuple.getString(0);
    for (String word: sentence.split("\\s+")) {
      collector.emit(new Values(word, 1));
    }
  });
}

代码示例来源：origin: apache/storm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  String input = tuple.getString(1);
  collector.emit(new Values(tuple.getValue(0), input + "!"));
}

代码示例来源：origin: apache/storm

@Override
public void execute(Tuple tuple) {
 _collector.emit(tuple, new Values(tuple.getString(0) + "!!!"));
 _collector.ack(tuple);
}

代码示例来源：origin: apache/storm

@Override
public void execute(Tuple tuple) {
  String word = tuple.getString(0);
  Long count = wordCounts.get(word, 0L);
  count++;
  wordCounts.put(word, count);
  collector.emit(tuple, new Values(word, count));
  collector.ack(tuple);
}

代码示例来源：origin: apache/storm

@Override
public void execute(Tuple tuple) {
  String orig = tuple.getString(0);
  String ret = getFromCache(orig);
  if (ret == null) {
    ret = orig + "!!!";
    addToCache(orig, ret);
  }
  _collector.emit(tuple, new Values(ret));
  _collector.ack(tuple);
}