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

Tuple.getInteger介绍

[英]Returns the Integer at position i in the tuple.
[中]返回元组中位置i处的整数。

代码示例

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

@Override
public void execute(Tuple tuple) {
  _count += tuple.getInteger(1);
}

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

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  Integer c1 = tuple.getInteger(0);
  Integer c2 = tuple.getInteger(1);
  Integer exp = expected.get(c1);
  if (exp == null) exp = 0;
  if (c2.intValue() != exp.intValue()) {
    System.out.println(c1 + " " + c2 + " != " + exp);
    throw new FailedException(c1 + " " + c2 + " != " + exp);
  }
  exp = c2 + 1;
  expected.put(c1, exp);
}

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

public void execute(Tuple input) {
  Integer sourceId = input.getInteger(0);
  Long eventId = input.getLong(1);
  Long recentEvent = recentEventId.get(sourceId);
  if (null != recentEvent && eventId <= recentEvent) {
    String error = "Error: event id is not in strict order! event source Id: "
            + sourceId + ", last event Id: " + recentEvent + ", current event Id: " + eventId;
    _collector.emit(input, new Values(error));
  }
  recentEventId.put(sourceId, eventId);
  _collector.ack(input);
}

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

@Override
public void execute(TupleWindow window) {
  int sum = 0;
  int count = 0;
  // iterate over tuples in the current window
  Iterator<Tuple> it = window.getIter();
  while (it.hasNext()) {
    Tuple tuple = it.next();
    sum += tuple.getInteger(0);
    ++count;
  }
  LOG.debug("Count : {}", count);
  globalAvg = Pair.of(globalAvg.getFirst() + sum, globalAvg.getSecond() + count);
  // update the value in state
  state.put(STATE_KEY, globalAvg);
  // emit the averages downstream
  collector.emit(new Values(new Averages((double) globalAvg.getFirst() / globalAvg.getSecond(), (double) sum / count)));
}

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

curr.spoutTask = input.getInteger(2);
} else if (ACKER_ACK_STREAM_ID.equals(streamId)) {
  if (curr == null) {

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

checkFinish(tracked, tuple, t);
} else if (t == TupleType.COORD) {
  int count = tuple.getInteger(1);
  tracked.reportedTasks++;
  tracked.expectedTupleCount += count;

代码示例来源：origin: org.apache.storm/storm-core

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

代码示例来源：origin: org.apache.storm/storm-core

public void execute(Tuple input) {
  Integer sourceId = input.getInteger(0);
  Long eventId = input.getLong(1);
  Long recentEvent = recentEventId.get(sourceId);
  if (null != recentEvent && eventId <= recentEvent) {
    String error = "Error: event id is not in strict order! event source Id: "
        + sourceId + ", last event Id: " + recentEvent + ", current event Id: " + eventId;
    _collector.emit(input, new Values(error));
  }
  recentEventId.put(sourceId, eventId);
  _collector.ack(input);
}

代码示例来源：origin: org.apache.storm/storm-core

checkFinish(tracked, tuple, t);
} else if(t==TupleType.COORD) {
  int count = tuple.getInteger(1);
  tracked.reportedTasks++;
  tracked.expectedTupleCount+=count;