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

Tuple.getSourceGlobalStreamid介绍

[英]Returns the global stream id (component + stream) of this tuple.
[中]返回此元组的全局流id（组件+流）。

代码示例

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

private TupleType getTupleType(Tuple tuple) {
  if (_idStreamSpec != null && tuple.getSourceGlobalStreamid().equals(_idStreamSpec._id)) {
    return TupleType.ID;
  } else if (!_sourceArgs.isEmpty() && tuple.getSourceStreamId().equals(Constants.COORDINATED_STREAM_ID)) {
    return TupleType.COORD;
  } else {
    return TupleType.REGULAR;
  }
}

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

private TupleType getTupleType(Tuple tuple, TrackedBatch batch) {
  CoordCondition cond = batch.condition;
  if (cond.commitStream != null
      && tuple.getSourceGlobalStreamid().equals(cond.commitStream)) {
    return TupleType.COMMIT;
  } else if (cond.expectedTaskReports > 0
      && tuple.getSourceStreamId().startsWith(COORD_STREAM_PREFIX)) {
    return TupleType.COORD;
  } else {
    return TupleType.REGULAR;
  }
}

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

static TaskStream fromTuple(Tuple input) {
    return new TaskStream(input.getSourceTask(), input.getSourceGlobalStreamid());
  }
}

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

@Override
public void execute(Tuple input) {
  if (isTupleTs()) {
    long ts = input.getLongByField(tupleTsFieldName);
    if (waterMarkEventGenerator.track(input.getSourceGlobalStreamid(), ts)) {
      windowManager.add(input, ts);
    } else {
      LOG.info("Received a late tuple {} with ts {}. This will not processed.", input, ts);
    }
  } else {
    windowManager.add(input);
  }
}

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

(_idStreamSpec!=null && tup.getSourceGlobalStreamid().equals(_idStreamSpec._id))
 )) {
throw new IllegalStateException("Coordination condition met on a non-coordinating tuple. Should be impossible");

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

&& tuple.getSourceGlobalStreamid().equals(_idStreamSpec._id)) {
synchronized(_tracked) {
  track.receivedId = true;

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

String batchGroup = _batchGroupIds.get(tuple.getSourceGlobalStreamid());
if (batchGroup == null) {

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

private TupleType getTupleType(Tuple tuple) {
  if (_idStreamSpec != null && tuple.getSourceGlobalStreamid().equals(_idStreamSpec._id)) {
    return TupleType.ID;
  } else if (!_sourceArgs.isEmpty() && tuple.getSourceStreamId().equals(Constants.COORDINATED_STREAM_ID)) {
    return TupleType.COORD;
  } else {
    return TupleType.REGULAR;
  }
}

代码示例来源：origin: com.n3twork.storm/storm-core

private TupleType getTupleType(Tuple tuple) {
  if(_idStreamSpec!=null
      && tuple.getSourceGlobalStreamid().equals(_idStreamSpec._id)) {
    return TupleType.ID;
  } else if(!_sourceArgs.isEmpty()
      && tuple.getSourceStreamId().equals(Constants.COORDINATED_STREAM_ID)) {
    return TupleType.COORD;
  } else {
    return TupleType.REGULAR;
  }
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

private TupleType getTupleType(Tuple tuple, TrackedBatch batch) {
  CoordCondition cond = batch.condition;
  if(cond.commitStream!=null
      && tuple.getSourceGlobalStreamid().equals(cond.commitStream)) {
    return TupleType.COMMIT;
  } else if(cond.expectedTaskReports > 0
      && tuple.getSourceStreamId().startsWith(COORD_STREAM_PREFIX)) {
    return TupleType.COORD;
  } else {
    return TupleType.REGULAR;
  }
}

代码示例来源：origin: com.n3twork.storm/storm-core

private TupleType getTupleType(Tuple tuple, TrackedBatch batch) {
  CoordCondition cond = batch.condition;
  if(cond.commitStream!=null
      && tuple.getSourceGlobalStreamid().equals(cond.commitStream)) {
    return TupleType.COMMIT;
  } else if(cond.expectedTaskReports > 0
      && tuple.getSourceStreamId().startsWith(COORD_STREAM_PREFIX)) {
    return TupleType.COORD;
  } else {
    return TupleType.REGULAR;
  }
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

static TaskStream fromTuple(Tuple input) {
    return new TaskStream(input.getSourceTask(), input.getSourceGlobalStreamid());
  }
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

@Override
public void execute(Tuple input) {
  if (isTupleTs()) {
    long ts = input.getLongByField(tupleTsFieldName);
    if (waterMarkEventGenerator.track(input.getSourceGlobalStreamid(), ts)) {
      windowManager.add(input, ts);
    } else {
      LOG.info("Received a late tuple {} with ts {}. This will not processed.", input, ts);
    }
  } else {
    windowManager.add(input);
  }
}

代码示例来源：origin: com.n3twork.storm/storm-core

String batchGroup = _batchGroupIds.get(tuple.getSourceGlobalStreamid());
if(batchGroup==null) {

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

String batchGroup = _batchGroupIds.get(tuple.getSourceGlobalStreamid());
if(batchGroup==null) {