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

Tuple.getInteger介绍

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

代码示例

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

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

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

@Override
public void execute(Tuple tuple) {
  _sum += tuple.getInteger(1);
  LOG.info("---UpdateGlobalCount.execute(), _sum=" + _sum);
}

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

@Override
public void execute(Tuple tuple) {
  Integer bucket = tuple.getInteger(1);
  Integer delta = tuple.getInteger(2);
  Integer curr = _accum.get(bucket);
  if (curr == null)
    curr = 0;
  _accum.put(bucket, curr + delta);
}

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

@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: 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/mdrill

@Override
public void execute(Tuple tuple) {
  Object key = tuple.getValue(1);
  int curr = Utils.get(_sums, key, 0);
  _sums.put(key, curr + tuple.getInteger(2));
}

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

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: alibaba/jstorm

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  TransactionAttempt attempt = (TransactionAttempt) tuple.getValue(0);
  int curr = tuple.getInteger(2);
  Integer prev = tuple.getInteger(3);
  
  int currBucket = curr / BUCKET_SIZE;
  Integer prevBucket = null;
  if (prev != null) {
    prevBucket = prev / BUCKET_SIZE;
  }
  
  if (prevBucket == null) {
    collector.emit(new Values(attempt, currBucket, 1));
  } else if (currBucket != prevBucket) {
    collector.emit(new Values(attempt, currBucket, 1));
    collector.emit(new Values(attempt, prevBucket, -1));
  }
}

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

@Override
public void execute(Tuple tuple) {
  String sourceIp = tuple.getString(1);
  Integer sourcePort = tuple.getInteger(2);
  if (differentNode) {
    if (ip.equals(sourceIp)) {
      fail(tuple, _collector);
      return;
    } else if (port.equals(sourcePort)) {
      fail(tuple, _collector);
      return;
    }
    _collector.emit(tuple, new Values(tuple.getValue(0), ip, port));
    _collector.ack(tuple);
    return;
  } else {
    if (ip.equals(sourceIp) == false) {
      fail(tuple, _collector);
      return;
    }
    _collector.emit(tuple, new Values(tuple.getValue(0), ip, port));
    _collector.ack(tuple);
  }
  
}

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

curr.spout_task = input.getInteger(2);
curr.spout_task = input.getInteger(2);

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

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

代码示例来源：origin: menacher/nerdronix

@Override
public void execute(Tuple input) {
  Integer channelId = input.getInteger(1);
  Integer viewTime = channelViewTimeMap.get(channelId);
  if (null == viewTime) {
    viewTime = input.getInteger(2);
  } else {
    viewTime += input.getInteger(2);
  }
  channelViewTimeMap.put(channelId, viewTime);
  collector.emit(new Values(channelId, viewTime));
  collector.ack(input);
}

代码示例来源：origin: menacher/nerdronix

@Override
public void execute(Tuple input) {
  Integer userId = input.getInteger(0);
  Integer channelId = input.getInteger(1);
  Map<Integer, Integer> channelViewTime = userChannelViewMap.get(userId);
  if (null == channelViewTime) {
    channelViewTime = new HashMap<>();
    channelViewTime.put(channelId, 0);
  }
  channelViewTime.put(channelId, channelViewTime.get(channelId) + input.getInteger(2));
  collector.emit(new Values(userId, channelViewTime.get(channelId)));
  collector.ack(input);
}

代码示例来源：origin: com.n3twork.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: com.alibaba.jstorm/jstorm-core

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

代码示例来源：origin: menacher/nerdronix

@Override
public void execute(Tuple input) {
  Integer channelId = input.getInteger(1);
  Integer clickCount = channelClickCount.get(channelId);
  if (null == clickCount) {
    clickCount = 1;
  } else {
    clickCount += 1;
  }
  channelClickCount.put(channelId, clickCount);
  collector.emit(new Values(channelId, clickCount));
  collector.ack(input);
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-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: Big-Data-Manning/big-data-code

@Override
public void execute(Tuple tuple, BasicOutputCollector collector) {
  PersonID user = (PersonID) tuple.getValue(0);
  String url = tuple.getString(1);
  int timestamp = tuple.getInteger(2);
  try {
    String domain = new URL(url).getAuthority();
    collector.emit(new Values(
            domain,
            url,
            timestamp / HOUR_SECS,
            user));
  } catch(MalformedURLException e) {
  }
}

代码示例来源：origin: dongeforever/middlewarerace

@Override
public void execute(Tuple tuple) {
  Long orderId = tuple.getLong(0);
  int from = tuple.getInteger(1);
  Long ctime = tuple.getLong(2);
  double amount = tuple.getDouble(3);
  collector.ack(tuple);
  collector.emit(new Values(orderId,from,ctime,amount));
  updateSendTps();
}

代码示例来源：origin: dongeforever/middlewarerace

@Override
public void execute(Tuple tuple) {
  int from = tuple.getInteger(0);
  Long ctime = tuple.getLong(1);
  double amount = tuple.getDouble(2);
  collector.ack(tuple);
  if(from == RaceConfig.TBORDER ){
    this.tbPayMap.merge(new Item().amount(amount).key(RaceUtils.getMinuteTime(ctime)));
  }else if (from == RaceConfig.TMORDER){
    this.tmPayMap.merge(new Item().amount(amount).key(RaceUtils.getMinuteTime(ctime)));
  }else {
    LOG.info("unknown from {}",from);
  }
  updateSendTps();
}