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

Watermark.equals介绍

暂无

代码示例

代码示例来源：origin: apache/flink

@Override
  protected void handleWatermark(Watermark mark) {
    if (mark.equals(Watermark.MAX_WATERMARK)) {
      output.emitWatermark(mark);
      lastWatermark = Long.MAX_VALUE;
    }
  }
}

代码示例来源：origin: apache/flink

if (!CustomOperator.finalWatermarks[i].get(j).equals(new Watermark(initialTime + j))) {
  System.err.println("All Watermarks: ");
  for (int k = 0; k <= numWatermarks / 2; k++) {

代码示例来源：origin: apache/flink

if (!CustomOperator.finalWatermarks[0].get(j).equals(new Watermark(j))) {
  Assert.fail("Wrong watermark.");

代码示例来源：origin: apache/flink

if (!CustomOperator.finalWatermarks[0].get(j).equals(new Watermark(j))) {
  Assert.fail("Wrong watermark.");

代码示例来源：origin: apache/flink

if (!CustomOperator.finalWatermarks[0].get(j).equals(new Watermark(j))) {
  long wm = CustomOperator.finalWatermarks[0].get(j).getTimestamp();
  Assert.fail("Wrong watermark. Expected: " + j + " Found: " + wm + " All: " + CustomOperator.finalWatermarks[0]);