Package org.apache.pinot.tools.perf

Class PerfBenchmarkDriver

java.lang.Object

org.apache.pinot.tools.perf.PerfBenchmarkDriver

public class PerfBenchmarkDriver
extends Object

Constructor Summary

Constructors

Constructor	Description
PerfBenchmarkDriver(PerfBenchmarkDriverConf conf)
PerfBenchmarkDriver(PerfBenchmarkDriverConf conf, String tempDir, String loadMode, String segmentFormatVersion, boolean verbose)

Method Summary

Modifier and Type	Method	Description
void	addSegment(String tableNameWithType, org.apache.pinot.segment.spi.SegmentMetadata segmentMetadata)	Add segment while segment data is already in server data directory.
void	configureTable(String tableName)
void	configureTable(String tableName, List<String> invertedIndexColumns, List<String> bloomFilterColumns)
static void	main(String[] args)
com.fasterxml.jackson.databind.JsonNode	postQuery(String query)
com.fasterxml.jackson.databind.JsonNode	postQuery(String dialect, String query)
com.fasterxml.jackson.databind.JsonNode	postQuery(String dialect, String query, Map<String,String> headers)
com.fasterxml.jackson.databind.JsonNode	postQuery(String query, Map<String,String> headers)
void	run()
static PerfBenchmarkDriver	startComponents(boolean isStartZookeeper, boolean isStartController, boolean isStartBroker, boolean isStartServer, String serverDataDir)	Start cluster components with default configuration.
static void	waitForExternalViewUpdate(String zkAddress, String clusterName, long timeoutInMilliseconds)

Methods inherited from class java.lang.Object

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

Constructor Detail

PerfBenchmarkDriver

public PerfBenchmarkDriver(PerfBenchmarkDriverConf conf)

PerfBenchmarkDriver

public PerfBenchmarkDriver(PerfBenchmarkDriverConf conf,
                           String tempDir,
                           String loadMode,
                           String segmentFormatVersion,
                           boolean verbose)

Method Detail

run

public void run()
         throws Exception

Throws:

Exception

configureTable

public void configureTable(String tableName)
                    throws Exception

Throws:

Exception

configureTable

public void configureTable(String tableName,
                           List<String> invertedIndexColumns,
                           List<String> bloomFilterColumns)
                    throws Exception

Throws:

Exception

addSegment

public void addSegment(String tableNameWithType,
                       org.apache.pinot.segment.spi.SegmentMetadata segmentMetadata)

Add segment while segment data is already in server data directory.

Parameters:

segmentMetadata - segment metadata.

waitForExternalViewUpdate

public static void waitForExternalViewUpdate(String zkAddress,
                                             String clusterName,
                                             long timeoutInMilliseconds)

postQuery

public com.fasterxml.jackson.databind.JsonNode postQuery(String query)
                                                  throws Exception

Throws:

Exception

postQuery

public com.fasterxml.jackson.databind.JsonNode postQuery(String query,
                                                         Map<String,String> headers)
                                                  throws Exception

Throws:

Exception

postQuery

public com.fasterxml.jackson.databind.JsonNode postQuery(String dialect,
                                                         String query)
                                                  throws Exception

Throws:

Exception

postQuery

public com.fasterxml.jackson.databind.JsonNode postQuery(String dialect,
                                                         String query,
                                                         Map<String,String> headers)
                                                  throws Exception

Throws:

Exception

startComponents

public static PerfBenchmarkDriver startComponents(boolean isStartZookeeper,
                                                  boolean isStartController,
                                                  boolean isStartBroker,
                                                  boolean isStartServer,
                                                  @Nullable
                                                  String serverDataDir)
                                           throws Exception

Start cluster components with default configuration.

Parameters:

isStartZookeeper - whether to start zookeeper.

isStartController - whether to start controller.

isStartBroker - whether to start broker.

isStartServer - whether to start server.

Returns:

perf benchmark driver.

Throws:

Exception

main

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

Throws:

Exception