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

Class KafkaIOUtilsBenchmark.ProducerState

java.lang.Object

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

Enclosing class:

KafkaIOUtilsBenchmark

public static class KafkaIOUtilsBenchmark.ProducerState
extends Object

Constructor Summary

Constructors

Constructor	Description
ProducerState()

Method Summary

Modifier and Type	Method	Description
void	setup(IterationParams ip, ThreadParams tp)

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerState

public ProducerState()

Method Details

setup

public void setup(IterationParams ip,
 ThreadParams tp)