org.apache.beam.sdk.io.kafka.jmh

Class KafkaIOUtilsBenchmark

java.lang.Object

org.apache.beam.sdk.io.kafka.jmh.KafkaIOUtilsBenchmark

public class KafkaIOUtilsBenchmark
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaIOUtilsBenchmark.AtomicAccumulatorState
static class	KafkaIOUtilsBenchmark.PlainAccumulatorState
static class	KafkaIOUtilsBenchmark.ProducerState
static class	KafkaIOUtilsBenchmark.VolatileAccumulatorState

Constructor Summary

Constructors

Constructor and Description
KafkaIOUtilsBenchmark()

Method Summary

Modifier and Type	Method and Description
double	atomicRead(KafkaIOUtilsBenchmark.AtomicAccumulatorState as)
double	atomicReadWhileWriting(KafkaIOUtilsBenchmark.AtomicAccumulatorState as)
void	atomicWrite(KafkaIOUtilsBenchmark.AtomicAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)
void	atomicWriteWhileReading(KafkaIOUtilsBenchmark.AtomicAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)
double	plainRead(KafkaIOUtilsBenchmark.PlainAccumulatorState as)
double	plainReadWhileWriting(KafkaIOUtilsBenchmark.PlainAccumulatorState as)
void	plainWrite(KafkaIOUtilsBenchmark.PlainAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)
void	plainWriteWhileReading(KafkaIOUtilsBenchmark.PlainAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)
double	synchronizedPlainRead(KafkaIOUtilsBenchmark.PlainAccumulatorState as)
double	synchronizedPlainReadWhileWriting(KafkaIOUtilsBenchmark.PlainAccumulatorState as)
void	synchronizedPlainWrite(KafkaIOUtilsBenchmark.PlainAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)
void	synchronizedPlainWriteWhileReading(KafkaIOUtilsBenchmark.PlainAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)
double	volatileRead(KafkaIOUtilsBenchmark.VolatileAccumulatorState as)
double	volatileReadWhileWriting(KafkaIOUtilsBenchmark.VolatileAccumulatorState as)
void	volatileWrite(KafkaIOUtilsBenchmark.VolatileAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)
void	volatileWriteWhileReading(KafkaIOUtilsBenchmark.VolatileAccumulatorState as, KafkaIOUtilsBenchmark.ProducerState ps)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaIOUtilsBenchmark

public KafkaIOUtilsBenchmark()

Method Detail

plainWrite

public void plainWrite(KafkaIOUtilsBenchmark.PlainAccumulatorState as,
                       KafkaIOUtilsBenchmark.ProducerState ps)

plainRead

public double plainRead(KafkaIOUtilsBenchmark.PlainAccumulatorState as)

plainWriteWhileReading

public void plainWriteWhileReading(KafkaIOUtilsBenchmark.PlainAccumulatorState as,
                                   KafkaIOUtilsBenchmark.ProducerState ps)

plainReadWhileWriting

public double plainReadWhileWriting(KafkaIOUtilsBenchmark.PlainAccumulatorState as)

synchronizedPlainWrite

public void synchronizedPlainWrite(KafkaIOUtilsBenchmark.PlainAccumulatorState as,
                                   KafkaIOUtilsBenchmark.ProducerState ps)

synchronizedPlainRead

public double synchronizedPlainRead(KafkaIOUtilsBenchmark.PlainAccumulatorState as)

synchronizedPlainWriteWhileReading

public void synchronizedPlainWriteWhileReading(KafkaIOUtilsBenchmark.PlainAccumulatorState as,
                                               KafkaIOUtilsBenchmark.ProducerState ps)

synchronizedPlainReadWhileWriting

public double synchronizedPlainReadWhileWriting(KafkaIOUtilsBenchmark.PlainAccumulatorState as)

atomicWrite

public void atomicWrite(KafkaIOUtilsBenchmark.AtomicAccumulatorState as,
                        KafkaIOUtilsBenchmark.ProducerState ps)

atomicRead

public double atomicRead(KafkaIOUtilsBenchmark.AtomicAccumulatorState as)

atomicWriteWhileReading

public void atomicWriteWhileReading(KafkaIOUtilsBenchmark.AtomicAccumulatorState as,
                                    KafkaIOUtilsBenchmark.ProducerState ps)

atomicReadWhileWriting

public double atomicReadWhileWriting(KafkaIOUtilsBenchmark.AtomicAccumulatorState as)

volatileWrite

public void volatileWrite(KafkaIOUtilsBenchmark.VolatileAccumulatorState as,
                          KafkaIOUtilsBenchmark.ProducerState ps)

volatileRead

public double volatileRead(KafkaIOUtilsBenchmark.VolatileAccumulatorState as)

volatileWriteWhileReading

public void volatileWriteWhileReading(KafkaIOUtilsBenchmark.VolatileAccumulatorState as,
                                      KafkaIOUtilsBenchmark.ProducerState ps)

volatileReadWhileWriting

public double volatileReadWhileWriting(KafkaIOUtilsBenchmark.VolatileAccumulatorState as)