stream.scotty.flinkBenchmark

Class ThroughputLogger<T>

java.lang.Object

flinkBenchmark.stream.scotty.ThroughputLogger<T>

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.api.common.functions.FlatMapFunction<T,java.lang.Integer>, org.apache.flink.api.common.functions.Function

public class ThroughputLogger<T>
extends java.lang.Object
implements org.apache.flink.api.common.functions.FlatMapFunction<T,java.lang.Integer>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private int	elementSize
private long	lastLogTimeMs
private long	lastTotalReceived
private static org.slf4j.Logger	LOG
private long	logfreq
private long	totalReceived

Constructor Summary

Constructors

Constructor and Description
ThroughputLogger(int elementSize, long logfreq)

Method Summary

Modifier and Type	Method and Description
void	flatMap(T element, org.apache.flink.util.Collector<java.lang.Integer> collector)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

totalReceived

private long totalReceived

lastTotalReceived

private long lastTotalReceived

lastLogTimeMs

private long lastLogTimeMs

elementSize

private int elementSize

logfreq

private long logfreq

Constructor Detail

ThroughputLogger

public ThroughputLogger(int elementSize,
                        long logfreq)

Method Detail

flatMap

public void flatMap(T element,
                    org.apache.flink.util.Collector<java.lang.Integer> collector)
             throws java.lang.Exception

Specified by:

flatMap in interface org.apache.flink.api.common.functions.FlatMapFunction<T,java.lang.Integer>

Throws:

java.lang.Exception