Package 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	Description
QuickstartRunner(List<QuickstartTableRequest> tableRequests, int numControllers, int numBrokers, int numServers, int numMinions, File tempDir, boolean enableIsolation, String authToken, Map<String,Object> configOverrides)
QuickstartRunner(List<QuickstartTableRequest> tableRequests, int numControllers, int numBrokers, int numServers, File tempDir)

Method Summary

Modifier and Type	Method	Description
void	addTable()	Deprecated.
void	bootstrapTable()
void	createBrokerTenantWith(int number, String tenantName)
void	createServerTenantWith(int numOffline, int numRealtime, String tenantName)
void	launchDataIngestionJob()	Deprecated.
static void	registerDefaultPinotFS()
static void	registerPinotFS(String scheme, String fsClassName, Map<String,Object> configs)
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 numControllers,
                        int numBrokers,
                        int numServers,
                        int numMinions,
                        File tempDir,
                        boolean enableIsolation,
                        String authToken,
                        Map<String,Object> configOverrides)
                 throws Exception

Throws:

Exception

QuickstartRunner

public QuickstartRunner(List<QuickstartTableRequest> tableRequests,
                        int numControllers,
                        int numBrokers,
                        int numServers,
                        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

bootstrapTable

public void bootstrapTable()
                    throws Exception

Throws:

Exception

addTable

@Deprecated
public void addTable()
              throws Exception

Deprecated.

Throws:

Exception

launchDataIngestionJob

@Deprecated
public void launchDataIngestionJob()
                            throws Exception

Deprecated.

Throws:

Exception

runQuery

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

Throws:

Exception

registerDefaultPinotFS

public static void registerDefaultPinotFS()

registerPinotFS

public static void registerPinotFS(String scheme,
                                   String fsClassName,
                                   Map<String,Object> configs)