public final class KeyGroupStreamFactory<T>
extends java.lang.Object
implements java.util.function.Supplier<org.apache.flink.statefun.flink.core.logger.KeyGroupStream<T>>
Modifier and Type | Method and Description |
---|---|
org.apache.flink.statefun.flink.core.logger.KeyGroupStream<T> |
get() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.