org.apache.pinot.tools.admin.command

Class QuickstartRunner

java.lang.Object

org.apache.pinot.tools.admin.command.QuickstartRunner

public class QuickstartRunner
extends Object

Constructor Summary

Constructors

Constructor and Description
QuickstartRunner(List<QuickstartTableRequest> tableRequests, int numServers, int numBrokers, int numControllers, File tempDir)
QuickstartRunner(List<QuickstartTableRequest> tableRequests, int numServers, int numBrokers, int numControllers, File tempDir, boolean enableIsolation)

Method Summary

Modifier and Type	Method and Description
void	addTable()
void	createBrokerTenantWith(int number, String tenantName)
void	createServerTenantWith(int numOffline, int numRealtime, String tenantName)
void	launchDataIngestionJob()
com.fasterxml.jackson.databind.JsonNode	runQuery(String query)
void	startAll()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

QuickstartRunner

public QuickstartRunner(List<QuickstartTableRequest> tableRequests,
                        int numServers,
                        int numBrokers,
                        int numControllers,
                        File tempDir,
                        boolean enableIsolation)
                 throws Exception

Throws:

Exception

QuickstartRunner

public QuickstartRunner(List<QuickstartTableRequest> tableRequests,
                        int numServers,
                        int numBrokers,
                        int numControllers,
                        File tempDir)
                 throws Exception

Throws:

Exception

Method Detail

startAll

public void startAll()
              throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

createServerTenantWith

public void createServerTenantWith(int numOffline,
                                   int numRealtime,
                                   String tenantName)
                            throws Exception

Throws:

Exception

createBrokerTenantWith

public void createBrokerTenantWith(int number,
                                   String tenantName)
                            throws Exception

Throws:

Exception

addTable

public void addTable()
              throws Exception

Throws:

Exception

launchDataIngestionJob

public void launchDataIngestionJob()
                            throws Exception

Throws:

Exception

runQuery

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

Throws:

Exception