org.apache.beam.sdk.util.WindowedValue.getWindows()方法的使用及代码示例

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

WindowedValue.getWindows介绍

[英]Returns the windows of this WindowedValue.
[中]返回此WindowedValue的窗口。

代码示例

代码示例来源：origin: org.apache.beam/beam-runners-core-java

/** Extract the windows associated with the values. */
private Set collectWindows(Iterable> values) throws Exception {
Set windows = new HashSet<>();
for (WindowedValue value : values) {
for (BoundedWindow untypedWindow : value.getWindows()) {
@SuppressWarnings("unchecked")
W window = (W) untypedWindow;
windows.add(window);
}
}
return windows;
}

代码示例来源：origin: org.apache.beam/beam-runners-flink_2.11

private Set collectWindows(Iterable>> values) {
Set windows = new HashSet<>();
for (WindowedValue value : values) {
for (BoundedWindow untypedWindow : value.getWindows()) {
@SuppressWarnings("unchecked")
W window = (W) untypedWindow;
windows.add(window);
}
}
return windows;
}
}

代码示例来源：origin: org.apache.beam/beam-runners-flink

private Set collectWindows(Iterable>> values) {
Set windows = new HashSet<>();
for (WindowedValue value : values) {
for (BoundedWindow untypedWindow : value.getWindows()) {
@SuppressWarnings("unchecked")
W window = (W) untypedWindow;
windows.add(window);
}
}
return windows;
}
}

代码示例来源：origin: org.apache.beam/beam-runners-flink_2.11

FlinkAssignContext(WindowFn fn, WindowedValue value) {
fn.super();
if (Iterables.size(value.getWindows()) != 1) {
throw new IllegalArgumentException(
String.format(
"%s passed to window assignment must be in a single window, but it was in %s: %s",
WindowedValue.class.getSimpleName(),
Iterables.size(value.getWindows()),
value.getWindows()));
}
this.value = value;
}

代码示例来源：origin: org.apache.beam/beam-runners-flink

FlinkAssignContext(WindowFn fn, WindowedValue value) {
fn.super();
if (Iterables.size(value.getWindows()) != 1) {
throw new IllegalArgumentException(
String.format(
"%s passed to window assignment must be in a single window, but it was in %s: %s",
WindowedValue.class.getSimpleName(),
Iterables.size(value.getWindows()),
value.getWindows()));
}
this.value = value;
}

代码示例来源：origin: org.apache.beam/beam-runners-flink_2.10

FlinkAssignContext(WindowFn fn, WindowedValue value) {
fn.super();
if (Iterables.size(value.getWindows()) != 1) {
throw new IllegalArgumentException(
String.format(
"%s passed to window assignment must be in a single window, but it was in %s: %s",
WindowedValue.class.getSimpleName(),
Iterables.size(value.getWindows()),
value.getWindows()));
}
this.value = value;
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Override
public BoundedWindow window() {
return Iterables.getOnlyElement(value.getWindows());
}
}

代码示例来源：origin: org.apache.beam/beam-runners-spark

@Override
public T sideInput(PCollectionView view) {
checkNotNull(input, "Input in SparkCombineContext must not be null!");
//validate element window.
final Collection elementWindows = input.getWindows();
checkState(
elementWindows.size() == 1,
"sideInput can only be called when the main " + "input element is in exactly one window");
return sideInputReader.get(view, elementWindows.iterator().next());
}
}

代码示例来源：origin: org.apache.beam/beam-runners-spark

protected static Iterable> sortByWindows(Iterable> iter) {
List> sorted = Lists.newArrayList(iter);
sorted.sort(Comparator.comparing(o -> Iterables.getOnlyElement(o.getWindows()).maxTimestamp()));
return sorted;
}

代码示例来源：origin: org.apache.beam/beam-runners-flink_2.10

@Override
public int compare(
WindowedValue> o1,
WindowedValue> o2) {
return Iterables.getOnlyElement(o1.getWindows()).maxTimestamp()
.compareTo(Iterables.getOnlyElement(o2.getWindows()).maxTimestamp());
}
});

代码示例来源：origin: org.apache.beam/beam-runners-core-java

@Override
protected boolean matchesSafely(WindowedValue windowedValue) {
return valueMatcher.matches(windowedValue.getValue())
&& timestampMatcher.matches(windowedValue.getTimestamp())
&& windowsMatcher.matches(windowedValue.getWindows())
&& paneInfoMatcher.matches(windowedValue.getPane());
}
}

代码示例来源：origin: org.apache.beam/beam-runners-flink

@Override
public void output(TupleTag tag, WindowedValue output) {
collector.collect(
WindowedValue.of(
new RawUnionValue(outputMap.get(tag), output.getValue()),
output.getTimestamp(),
output.getWindows(),
output.getPane()));
}
}

代码示例来源：origin: org.apache.beam/beam-runners-gearpump

@Override
public KV>> map(WindowedValue> wv) {
BoundedWindow window = Iterables.getOnlyElement(wv.getWindows());
Instant timestamp =
timestampCombiner.assign(window, windowFn.getOutputTime(wv.getTimestamp(), window));
return KV.of(timestamp, wv);
}
}

代码示例来源：origin: org.apache.beam/beam-runners-flink_2.11

@Override
@SuppressWarnings("unchecked")
public void output(TupleTag tag, WindowedValue output) {
collector.collect(
WindowedValue.of(
new RawUnionValue(0 /* single output */, output.getValue()),
output.getTimestamp(),
output.getWindows(),
output.getPane()));
}
}

代码示例来源：origin: org.apache.beam/beam-runners-flink_2.10

@Override
@SuppressWarnings("unchecked")
public void output(TupleTag tag, WindowedValue output) {
collector.collect(
WindowedValue.of(new RawUnionValue(0 /* single output */, output.getValue()),
output.getTimestamp(), output.getWindows(), output.getPane()));
}
}

代码示例来源：origin: org.apache.beam/beam-runners-flink

@Override
@SuppressWarnings("unchecked")
public void output(TupleTag tag, WindowedValue output) {
collector.collect(
WindowedValue.of(
new RawUnionValue(0 /* single output */, output.getValue()),
output.getTimestamp(),
output.getWindows(),
output.getPane()));
}
}

代码示例来源：origin: org.apache.beam/beam-runners-spark

@Override
public WindowedValue> call(WindowedValue>> windowedKv)
throws Exception {
return WindowedValue.of(
KV.of(windowedKv.getValue().getKey(), fn.apply(windowedKv)),
windowedKv.getTimestamp(),
windowedKv.getWindows(),
windowedKv.getPane());
}
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

/**
* Returns a collection of {@link WindowedValue WindowedValues} identical to this one, except each
* is in exactly one of the windows that this {@link WindowedValue} is in.
*/
public Iterable> explodeWindows() {
ImmutableList.Builder> windowedValues = ImmutableList.builder();
for (BoundedWindow w : getWindows()) {
windowedValues.add(of(getValue(), getTimestamp(), w, getPane()));
}
return windowedValues.build();
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public void encode(WindowedValue windowedElem, OutputStream outStream, Context context)
throws CoderException, IOException {
InstantCoder.of().encode(windowedElem.getTimestamp(), outStream);
windowsCoder.encode(windowedElem.getWindows(), outStream);
PaneInfoCoder.INSTANCE.encode(windowedElem.getPane(), outStream);
valueCoder.encode(windowedElem.getValue(), outStream, context);
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Override
public void registerByteSizeObserver(WindowedValue value, ElementByteSizeObserver observer)
throws Exception {
InstantCoder.of().registerByteSizeObserver(value.getTimestamp(), observer);
windowsCoder.registerByteSizeObserver(value.getWindows(), observer);
PaneInfoCoder.INSTANCE.registerByteSizeObserver(value.getPane(), observer);
valueCoder.registerByteSizeObserver(value.getValue(), observer);
}