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

Class UnboundedFeedbackLogger<T>

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable, FeedbackLogger<T>

public final class UnboundedFeedbackLogger<T>
extends java.lang.Object
implements FeedbackLogger<T>

Constructor Summary

Constructors

Constructor and Description
UnboundedFeedbackLogger(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
void	append(T message) Append a message to the currently logging logger.
void	close()
void	commit() Commit the currently logging logger.
void	replyLoggedEnvelops(java.io.InputStream rawKeyedStateInputs, FeedbackConsumer<T> consumer)
void	startLogging(java.io.OutputStream keyedStateCheckpointOutputStream) Start logging messages into the supplied output stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

UnboundedFeedbackLogger

public UnboundedFeedbackLogger(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

startLogging

public void startLogging(java.io.OutputStream keyedStateCheckpointOutputStream)

Description copied from interface: FeedbackLogger

Start logging messages into the supplied output stream.

Specified by:

startLogging in interface FeedbackLogger<T>

append

public void append(T message)

Description copied from interface: FeedbackLogger

Append a message to the currently logging logger.

Specified by:

append in interface FeedbackLogger<T>

commit

public void commit()

Description copied from interface: FeedbackLogger

Commit the currently logging logger.

Specified by:

commit in interface FeedbackLogger<T>

replyLoggedEnvelops

public void replyLoggedEnvelops(java.io.InputStream rawKeyedStateInputs,
                                FeedbackConsumer<T> consumer)
                         throws java.lang.Exception

Throws:

java.lang.Exception

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable