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

Interface FeedbackLogger<T>

All Superinterfaces:

java.lang.AutoCloseable

All Known Implementing Classes:

UnboundedFeedbackLogger

public interface FeedbackLogger<T>
extends java.lang.AutoCloseable

Method Summary

Modifier and Type	Method and Description
void	append(T message) Append a message to the currently logging logger.
void	commit() Commit the currently logging logger.
void	startLogging(java.io.OutputStream keyedStateCheckpointOutputStream) Start logging messages into the supplied output stream.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

startLogging

void startLogging(java.io.OutputStream keyedStateCheckpointOutputStream)

Start logging messages into the supplied output stream.

append

void append(T message)

Append a message to the currently logging logger.

commit

void commit()

Commit the currently logging logger.