Package io.confluent.kafka.schemaregistry.tools

Class SchemaRegistryPerformance

java.lang.Object

io.confluent.common.utils.AbstractPerformanceTest

io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance

Direct Known Subclasses:

SchemaRegistryClientPerformance

public class SchemaRegistryPerformance
extends io.confluent.common.utils.AbstractPerformanceTest

Field Summary

Fields inherited from class io.confluent.common.utils.AbstractPerformanceTest

stats, targetIterationRate

Constructor Summary

Constructors

Constructor	Description
SchemaRegistryPerformance(String baseUrl, String subject, long numSchemas, long targetSchemasPerSec, String schemaType)

Method Summary

Modifier and Type	Method	Description
protected void	close()
protected void	doIteration(io.confluent.common.utils.PerformanceStats.Callback cb)
protected boolean	finished(int iteration)
protected void	init()
static void	main(String[] args)
static ParsedSchema	makeParsedSchema(String schemaType, long num)
static String	makeSchema(String schemaType, long num)
protected boolean	runningFast(int iteration, float elapsed)

Methods inherited from class io.confluent.common.utils.AbstractPerformanceTest

getTargetIterationRate, run, run

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaRegistryPerformance

public SchemaRegistryPerformance(String baseUrl,
 String subject,
 long numSchemas,
 long targetSchemasPerSec,
 String schemaType)

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

init

protected void init()
             throws Exception

Throws:

Exception

makeSchema

public static String makeSchema(String schemaType,
 long num)

makeParsedSchema

public static ParsedSchema makeParsedSchema(String schemaType,
 long num)

doIteration

protected void doIteration(io.confluent.common.utils.PerformanceStats.Callback cb)

Specified by:

doIteration in class io.confluent.common.utils.AbstractPerformanceTest

close

protected void close()
              throws IOException

Throws:

IOException

finished

protected boolean finished(int iteration)

Specified by:

finished in class io.confluent.common.utils.AbstractPerformanceTest

runningFast

protected boolean runningFast(int iteration,
 float elapsed)

Specified by:

runningFast in class io.confluent.common.utils.AbstractPerformanceTest