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

Class Loggers

java.lang.Object

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

public final class Loggers
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static UnboundedFeedbackLoggerFactory<?>	unboundedSpillableLoggerFactory(org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, int maxParallelism, long inMemoryMaxBufferSize, org.apache.flink.api.common.typeutils.TypeSerializer<?> serializer, java.util.function.Function<?,?> keySelector)

Methods inherited from class java.lang.Object

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

Method Detail

unboundedSpillableLoggerFactory

public static UnboundedFeedbackLoggerFactory<?> unboundedSpillableLoggerFactory(org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
                                                                                int maxParallelism,
                                                                                long inMemoryMaxBufferSize,
                                                                                org.apache.flink.api.common.typeutils.TypeSerializer<?> serializer,
                                                                                java.util.function.Function<?,?> keySelector)