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

WindowedElement.getWindow介绍

暂无

代码示例

代码示例来源：origin: seznam/euphoria

@Override
@SuppressWarnings("unchecked")
public Iterable<WID> assignWindowsToElement(WindowedElement<?, T> el) {
 return Collections.singleton((WID) el.getWindow());
}

代码示例来源：origin: seznam/euphoria

@SuppressWarnings("unchecked")
@Override
public Iterable<W> assignWindowsToElement(WindowedElement<?, T> input) {
 return Collections.singleton((W) input.getWindow());
}

代码示例来源：origin: seznam/euphoria

@SuppressWarnings("unchecked")
@Override
public Iterable<W> assignWindowsToElement(WindowedElement<?, T> input) {
 return Collections.singleton((W) input.getWindow());
}

代码示例来源：origin: seznam/euphoria

@Override
@SuppressWarnings("unchecked")
public Iterable<W> assignWindowsToElement(WindowedElement<?, T> input) {
 return Collections.singleton((W) input.getWindow());
}

代码示例来源：origin: seznam/euphoria

@Override
@SuppressWarnings("unchecked")
public Iterable<W> assignWindowsToElement(WindowedElement<?, T> input) {
 return Collections.singleton((W) input.getWindow());
}

代码示例来源：origin: seznam/euphoria

@SuppressWarnings("unchecked")
public void process(WindowedElement<WID, Pair<KEY, I>> elem) {
 // ~ make sure we have the key
 updateKey(elem);
 // ~ advance our clock
 clock.updateStamp(elem.getTimestamp(), this::onTimerCallback);
 // ~ get the target window
 WID window = elem.getWindow();
 // ~ merge the new window into existing ones if necessary
 if (windowing instanceof MergingWindowing) {
  window = mergeWindows(window);
 }
 // ~ add the value to the target window state
 {
  State state = getStateForUpdate(window);
  state.add(elem.getElement().getSecond());
 }
 // ~ process trigger#onElement
 {
  ElementTriggerContext trgCtx = new ElementTriggerContext(window);
  Trigger.TriggerResult windowTr =
      trigger.onElement(elem.getTimestamp(), window, trgCtx);
  processTriggerResult(window, trgCtx, windowTr);
 }
}

代码示例来源：origin: seznam/euphoria

@SuppressWarnings("unchecked")
public void process(WindowedElement<WID, Pair<KEY, I>> elem) {
 // ~ make sure we have the key
 updateKey(elem);
 // ~ advance our clock
 clock.updateStamp(elem.getTimestamp(), this::onTimerCallback);
 // ~ get the target window
 WID window = elem.getWindow();
 // ~ merge the new window into existing ones if necessary
 if (windowing instanceof MergingWindowing) {
  window = mergeWindows(window);
 }
 // ~ add the value to the target window state
 {
  State state = getStateForUpdate(window);
  state.add(elem.getElement().getSecond());
 }
 // ~ process trigger#onElement
 {
  ElementTriggerContext trgCtx = new ElementTriggerContext(window);
  Trigger.TriggerResult windowTr =
      trigger.onElement(elem.getTimestamp(), window, trgCtx);
  processTriggerResult(window, trgCtx, windowTr);
 }
}