co.cask.cdap.test

Class IntegrationTestManager

java.lang.Object

co.cask.cdap.test.IntegrationTestManager

All Implemented Interfaces:

TestManager

public class IntegrationTestManager
extends Object
implements TestManager

Constructor Summary

Constructors

Constructor and Description
IntegrationTestManager(ClientConfig clientConfig, LocationFactory locationFactory)

Method Summary

Methods

Modifier and Type	Method and Description
<T extends DatasetAdmin> T	addDatasetInstance(Id.Namespace namespace, String datasetTypeName, String datasetInstanceName)
<T extends DatasetAdmin> T	addDatasetInstance(Id.Namespace namespace, String datasetTypeName, String datasetInstanceName, DatasetProperties props)
void	addTemplatePluginJson(Id.ApplicationTemplate templateId, String fileName, String type, String name, String description, String className, PluginPropertyField... fields)
void	addTemplatePlugins(Id.ApplicationTemplate templateId, String jarName, Class<?> pluginClz, Class<?>... classes)
void	clear()
AdapterManager	createAdapter(Id.Adapter adapterId, AdapterConfig config)
void	createNamespace(NamespaceMeta namespaceMeta)
void	deleteNamespace(Id.Namespace namespace)
ApplicationManager	deployApplication(Id.Namespace namespace, Class<? extends Application> applicationClz, File... bundleEmbeddedJars)
void	deployDatasetModule(Id.Namespace namespace, String moduleName, Class<? extends DatasetModule> datasetModule)
void	deployTemplate(Id.Namespace namespace, Id.ApplicationTemplate templateId, Class<? extends ApplicationTemplate> templateClz, String... exportPackages)
<T> DataSetManager<T>	getDataset(Id.Namespace namespace, String datasetInstanceName)
Connection	getQueryClient(Id.Namespace namespace)
StreamManager	getStreamManager(Id.Stream streamId)

Methods inherited from class java.lang.Object

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

Constructor Detail

IntegrationTestManager

public IntegrationTestManager(ClientConfig clientConfig,
                      LocationFactory locationFactory)

Method Detail

deployApplication

public ApplicationManager deployApplication(Id.Namespace namespace,
                                   Class<? extends Application> applicationClz,
                                   File... bundleEmbeddedJars)

Specified by:

deployApplication in interface TestManager

deployTemplate

public void deployTemplate(Id.Namespace namespace,
                  Id.ApplicationTemplate templateId,
                  Class<? extends ApplicationTemplate> templateClz,
                  String... exportPackages)
                    throws IOException

Specified by:

deployTemplate in interface TestManager

Throws:

IOException

addTemplatePlugins

public void addTemplatePlugins(Id.ApplicationTemplate templateId,
                      String jarName,
                      Class<?> pluginClz,
                      Class<?>... classes)
                        throws IOException

Specified by:

addTemplatePlugins in interface TestManager

Throws:

IOException

addTemplatePluginJson

public void addTemplatePluginJson(Id.ApplicationTemplate templateId,
                         String fileName,
                         String type,
                         String name,
                         String description,
                         String className,
                         PluginPropertyField... fields)
                           throws IOException

Specified by:

addTemplatePluginJson in interface TestManager

Throws:

IOException

createAdapter

public AdapterManager createAdapter(Id.Adapter adapterId,
                           AdapterConfig config)
                             throws Exception

Specified by:

createAdapter in interface TestManager

Throws:

Exception

clear

public void clear()
           throws Exception

Specified by:

clear in interface TestManager

Throws:

Exception

deployDatasetModule

public void deployDatasetModule(Id.Namespace namespace,
                       String moduleName,
                       Class<? extends DatasetModule> datasetModule)
                         throws Exception

Specified by:

deployDatasetModule in interface TestManager

Throws:

Exception

addDatasetInstance

public <T extends DatasetAdmin> T addDatasetInstance(Id.Namespace namespace,
                                            String datasetTypeName,
                                            String datasetInstanceName,
                                            DatasetProperties props)
                                          throws Exception

Specified by:

addDatasetInstance in interface TestManager

Throws:

Exception

addDatasetInstance

public <T extends DatasetAdmin> T addDatasetInstance(Id.Namespace namespace,
                                            String datasetTypeName,
                                            String datasetInstanceName)
                                          throws Exception

Specified by:

addDatasetInstance in interface TestManager

Throws:

Exception

getDataset

public <T> DataSetManager<T> getDataset(Id.Namespace namespace,
                               String datasetInstanceName)
                             throws Exception

Specified by:

getDataset in interface TestManager

Throws:

Exception

getQueryClient

public Connection getQueryClient(Id.Namespace namespace)
                          throws Exception

Specified by:

getQueryClient in interface TestManager

Throws:

Exception

createNamespace

public void createNamespace(NamespaceMeta namespaceMeta)
                     throws Exception

Specified by:

createNamespace in interface TestManager

Throws:

Exception

deleteNamespace

public void deleteNamespace(Id.Namespace namespace)
                     throws Exception

Specified by:

deleteNamespace in interface TestManager

Throws:

Exception

getStreamManager

public StreamManager getStreamManager(Id.Stream streamId)

Specified by:

getStreamManager in interface TestManager