Apache风暴喷口出流速率的研究

efzxgjgh  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(252)

在apachestorm中,如何在不使用sleep命令的情况下限制喷口传输元组的秒数?例如,我不想使用此代码。谢谢

puplic Void Next Tuple(){
     utils.sleep(time);
}
vbopmzt1

vbopmzt11#

我假设你希望元组以较慢的速度发射?作为一个程序员,这是一个非常简单的解决方案,你应该已经想出了。伪代码是这样的:

class MyClass {
private boolean timeUp = false;
public void nextTuple() {
    if (timeUp) {
      EmitMyTuple();
      ResetTimeCounterToZero();
      timeUp = false;
    } else {
      boolean greater = CheckIfTimeIsGreaterThanOneSecond();
      if (greater) {timeUp = true;}
    }
  }
  SleepForFewMilliseconds();
}

相关问题