org.apache.flink.statefun.flink.core.logger

Class UnboundedFeedbackLoggerFactory<T>

java.lang.Object

org.apache.flink.statefun.flink.core.logger.UnboundedFeedbackLoggerFactory<T>

public final class UnboundedFeedbackLoggerFactory<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
UnboundedFeedbackLoggerFactory(java.util.function.Supplier<org.apache.flink.statefun.flink.core.logger.KeyGroupStream<T>> supplier, java.util.function.ToIntFunction<T> keyGroupAssigner, CheckpointedStreamOperations ops, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)

Method Summary

Modifier and Type	Method and Description
UnboundedFeedbackLogger<T>	create()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnboundedFeedbackLoggerFactory

public UnboundedFeedbackLoggerFactory(java.util.function.Supplier<org.apache.flink.statefun.flink.core.logger.KeyGroupStream<T>> supplier,
                                      java.util.function.ToIntFunction<T> keyGroupAssigner,
                                      CheckpointedStreamOperations ops,
                                      org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)

Method Detail

create

public UnboundedFeedbackLogger<T> create()