Java IntervalCheck类代码示例

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

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

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

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

示例1: open

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Override
public void open(Map conf, TopologyContext context,
		SpoutOutputCollector collector) {
	batchQueue = new LinkedBlockingQueue<BatchSpoutMsgId>();
	this.collector = collector;
	this.conf = conf;
	taskName = context.getThisComponentId() + "_" + context.getThisTaskId();
	
	intervalCheck = new IntervalCheck();

	try {
		zkClient = BatchCommon.getZkClient(conf);

		initMsgId();

	} catch (Exception e) {
		LOG.error("", e);
		throw new RuntimeException("Failed to init");
	}
	LOG.info("Successfully open " + taskName);
}

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

示例2: open

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
@Override
public void open(Map conf, TopologyContext context,
		SpoutOutputCollector collector) {
	batchQueue = new LinkedBlockingQueue<BatchSpoutMsgId>();
	this.collector = collector;
	this.conf = conf;
	taskName = context.getThisComponentId() + "_" + context.getThisTaskId();
	
	intervalCheck = new IntervalCheck();

	try {
		zkClient = BatchCommon.getZkClient(conf);

		initMsgId();

	} catch (Exception e) {
		LOG.error("", e);
		throw new RuntimeException("Failed to init");
	}
	LOG.info("Successfully open " + taskName);
}

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

示例3: TaskHeartbeatTrigger

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public TaskHeartbeatTrigger(Map conf, String name, DisruptorQueue queue, BlockingQueue<Object> controlQueue, int taskId, String componentId,
        TopologyContext sysTopologyCtx, ITaskReportErr reportError) {
    this.name = name;
    this.queue = queue;
    this.controlQueue = controlQueue;
    this.opCode = TimerConstants.TASK_HEARTBEAT;

    this.taskId = taskId;
    this.componentId = componentId;
    this.sysTopologyCtx = sysTopologyCtx;

    this.frequence = JStormUtils.parseInt(conf.get(Config.TASK_HEARTBEAT_FREQUENCY_SECS), 10);
    this.firstTime = frequence;

    this.executeThreadHbTime = TimeUtils.current_time_secs();
    this.taskHbTimeout = JStormUtils.parseInt(conf.get(Config.NIMBUS_TASK_TIMEOUT_SECS), 180);
    this.intervalCheck = new IntervalCheck();
    this.intervalCheck.setInterval(taskHbTimeout);
    this.intervalCheck.start();

    this.reportError = reportError;

    this.uptime = new UptimeComputer();
}

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

示例4: open

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
    batchQueue = new LinkedBlockingQueue<BatchSpoutMsgId>();
    this.collector = collector;
    this.conf = conf;
    taskName = context.getThisComponentId() + "_" + context.getThisTaskId();

    intervalCheck = new IntervalCheck();

    try {
        zkClient = BatchCommon.getZkClient(conf);

        initMsgId();

    } catch (Exception e) {
        LOG.error("", e);
        throw new RuntimeException("Failed to init");
    }
    LOG.info("Successfully open " + taskName);
}

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

示例5: RollingWindow

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
RollingWindow(V defaultValue, int interval, int windowSecond, Updater<V> updater, Merger<V> merger) {
    this.startTime = System.currentTimeMillis();
    this.interval = interval;
    this.intervalCheck = new IntervalCheck();
    this.intervalCheck.setInterval(interval);
    this.currBucketTime = getCurrBucketTime();

    this.bucketNum = windowSecond / interval;
    this.windowSecond = (bucketNum) * interval;

    this.buckets = new TreeMap<Integer, V>();

    this.updater = updater;
    this.merger = merger;

    this.defaultValue = defaultValue;

}

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

示例6: init

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public void init() {
    if (defaultValue == null || updater == null || merger == null || convertor == null) {
        throw new IllegalArgumentException("Invalid argements");
    }

    rollingWindows = new ArrayList<RollingWindow<V>>();
    if (windowSeconds != null) {
        rollingWindows.clear();
        for (int windowSize : windowSeconds) {
            RollingWindow<V> rollingWindow = new RollingWindow<V>(defaultValue, windowSize / bucketSize, windowSize, updater, merger);

            rollingWindows.add(rollingWindow);
        }

    }
    allWindow = new AllWindow<V>(defaultValue, updater, merger);

    this.interval = getInterval();
    this.intervalCheck = new IntervalCheck();
    this.intervalCheck.setInterval(interval);
}

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

示例7: MkLocalShuffer

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public MkLocalShuffer(List<Integer> workerTasks, List<Integer> allOutTasks,
                      WorkerData workerData) {
    super(workerData);
    List<Integer> localOutTasks = new ArrayList<Integer>();

    for (Integer outTask : allOutTasks) {
        if (workerTasks.contains(outTask)) {
            localOutTasks.add(outTask);
        }
    }
    this.workerData = workerData;
    intervalCheck = new IntervalCheck();
    intervalCheck.setInterval(60);

    if (localOutTasks.size() != 0) {
        this.outTasks = localOutTasks;
        isLocal = true;
    } else {
        this.outTasks = new ArrayList<Integer>();
        this.outTasks.addAll(allOutTasks);
        refreshLocalNodeTasks();
        isLocal = false;
    }
    randomrange = new RandomRange(outTasks.size());
}

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

示例8: TaskHeartbeatTrigger

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public TaskHeartbeatTrigger(Map conf, String name, DisruptorQueue controlQueue, int taskId, String componentId,
                            TopologyContext sysTopologyCtx, ITaskReportErr reportError, TaskStatus executorStatus) {
    this.name = name;
    this.queue = controlQueue;
    this.opCode = TimerConstants.TASK_HEARTBEAT;

    this.taskId = taskId;
    this.componentId = componentId;
    this.sysTopologyCtx = sysTopologyCtx;

    this.frequency = JStormUtils.parseInt(conf.get(Config.TASK_HEARTBEAT_FREQUENCY_SECS), 10);
    this.firstTime = 0;

    this.executeThreadHbTime = TimeUtils.current_time_secs();
    this.taskHbTimeout = JStormUtils.parseInt(conf.get(Config.NIMBUS_TASK_TIMEOUT_SECS), 180);
    this.intervalCheck = new IntervalCheck();
    this.intervalCheck.setInterval(taskHbTimeout);
    this.intervalCheck.start();

    this.reportError = reportError;

    this.uptime = new UptimeComputer();
    this.executorStatus = executorStatus;
}

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

示例9: open

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
    batchQueue = new LinkedBlockingQueue<>();
    this.collector = collector;
    this.conf = conf;
    taskName = context.getThisComponentId() + "_" + context.getThisTaskId();

    intervalCheck = new IntervalCheck();
    try {
        zkClient = BatchCommon.getZkClient(conf);
        initMsgId();
    } catch (Exception e) {
        LOG.error("", e);
        throw new RuntimeException("Failed to init");
    }
    LOG.info("Successfully open " + taskName);
}

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

示例10: open

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
    this.conf = conf;
    this.topologyContext = context;
    this.topologyId = topologyContext.getTopologyId();
    this.taskId = topologyContext.getThisTaskId();
    this.topologyMasterId = topologyContext.getTopologyMasterId();
    this.componentId = topologyContext.getThisComponentId();
    this.taskStats = new TaskBaseMetric(topologyId, componentId, taskId);
    this.downstreamTasks = TransactionCommon.getDownstreamTasks(componentId, topologyContext);
    LOG.info("downstreamTasks: {}", downstreamTasks);

    this.outputCollector = new TransactionSpoutOutputCollector(collector, this);

    this.spoutStatus = State.INIT;
    this.committingBatches = new TreeMap<>();
    this.isMaxPending = false;
    this.MAX_PENDING_BATCH_NUM = ConfigExtension.getTransactionMaxPendingBatch(conf);

    int taskLaunchTimeout = JStormUtils.parseInt(conf.get(Config.NIMBUS_TASK_LAUNCH_SECS));
    int spoutInitRetryDelaySec = JStormUtils.parseInt(conf.get("transaction.spout.init.retry.secs"), taskLaunchTimeout);
    this.initRetryCheck = new IntervalCheck();
    initRetryCheck.setInterval(spoutInitRetryDelaySec);

    this.lock = new ReentrantLock(true);
}

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

示例11: MkLocalShuffer

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public MkLocalShuffer(List<Integer> workerTasks, List<Integer> allOutTasks, WorkerData workerData) {
    super(workerData);
    List<Integer> localOutTasks = new ArrayList<>();
    allTargetTasks.addAll(allOutTasks);

    for (Integer outTask : allOutTasks) {
        if (workerTasks.contains(outTask)) {
            localOutTasks.add(outTask);
        }
    }
    this.workerData = workerData;
    intervalCheck = new IntervalCheck();
    intervalCheck.setInterval(60);

    if (localOutTasks.size() != 0) {
        this.outTasks = localOutTasks;
        isLocal = true;
    } else {
        this.outTasks = new ArrayList<>();
        this.outTasks.addAll(allOutTasks);
        refreshLocalNodeTasks();
        isLocal = false;
    }
    randomrange = new RandomRange(outTasks.size());
}

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

示例12: MkLocalFirst

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public MkLocalFirst(List<Integer> workerTasks, List<Integer> allOutTasks, WorkerData workerData) {
    super(workerData);

    intervalCheck = new IntervalCheck();
    intervalCheck.setInterval(10);

    this.allOutTasks.addAll(allOutTasks);
    this.workerData = workerData;

    List<Integer> localWorkerOutTasks = new ArrayList<Integer>();

    for (Integer outTask : allOutTasks) {
        if (workerTasks.contains(outTask)) {
            localWorkerOutTasks.add(outTask);
        }
    }

    remoteOutTasks.addAll(allOutTasks);
    if (localWorkerOutTasks.size() != 0) {
        isLocalWorkerAvail = true;
        localOutTasks.addAll(localWorkerOutTasks);
    } else {
        isLocalWorkerAvail = false;
    }
    randomrange = new RandomRange(localOutTasks.size());
    remoteRandomRange = new RandomRange(remoteOutTasks.size());

    LOG.info("Local out tasks:" + localOutTasks + ", Remote out tasks:" + remoteOutTasks);
}

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

示例13: TpsCounter

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public TpsCounter(String id, Class tclass) {
    this.id = id;
    this.LOG = LoggerFactory.getLogger(tclass);
    
    intervalCheck = new IntervalCheck();
    intervalCheck.setInterval(60);
}

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

示例14: MkShuffer

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public MkShuffer(String sourceComponent, String targetComponent, WorkerData workerData) {
    this.workerData = workerData;
    this.sourceComponent = sourceComponent;
    this.targetComponent = targetComponent;

    intervalCheck = new IntervalCheck();
    intervalCheck.setInterval(60 * 2);

    refreshTasks();

}

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

示例15: MkLocalFirst

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public MkLocalFirst(List<Integer> workerTasks, List<Integer> allOutTasks, WorkerData workerData) {
    super(workerData);

    intervalCheck = new IntervalCheck();
    intervalCheck.setInterval(10);

    this.allOutTasks.addAll(allOutTasks);
    this.workerData = workerData;

    List<Integer> localWorkerOutTasks = new ArrayList<>();

    for (Integer outTask : allOutTasks) {
        if (workerTasks.contains(outTask)) {
            localWorkerOutTasks.add(outTask);
        }
    }

    remoteOutTasks.addAll(allOutTasks);
    if (localWorkerOutTasks.size() != 0) {
        isLocalWorkerAvail = true;
        localOutTasks.addAll(localWorkerOutTasks);
    } else {
        isLocalWorkerAvail = false;
    }
    randomrange = new RandomRange(localOutTasks.size());
    remoteRandomRange = new RandomRange(remoteOutTasks.size());

    LOG.info("Local out tasks:" + localOutTasks + ", remote out tasks:" + remoteOutTasks);

    loadMark = JStormUtils.parseDouble(workerData.getStormConf().get("shuffle.load.mark"), 1.0).floatValue();
}

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

示例16: waitChannelReady

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
void waitChannelReady(long cachedSize, long sleepMs) {
	long begin = System.currentTimeMillis();
	boolean changeThreadhold = false;
	IntervalCheck oneSecond = new IntervalCheck();
	IntervalCheck timeoutIntervalCheck = new IntervalCheck();
	timeoutIntervalCheck.setInterval(timeoutSecond);
	while (isChannelReady() == null) {

		long now = System.currentTimeMillis();
		long delt = now - begin;
		if (oneSecond.check() == true) {
			LOG.warn(
					"Target server  {} is unavailable, pending {}, bufferSize {}, block sending {}ms",
					name, pendings.get(), cachedSize, delt);
		}

		if (timeoutIntervalCheck.check() == true) {
			if (messageBatchRef.get() != null) {
				LOG.warn(
						"Target server  {} is unavailable, wait too much time, throw timeout message",
						name);
				messageBatchRef.set(null);
			}
			setChannel(null);
			LOG.warn("Reset channel as null");
		}

		reconnect();
		JStormUtils.sleepMs(sleepMs);

		if (delt > 2 * timeoutSecond * 1000L && changeThreadhold == false) {
			if (channelRef.get() != null
					&& BATCH_THREASHOLD_WARN >= 2 * messageBatchSize) {
				// it is just channel isn't writable;
				BATCH_THREASHOLD_WARN = BATCH_THREASHOLD_WARN / 2;
				LOG.info("Reduce BATCH_THREASHOLD_WARN to {}",
						BATCH_THREASHOLD_WARN);

				changeThreadhold = true;
			}
		}
		
		if (isClosed()) {
			LOG.info("Channel has been closed " + name());
			break;
		}
	}
}

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

示例17: waitChannelReady

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
void waitChannelReady(long cachedSize, long sleepMs) {
	long begin = System.currentTimeMillis();
	boolean changeThreadhold = false;
	IntervalCheck oneSecond = new IntervalCheck();
	IntervalCheck timeoutIntervalCheck = new IntervalCheck();
	timeoutIntervalCheck.setInterval(timeoutSecond);
	while (isChannelReady() == null) {

		long now = System.currentTimeMillis();
		long delt = now - begin;
		if (oneSecond.check() == true) {
			LOG.warn(
					"Target server  {} is unavailable, pending {}, bufferSize {}, block sending {}ms",
					new Object[]{name, pendings.get(), cachedSize, delt});
		}

		if (timeoutIntervalCheck.check() == true) {
			if (messageBatchRef.get() != null) {
				LOG.warn(
						"Target server  {} is unavailable, wait too much time, throw timeout message",
						name);
				messageBatchRef.set(null);
			}
			setChannel(null);
			LOG.warn("Reset channel as null");
		}

		reconnect();
		JStormUtils.sleepMs(sleepMs);

		if (delt > 2 * timeoutSecond * 1000L && changeThreadhold == false) {
			if (channelRef.get() != null
					&& BATCH_THREASHOLD_WARN >= 2 * messageBatchSize) {
				// it is just channel isn't writable;
				BATCH_THREASHOLD_WARN = BATCH_THREASHOLD_WARN / 2;
				LOG.info("Reduce BATCH_THREASHOLD_WARN to {}",
						BATCH_THREASHOLD_WARN);

				changeThreadhold = true;
			}
		}
		
		if (isClosed()) {
			LOG.info("Channel has been closed " + name());
			break;
		}
	}
}

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

示例18: waitChannelReady

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
void waitChannelReady(long cachedSize, long sleepMs) {
    long begin = System.currentTimeMillis();
    boolean changeThreadhold = false;
    IntervalCheck oneSecond = new IntervalCheck();
    IntervalCheck timeoutIntervalCheck = new IntervalCheck();
    timeoutIntervalCheck.setIntervalMs(timeoutMs);
    sleepMs = (sleepMs < timeoutMs) ? sleepMs : timeoutMs;
    while (isChannelReady() == null) {

        long now = System.currentTimeMillis();
        long delt = now - begin;
        if (oneSecond.check() == true) {
            LOG.warn("Target server  {} is unavailable, pending {}, bufferSize {}, block sending {}ms", name, pendings.get(), cachedSize, delt);
        }

        if (timeoutIntervalCheck.check() == true) {
            if (messageBatchRef.get() != null) {
                LOG.warn("Target server  {} is unavailable, wait too much time, throw timeout message", name);
                messageBatchRef.set(null);
            }
            setChannel(null);
            LOG.warn("Reset channel as null");

            if (blockSend == false) {
                reconnect();
                break;
            }
        }

        reconnect();
        JStormUtils.sleepMs(sleepMs);

        if (delt > 2 * timeoutMs * 1000L && changeThreadhold == false) {
            if (channelRef.get() != null && BATCH_THREASHOLD_WARN >= 2 * messageBatchSize) {
                // it is just channel isn't writable;
                BATCH_THREASHOLD_WARN = BATCH_THREASHOLD_WARN / 2;
                LOG.info("Reduce BATCH_THREASHOLD_WARN to {}", BATCH_THREASHOLD_WARN);

                changeThreadhold = true;
            }
        }

        if (isClosed()) {
            LOG.info("Channel has been closed " + name());
            break;
        }
    }
}

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

示例19: BackpressureTrigger

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
public BackpressureTrigger(Task task, BoltExecutors boltExecutor, Map stormConf, OutputCollector output) {
    super(stormConf);

    this.task = task;
    this.taskId = task.getTaskId();

    int sampleNum = ConfigExtension.getBackpressureTriggerSampleNumber(stormConf);
    int smapleInterval = sampleNum * (ConfigExtension.getBackpressureCheckIntervl(stormConf));
    this.intervalCheck = new IntervalCheck();
    this.intervalCheck.setIntervalMs(smapleInterval);
    this.intervalCheck.start();

    this.samplingSet = new ArrayList<EventType>();
    this.triggerSampleRate = ConfigExtension.getBackpressureTriggerSampleRate(stormConf);

    this.output = output;

    this.boltExecutor = boltExecutor;

    try {
        StormClusterState zkCluster = task.getZkCluster();
        Map<String, SourceBackpressureInfo> backpressureInfo = zkCluster.get_backpressure_info(task.getTopologyId());
        if (backpressureInfo != null) {
            for (Entry<String, SourceBackpressureInfo> entry : backpressureInfo.entrySet()) {
                SourceBackpressureInfo info = entry.getValue();
                Map<String, TargetBackpressureInfo> targetInfoMap = info.getTargetTasks();
                if (targetInfoMap != null) {
                    TargetBackpressureInfo targetInfo = targetInfoMap.get(task.getComponentId());
                    if (targetInfo != null && targetInfo.getTasks().contains(taskId)) {
                        isBackpressureEnable = true;
                        LOG.info("Retrieved backpressure info for task-" + taskId);
                    }
                }
            }
        }
    } catch (Exception e) {
        LOG.info("Failed to get backpressure info from zk", e);
    }
    LOG.info("Finished BackpressureTrigger init, highWaterMark=" + highWaterMark + ", lowWaterMark=" + lowWaterMark + ", sendInterval="
            + intervalCheck.getInterval());
}

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

示例20: prepare

import com.alibaba.jstorm.utils.IntervalCheck; //导入依赖的package包/类
@Override
public void prepare(Map stormConf, TopologyContext context,
                    OutputCollector collector) {
    this.conf = context.getStormConf();
    this.collector = collector;
    this.taskId = context.getThisTaskId();
    this.topologyId = context.getTopologyId();
    this.zkCluster = context.getZkCluster();

    try {
        Assignment assignment = zkCluster.assignment_info(topologyId, null);
        this.workerSet = assignment.getWorkers();
        intervalCheck = new IntervalCheck();
        intervalCheck.setInterval(10);
        intervalCheck.start();
    } catch (Exception e) {
        LOG.error("Failed to get assignment for " + topologyId);
    }

    this.taskHeartbeatUpdater = new TaskHeartbeatUpdater(this.conf, topologyId, taskId, zkCluster);

    this.backpressureCoordinator = new BackpressureCoordinator(collector, context, taskId);

    this.topologyMetricContext = new TopologyMetricContext(topologyId, this.workerSet, this.conf);

    this.uploadMetricsExecutor = Executors.newSingleThreadScheduledExecutor();
    this.uploadMetricsExecutor.scheduleAtFixedRate(new Runnable() {
        @Override
        public void run() {
            int secOffset = TimeUtils.secOffset();
            int offset = 35;
            if (secOffset < offset) {
                JStormUtils.sleepMs((offset - secOffset) * 1000);
            } else if (secOffset == offset) {
                // do nothing
            } else {
                JStormUtils.sleepMs((60 - secOffset + offset) * 1000);
            }
            if (topologyMetricContext.getUploadedWorkerNum() > 0) {
                metricLogger.info("force upload metrics.");
                mergeAndUpload();
            }
        }
    }, 5, 60, TimeUnit.SECONDS);

    updateThread = new Thread(new TopologyMasterRunnable());
    updateThread.start();

    threadAliveCheck = new IntervalCheck();
    threadAliveCheck.setInterval(30);
    threadAliveCheck.start();
}

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

注：本文中的com.alibaba.jstorm.utils.IntervalCheck类示例整理自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 PatientICPStagesLiteVo类代码示例发布时间：2022-05-15

Java ReceiptPrinterSettingsService类代码示例发布时间：2022-05-15

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

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

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

阅读：18080|2023-10-27

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

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

阅读：9613|2022-11-06

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

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

阅读：8147|2022-11-06

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

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

阅读：8530|2022-11-06

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

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

阅读：8432|2022-11-06

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

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

阅读：9343|2022-11-06

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

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

阅读：8395|2022-11-06

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

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

阅读：7832|2022-11-06

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

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

阅读：8385|2022-11-06

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

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

阅读：7380|2022-11-06

客服电话

电子邮件

Java IntervalCheck类代码示例

示例1: open

示例2: open

示例3: TaskHeartbeatTrigger

示例4: open

示例5: RollingWindow

示例6: init

示例7: MkLocalShuffer

示例8: TaskHeartbeatTrigger

示例9: open

示例10: open

示例11: MkLocalShuffer

示例12: MkLocalFirst

示例13: TpsCounter

示例14: MkShuffer

示例15: MkLocalFirst

示例16: waitChannelReady

示例17: waitChannelReady

示例18: waitChannelReady

示例19: BackpressureTrigger

示例20: prepare

请发表评论

全部评论

上一篇：

下一篇：

mlrun/mlrun: Machine Learning automation

Delphi_09_Delphi_Object_Pascal_面向对象

win7系统将IE11降级为IE10的操作方法

aikar/timings: Source to the Aikar&#39;s

信号与系统实验序章0——MATLAB基础命令入

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

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

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

aikar/timings: Source to the Aikar's