Java MessageId类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中backtype.storm.tuple.MessageId类的典型用法代码示例。如果您正苦于以下问题：Java MessageId类的具体用法？Java MessageId怎么用？Java MessageId使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

MessageId类属于backtype.storm.tuple包，在下文中一共展示了MessageId类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: deserialize

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
public Tuple deserialize(byte[] ser) {
try {
    _kryoInput.setBuffer(ser);
    int taskId = _kryoInput.readInt(true);
    int streamId = _kryoInput.readInt(true);
    String componentName = _context.getComponentId(taskId);
    String streamName = _ids.getStreamName(componentName, streamId);
    MessageId id = MessageId.deserialize(_kryoInput);
    List<Object> values = _kryo.deserializeFrom(_kryoInput);
    TupleImpl tuple = new TupleImpl(_context, values, taskId,
	    streamName, id);
    long transferStartTime = _kryoInput.readLong(true);
    if (transferStartTime != -1) {
	tuple.setTransferSampleStartTime(transferStartTime);
    }
    return tuple;
} catch (IOException e) {
    throw new RuntimeException(e);
}
   }

开发者ID:troyding，项目名称:storm-resa，代码行数:21，代码来源:KryoTupleDeserializer.java

示例2: sendAckTuple

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
private boolean sendAckTuple(Tuple input) {
    boolean ret = false;
    Integer pendingCount;
    synchronized (pendingTuples) {
        pendingCount = pendingTuples.get(input);
    }
    if (pendingCount == null || pendingCount <= 0) {
        long ack_val = 0L;
        Object pend_val = pendingAcks.remove(input);
        if (pend_val != null) {
            ack_val = (Long) (pend_val);
        }
        MessageId messageId = input.getMessageId();
        if (messageId != null) {
            for (Map.Entry<Long, Long> e : messageId.getAnchorsToIds().entrySet()) {
                List<Object> ackTuple =
                        JStormUtils.mk_list((Object) e.getKey(), JStormUtils.bit_xor(e.getValue(), ack_val));
                sendBoltMsg(Acker.ACKER_ACK_STREAM_ID, null, ackTuple, null, null);
            }
        }
        ret = true;
    }

    return ret;
}

开发者ID:alibaba，项目名称:jstorm，代码行数:26，代码来源:BoltBatchCollector.java

示例3: processTupleBatchEvent

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
private void processTupleBatchEvent(Tuple tuple) {
    try {
        if ((!isSystemBolt && tuple.getSourceStreamId().equals(Common.TOPOLOGY_MASTER_CONTROL_STREAM_ID)) ||
                tuple.getSourceStreamId().equals(Common.TOPOLOGY_MASTER_REGISTER_METRICS_RESP_STREAM_ID)) {
            if (tuple.getValues().get(0) instanceof Pair) {
                for (Object value : tuple.getValues()) {
                    Pair<MessageId, List<Object>> val = (Pair<MessageId, List<Object>>) value;
                    TupleImplExt t = new TupleImplExt(
                            sysTopologyCtx, val.getSecond(), val.getFirst(), ((TupleImplExt) tuple));
                    processTupleEvent(t);
                }
            }
        } else {
            bolt.execute(tuple);
        }
    } catch (Throwable e) {
        error = e;
        LOG.error("bolt execute error ", e);
        reportError.report(e);
    }
}

开发者ID:alibaba，项目名称:jstorm，代码行数:22，代码来源:BoltExecutors.java

示例4: getRootId

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
protected Long getRootId(Object messageId) {
        Boolean needAck = (messageId != null) && (ackerNum > 0);

        // This change storm logic
        // Storm can't make sure root_id is unique
        // storm's logic is root_id = MessageId.generateId(random);
        // when duplicate root_id, it will miss call ack/fail
        Long rootId = null;
        if (needAck) {
            rootId = MessageId.generateId(random);
/*            while (pending.containsKey(rootId)) {
                rootId = MessageId.generateId(random);
            }*/
        }
        return rootId;
    }

开发者ID:alibaba，项目名称:jstorm，代码行数:17，代码来源:SpoutCollector.java

示例5: getMessageId

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
protected MessageId getMessageId(SpoutMsgInfo msg, Map<Long, MsgInfo> ackBatch) {
    MessageId msgId = null;
    if (msg.rootId != null) {
        Long as = MessageId.generateId(random);
        msgId = MessageId.makeRootId(msg.rootId, as);

        MsgInfo msgInfo = ackBatch.get(msg.rootId);
        List<Object> ackerTuple;
        if (msgInfo == null) {
            TupleInfo info = TupleInfo.buildTupleInfo(msg.streamId, msg.messageId, msg.values, System.currentTimeMillis(), isCacheTuple);
            pending.putHead(msg.rootId, info);

            ackerTuple = JStormUtils.mk_list((Object) msg.rootId, JStormUtils.bit_xor_vals(as), task_id);

            msgInfo = new SpoutMsgInfo(Acker.ACKER_INIT_STREAM_ID, ackerTuple, null, null, null, null);
            ackBatch.put(msg.rootId, msgInfo);
        } else {
            ackerTuple = msgInfo.values;
            ackerTuple.set(1, JStormUtils.bit_xor_vals(ackerTuple.get(1), as));
        }
    }

    return msgId;
}

开发者ID:alibaba，项目名称:jstorm，代码行数:25，代码来源:SpoutBatchCollector.java

示例6: getMessageId

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
protected MessageId getMessageId(Collection<Tuple> anchors) {
    MessageId ret = null;
    if (anchors != null && ackerNum > 0) {
        Map<Long, Long> anchors_to_ids = new HashMap<>();
        for (Tuple a : anchors) {
            if (a.getMessageId() != null) {
                Long edge_id = MessageId.generateId(random);
                put_xor(pendingAcks, a, edge_id);
                MessageId messageId = a.getMessageId();
                if (messageId != null) {
                    for (Long root_id : messageId.getAnchorsToIds().keySet()) {
                        put_xor(anchors_to_ids, root_id, edge_id);
                    }
                }
            }
        }
        ret = MessageId.makeId(anchors_to_ids);
    }
    return ret;
}

开发者ID:alibaba，项目名称:jstorm，代码行数:21，代码来源:BoltCollector.java

示例7: deserialize

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
@Override
public Tuple deserialize(byte[] ser) {
	
	int targetTaskId = 0;
	int taskId = 0;
	int streamId = 0;
	String componentName = null;
	String streamName = null;
	MessageId id = null;
	
	try {

		_kryoInput.setBuffer(ser);

		targetTaskId = _kryoInput.readInt();
		taskId = _kryoInput.readInt(true);
		streamId = _kryoInput.readInt(true);
		componentName = _context.getComponentId(taskId);
		streamName = _ids.getStreamName(componentName, streamId);
		id = MessageId.deserialize(_kryoInput);
		List<Object> values = _kryo.deserializeFrom(_kryoInput);
		TupleImplExt tuple = new TupleImplExt(_context, values, taskId,
				streamName, id);
		tuple.setTargetTaskId(targetTaskId);
		return tuple;
	} catch (Throwable e) {
		StringBuilder sb = new StringBuilder();
		
		sb.append("Deserialize error:");
		sb.append("targetTaskId:").append(targetTaskId);
		sb.append(",taskId:").append(taskId);
		sb.append(",streamId:").append(streamId);
		sb.append(",componentName:").append(componentName);
		sb.append(",streamName:").append(streamName);
		sb.append(",MessageId").append(id);
		
		LOG.info(sb.toString(), e );
		throw new RuntimeException(e);
	}
}

开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:41，代码来源:KryoTupleDeserializer.java

示例8: deserialize

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
public Tuple deserialize(byte[] ser) {
	
	int targetTaskId = 0;
	int taskId = 0;
	int streamId = 0;
	String componentName = null;
	String streamName = null;
	MessageId id = null;
	
	try {

		_kryoInput.setBuffer(ser);

		targetTaskId = _kryoInput.readInt();
		taskId = _kryoInput.readInt(true);
		streamId = _kryoInput.readInt(true);
		componentName = _context.getComponentId(taskId);
		streamName = _ids.getStreamName(componentName, streamId);
		id = MessageId.deserialize(_kryoInput);
		List<Object> values = _kryo.deserializeFrom(_kryoInput);
		TupleImplExt tuple = new TupleImplExt(_context, values, taskId,
				streamName, id);
		tuple.setTargetTaskId(targetTaskId);
		return tuple;
	} catch (Throwable e) {
		StringBuilder sb = new StringBuilder();
		
		sb.append("Deserialize error:");
		sb.append("targetTaskId:").append(targetTaskId);
		sb.append(",taskId:").append(taskId);
		sb.append(",streamId:").append(streamId);
		sb.append(",componentName:").append(componentName);
		sb.append(",streamName:").append(streamName);
		sb.append(",MessageId").append(id);
		
		LOG.info(sb.toString(), e );
		throw new RuntimeException(e);
	}
}

开发者ID:songtk，项目名称:learn_jstorm，代码行数:40，代码来源:KryoTupleDeserializer.java

示例9: deserialize

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
public Tuple deserialize(Input input) {
    int targetTaskId = 0;
    long timeStamp = 0l;
    int taskId = 0;
    int streamId = 0;
    String componentName = null;
    String streamName = null;
    MessageId id = null;

    try {
        targetTaskId = input.readInt();
        timeStamp = input.readLong();
        taskId = input.readInt(true);
        streamId = input.readInt(true);
        componentName = _context.getComponentId(taskId);
        streamName = _ids.getStreamName(componentName, streamId);
        id = MessageId.deserialize(input);
        List<Object> values = _kryo.deserializeFrom(input);
        TupleImplExt tuple = new TupleImplExt(_context, values, taskId, streamName, id);
        tuple.setTargetTaskId(targetTaskId);
        tuple.setCreationTimeStamp(timeStamp);
        return tuple;
    } catch (Throwable e) {
        StringBuilder sb = new StringBuilder();

        sb.append("Deserialize error:");
        sb.append("targetTaskId:").append(targetTaskId);
        sb.append(",creationTimeStamp:").append(timeStamp);
        sb.append(",taskId:").append(taskId);
        sb.append(",streamId:").append(streamId);
        sb.append(",componentName:").append(componentName);
        sb.append(",streamName:").append(streamName);
        sb.append(",MessageId").append(id);

        LOG.info(sb.toString(), e);
        throw new RuntimeException(e);
    }
}

开发者ID:kkllwww007，项目名称:jstrom，代码行数:39，代码来源:KryoTupleDeserializer.java

示例10: deserialize

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
public Tuple deserialize(byte[] ser) {
    try {
        _kryoInput.setBuffer(ser);
        int taskId = _kryoInput.readInt(true);
        int streamId = _kryoInput.readInt(true);
        String componentName = _context.getComponentId(taskId);
        String streamName = _ids.getStreamName(componentName, streamId);
        MessageId id = MessageId.deserialize(_kryoInput);
        List<Object> values = _kryo.deserializeFrom(_kryoInput);
        return new TupleImpl(_context, values, taskId, streamName, id);
    } catch(IOException e) {
        throw new RuntimeException(e);
    }
}

开发者ID:metamx，项目名称:incubator-storm，代码行数:15，代码来源:KryoTupleDeserializer.java

示例11: getMessageId

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
@Override
protected MessageId getMessageId(Collection<Tuple> anchors) {
    MessageId ret = null;
    if (anchors != null) {
        Map<Long, Long> anchors_to_ids = new HashMap<Long, Long>();
        long now = System.currentTimeMillis();
        if (now - lastRotate > rotateTime) {
            pendingAcks.rotate();
            synchronized (pendingTuples) {
                pendingTuples.rotate();
            }
            lastRotate = now;
        }
        for (Tuple a : anchors) {
            // Long edge_id = MessageId.generateId();
            Long edge_id = MessageId.generateId(random);
            synchronized (pendingAcks) {
                put_xor(pendingAcks, a, edge_id);
            }
            MessageId messageId = a.getMessageId();
            if (messageId != null) {
                for (Long root_id : messageId.getAnchorsToIds().keySet()) {
                    put_xor(anchors_to_ids, root_id, edge_id);
                }
            }
        }
        ret = MessageId.makeId(anchors_to_ids);
    }
    return ret;
}

开发者ID:alibaba，项目名称:jstorm，代码行数:31，代码来源:BoltBatchCollector.java

示例12: sendMsg

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
public List<Integer> sendMsg(String out_stream_id, List<Object> values, Object message_id,
                             Integer out_task_id, ICollectorCallback callback) {
    final long startTime = emitTotalTimer.getTime();
    try {
        boolean needAck = (message_id != null) && (ackerNum > 0);
        Long root_id = getRootId(message_id);
        List<Integer> outTasks;

        if (out_task_id != null) {
            outTasks = sendTargets.get(out_task_id, out_stream_id, values, null, root_id);
        } else {
            outTasks = sendTargets.get(out_stream_id, values, null, root_id);
        }

        List<Long> ackSeq = new ArrayList<>();
        for (Integer t : outTasks) {
            MessageId msgId;
            if (needAck) {
                // Long as = MessageId.generateId();
                Long as = MessageId.generateId(random);
                msgId = MessageId.makeRootId(root_id, as);
                ackSeq.add(as);
            } else {
                msgId = null;
            }

            TupleImplExt tp = new TupleImplExt(topology_context, values, task_id, out_stream_id, msgId);
            tp.setTargetTaskId(t);
            transfer_fn.transfer(tp);
        }
        sendMsgToAck(out_stream_id, values, message_id, root_id, ackSeq, needAck);
        if (callback != null)
            callback.execute(out_stream_id, outTasks, values);
        return outTasks;
    } finally {
        emitTotalTimer.updateTime(startTime);
    }
}

开发者ID:alibaba，项目名称:jstorm，代码行数:39，代码来源:SpoutCollector.java

示例13: sendCtrlMsg

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
protected List<Integer> sendCtrlMsg(String out_stream_id, List<Object> values, Object message_id, Integer out_task_id) {
    final long startTime = emitTotalTimer.getTime();
    try {
        boolean needAck = (message_id != null) && (ackerNum > 0);
        Long root_id = getRootId(message_id);
        java.util.List<Integer> out_tasks;

        if (out_task_id != null) {
            out_tasks = sendTargets.get(out_task_id, out_stream_id, values, null, root_id);
        } else {
            out_tasks = sendTargets.get(out_stream_id, values, null, root_id);
        }

        List<Long> ackSeq = new ArrayList<>();
        for (Integer t : out_tasks) {
            MessageId msgId;
            if (needAck) {
                // Long as = MessageId.generateId();
                Long as = MessageId.generateId(random);
                msgId = MessageId.makeRootId(root_id, as);
                ackSeq.add(as);
            } else {
                msgId = null;
            }

            TupleImplExt tp = new TupleImplExt(topology_context, values, task_id, out_stream_id, msgId);
            tp.setTargetTaskId(t);
            transferCtr(tp);
        }
        sendMsgToAck(out_stream_id, values, message_id, root_id, ackSeq, needAck);
        return out_tasks;
    } finally {
        emitTotalTimer.updateTime(startTime);
    }
}

开发者ID:alibaba，项目名称:jstorm，代码行数:36，代码来源:SpoutCollector.java

示例14: sendMsg

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
public List<Integer> sendMsg(String out_stream_id, List<Object> values, Collection<Tuple> anchors,
                             Integer out_task_id, ICollectorCallback callback) {
    final long start = emitTimer.getTime();
    List<Integer> outTasks = null;
    try {
        if (out_task_id != null) {
            outTasks = sendTargets.get(out_task_id, out_stream_id, values, anchors, null);
        } else {
            outTasks = sendTargets.get(out_stream_id, values, anchors, null);
        }

        tryRotate();
        for (Integer t : outTasks) {
            MessageId msgId = getMessageId(anchors);
            TupleImplExt tp = new TupleImplExt(topologyContext, values, taskId, out_stream_id, msgId);
            tp.setTargetTaskId(t);
            taskTransfer.transfer(tp);
        }
    } catch (Exception e) {
        LOG.error("bolt emit error:", e);
    } finally {
        if (outTasks == null) {
            outTasks = new ArrayList<>();
        }
        if (callback != null)
            callback.execute(out_stream_id, outTasks, values);
        emitTimer.updateTime(start);
    }
    return outTasks;
}

开发者ID:alibaba，项目名称:jstorm，代码行数:31，代码来源:BoltCollector.java

示例15: sendCtrlMsg

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
protected List<Integer> sendCtrlMsg(String out_stream_id, List<Object> values,
                                    Collection<Tuple> anchors, Integer out_task_id) {
    final long start = emitTimer.getTime();
    java.util.List<Integer> out_tasks = null;
    try {

        if (out_task_id != null) {
            out_tasks = sendTargets.get(out_task_id, out_stream_id, values, anchors, null);
        } else {
            out_tasks = sendTargets.get(out_stream_id, values, anchors, null);
        }

        tryRotate();
        for (Integer t : out_tasks) {
            MessageId msgId = getMessageId(anchors);

            TupleImplExt tp = new TupleImplExt(topologyContext, values, taskId, out_stream_id, msgId);
            tp.setTargetTaskId(t);
            transferCtr(tp);
        }
    } catch (Exception e) {
        LOG.error("bolt emit error:", e);
    } finally {
        emitTimer.updateTime(start);
    }
    return out_tasks;
}

开发者ID:alibaba，项目名称:jstorm，代码行数:28，代码来源:BoltCollector.java

示例16: boltEmit

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
private List<Integer> boltEmit(String out_stream_id,
		Collection<Tuple> anchors, List<Object> values, Integer out_task_id) {
	timer.start();
	try {
		java.util.List<Integer> out_tasks = null;
		if (out_task_id != null) {
			out_tasks = sendTargets.get(out_task_id, out_stream_id, values);
		} else {
			out_tasks = sendTargets.get(out_stream_id, values);
		}

		for (Integer t : out_tasks) {
			Map<Long, Long> anchors_to_ids = new HashMap<Long, Long>();
			if (anchors != null) {
				for (Tuple a : anchors) {
					//Long edge_id = MessageId.generateId();
					Long edge_id = MessageId.generateId(random);
					long now = System.currentTimeMillis();
					if (now - lastRotate > rotateTime) {
						pending_acks.rotate();
						lastRotate = now;
					}
					put_xor(pending_acks, a, edge_id);
					for (Long root_id : a.getMessageId().getAnchorsToIds()
							.keySet()) {
						put_xor(anchors_to_ids, root_id, edge_id);
					}
				}
			}
			MessageId msgid = MessageId.makeId(anchors_to_ids);
			TupleImplExt tupleExt = new TupleImplExt(topologyContext,
					values, task_id, out_stream_id, msgid);
			tupleExt.setTargetTaskId(t);

			taskTransfer.transfer(tupleExt);

		}
		return out_tasks;
	} catch (Exception e) {
		LOG.error("bolt emit", e);
	}finally {
		timer.stop();
	}
	return new ArrayList<Integer>();
}

开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:46，代码来源:BoltCollector.java

示例17: boltEmit

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
private List<Integer> boltEmit(String out_stream_id, Collection<Tuple> anchors, List<Object> values, Integer out_task_id) {
    final long start = System.nanoTime();
    try {
        List<Integer> out_tasks;
        if (out_task_id != null) {
            out_tasks = sendTargets.get(out_task_id, out_stream_id, values);
        } else {
            out_tasks = sendTargets.get(out_stream_id, values);
        }

        for (Integer t : out_tasks) {
            Map<Long, Long> anchors_to_ids = new HashMap<Long, Long>();
            if (anchors != null) {
                for (Tuple a : anchors) {
                    // Long edge_id = MessageId.generateId();
                    Long edge_id = MessageId.generateId(random);
                    long now = System.currentTimeMillis();
                    if (now - lastRotate > rotateTime) {
                        pending_acks.rotate();
                        lastRotate = now;
                    }
                    put_xor(pending_acks, a, edge_id);
                    for (Long root_id : a.getMessageId().getAnchorsToIds().keySet()) {
                        put_xor(anchors_to_ids, root_id, edge_id);
                    }
                }
            }
            MessageId msgid = MessageId.makeId(anchors_to_ids);
            TupleImplExt tupleExt = new TupleImplExt(topologyContext, values, task_id, out_stream_id, msgid);
            tupleExt.setTargetTaskId(t);

            taskTransfer.transfer(tupleExt);
        }
        return out_tasks;
    } catch (Exception e) {
        LOG.error("bolt emit", e);
    } finally {
        long end = System.nanoTime();
        timer.update((end - start) / TimeUtils.NS_PER_US);
    }
    return new ArrayList<Integer>();
}

开发者ID:kkllwww007，项目名称:jstrom，代码行数:43，代码来源:BoltCollector.java

示例18: getMessageId

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
@Override
public MessageId getMessageId() {
	// TODO Auto-generated method stub
	return null;
}

开发者ID:IntersysConsulting，项目名称:ingestive，代码行数:6，代码来源:MockedTuple.java

示例19: isDebugRecv

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
public static boolean isDebugRecv(MessageId msgId) {
    return msgId != null && isDebugRecv(msgId.getAnchors());
}

开发者ID:alibaba，项目名称:jstorm，代码行数:4，代码来源:JStormDebugger.java

示例20: onEvent

import backtype.storm.tuple.MessageId; //导入依赖的package包/类
@Override
public void onEvent(Object event, long sequence, boolean endOfBatch) throws Exception {
    if (event == null) {
        return;
    }

    if (event instanceof Tuple) {
        Tuple tuple = (Tuple) event;
        int tupleNum = 1;
        Long startTime = System.currentTimeMillis();
        long lifeCycleStart = ((TupleExt) tuple).getCreationTimeStamp();

        if (((TupleExt) tuple).isBatchTuple()) {
            List<Object> values = ((Tuple) event).getValues();
            tupleNum = values.size();
            if (bolt instanceof IRichBatchBolt) {
                processTupleBatchEvent(tuple);
            } else {
                for (Object value : values) {
                    Pair<MessageId, List<Object>> val = (Pair<MessageId, List<Object>>) value;
                    TupleImplExt t = new TupleImplExt(
                            sysTopologyCtx, val.getSecond(), val.getFirst(), ((TupleImplExt) event));
                    processTupleEvent(t);
                }
            }
        } else {
            processTupleEvent(tuple);
        }
        taskStats.tupleLifeCycle(tuple.getSourceComponent(), tuple.getSourceStreamId(), lifeCycleStart, startTime, tupleNum);
        taskStats.recv_tuple(tuple.getSourceComponent(), tuple.getSourceStreamId(), tupleNum);
        if (ackerNum == 0) {
            // only when acker is disabled
            // get tuple process latency
            if (JStormMetrics.enabled) {
                long endTime = System.currentTimeMillis();
                taskStats.update_bolt_acked_latency(
                        tuple.getSourceComponent(), tuple.getSourceStreamId(), startTime, endTime, tupleNum);
            }
        }
    } else if (event instanceof TimerTrigger.TimerEvent) {
        processTimerEvent((TimerTrigger.TimerEvent) event);
    } else {
        LOG.warn("Bolt executor received an unknown message");
    }
}

开发者ID:alibaba，项目名称:jstorm，代码行数:46，代码来源:BoltExecutors.java

注：本文中的backtype.storm.tuple.MessageId类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java CheckpointConfig类代码示例发布时间：2022-05-22

Java DocumentMetadataHandle类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18282|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9680|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8180|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8549|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8458|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9393|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8431|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7865|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8416|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java MessageId类代码示例

示例1: deserialize

示例2: sendAckTuple

示例3: processTupleBatchEvent

示例4: getRootId

示例5: getMessageId

示例6: getMessageId

示例7: deserialize

示例8: deserialize

示例9: deserialize

示例10: deserialize

示例11: getMessageId

示例12: sendMsg

示例13: sendCtrlMsg

示例14: sendMsg

示例15: sendCtrlMsg

示例16: boltEmit

示例17: boltEmit

示例18: getMessageId

示例19: isDebugRecv

示例20: onEvent

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

tianli/matlab_offscreen: Matlab offscree

win7系统注册表编辑器打开的操作方法

これがマストドンだ！ 使い方からインスタ

芙蓉王（硬领航）多少钱一包？

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

これがマストドンだ！使い方からインスタ