org.apache.flink.runtime.io.network.logger

Class NetworkActionsLogger

java.lang.Object

org.apache.flink.runtime.io.network.logger.NetworkActionsLogger

public class NetworkActionsLogger
extends Object

Utility class for logging actions that happened in the network stack for debugging purposes.

Action parameter typically includes class and method names.

Constructor Summary

Constructors

Constructor and Description
NetworkActionsLogger()

Method Summary

Modifier and Type	Method and Description
static Closeable	measureIO(String action, Object entity)
static void	traceInput(String action, Buffer buffer, String taskName, InputChannelInfo channelInfo, ChannelStatePersister channelStatePersister, int sequenceNumber)
static void	traceOutput(String action, Buffer buffer, String taskName, ResultSubpartitionInfo channelInfo)
static void	tracePersist(String action, Buffer buffer, Object channelInfo, long checkpointId)
static void	traceRecover(String action, BufferConsumer bufferConsumer, String taskName, ResultSubpartitionInfo channelInfo)
static void	traceRecover(String action, Buffer buffer, String taskName, InputChannelInfo channelInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

NetworkActionsLogger

public NetworkActionsLogger()

Method Detail

traceInput

public static void traceInput(String action,
                              Buffer buffer,
                              String taskName,
                              InputChannelInfo channelInfo,
                              ChannelStatePersister channelStatePersister,
                              int sequenceNumber)

traceOutput

public static void traceOutput(String action,
                               Buffer buffer,
                               String taskName,
                               ResultSubpartitionInfo channelInfo)

traceRecover

public static void traceRecover(String action,
                                Buffer buffer,
                                String taskName,
                                InputChannelInfo channelInfo)

traceRecover

public static void traceRecover(String action,
                                BufferConsumer bufferConsumer,
                                String taskName,
                                ResultSubpartitionInfo channelInfo)

tracePersist

public static void tracePersist(String action,
                                Buffer buffer,
                                Object channelInfo,
                                long checkpointId)

measureIO

public static Closeable measureIO(String action,
                                  Object entity)