@Test public void testNoEvents() throws Exception { waterMarkEventGenerator.run(); assertTrue(eventList.isEmpty()); }
@Override public void run() { ThreadContext.put("function", WindowUtils.getFullyQualifiedName( context.getTenant(), context.getNamespace(), context.getFunctionName())); try { long waterMarkTs = computeWaterMarkTs(); if (waterMarkTs > lastWaterMarkTs) { windowManager.add(new WaterMarkEvent<>(waterMarkTs)); lastWaterMarkTs = waterMarkTs; } } catch (Throwable th) { log.error("Failed while processing watermark event ", th); throw th; } }
WaterMarkEventGenerator implements Runnable { @Override public void run() { ThreadContext.put("function", WindowUtils.getFullyQualifiedName( context.getTenant(), context.getNamespace(), context.getFunctionName())); try { long waterMarkTs = computeWaterMarkTs(); if (waterMarkTs > lastWaterMarkTs) { windowManager.add(new WaterMarkEvent<>(waterMarkTs)); lastWaterMarkTs = waterMarkTs; } } catch (Throwable th) { log.error("Failed while processing watermark event ", th); throw th; } } }
WaterMarkEventGenerator implements Runnable { @Override public void run() { ThreadContext.put("function", WindowUtils.getFullyQualifiedName( context.getTenant(), context.getNamespace(), context.getFunctionName())); try { long waterMarkTs = computeWaterMarkTs(); if (waterMarkTs > lastWaterMarkTs) { windowManager.add(new WaterMarkEvent<>(waterMarkTs)); lastWaterMarkTs = waterMarkTs; } } catch (Throwable th) { log.error("Failed while processing watermark event ", th); throw th; } } WaterMarkEventGenerator(WindowManager<T> windowManager, long intervalMs,
                                   long eventTsLagMs, Set<String> inputTopics, Context context); }
WaterMarkEventGenerator implements Runnable { @Override public void run() { ThreadContext.put("function", WindowUtils.getFullyQualifiedName( context.getTenant(), context.getNamespace(), context.getFunctionName())); try { long waterMarkTs = computeWaterMarkTs(); if (waterMarkTs > lastWaterMarkTs) { windowManager.add(new WaterMarkEvent<>(waterMarkTs)); lastWaterMarkTs = waterMarkTs; } } catch (Throwable th) { log.error("Failed while processing watermark event ", th); throw th; } } WaterMarkEventGenerator(WindowManager<T> windowManager, long intervalMs,
                                   long eventTsLagMs, Set<String> inputTopics, Context context); boolean track(String inputTopic, long ts); @Override void run(); void start(); void shutdown(); }
WaterMarkEventGenerator implements Runnable { @Override public void run() { ThreadContext.put("function", WindowUtils.getFullyQualifiedName( context.getTenant(), context.getNamespace(), context.getFunctionName())); try { long waterMarkTs = computeWaterMarkTs(); if (waterMarkTs > lastWaterMarkTs) { windowManager.add(new WaterMarkEvent<>(waterMarkTs)); lastWaterMarkTs = waterMarkTs; } } catch (Throwable th) { log.error("Failed while processing watermark event ", th); throw th; } } WaterMarkEventGenerator(WindowManager<T> windowManager, long intervalMs,
                                   long eventTsLagMs, Set<String> inputTopics, Context context); boolean track(String inputTopic, long ts); @Override void run(); void start(); void shutdown();  }