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, RESTClient restClient, File tmpFolder)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAppArtifact(Id.Artifact artifactId, Class<?> appClass)
void	addAppArtifact(Id.Artifact artifactId, Class<?> appClass, Manifest manifest)
void	addAppArtifact(Id.Artifact artifactId, Class<?> appClass, String... exportPackages)
void	addArtifact(Id.Artifact artifactId, File artifactFile)
<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	addPluginArtifact(Id.Artifact artifactId, Id.Artifact parent, Class<?> pluginClass, Class<?>... pluginClasses)
void	addPluginArtifact(Id.Artifact artifactId, Id.Artifact parent, Set<PluginClass> additionalPlugins, Class<?> pluginClass, Class<?>... pluginClasses)
void	addPluginArtifact(Id.Artifact artifactId, Set<ArtifactRange> parents, Class<?> pluginClass, Class<?>... pluginClasses)
void	addPluginArtifact(Id.Artifact artifactId, Set<ArtifactRange> parents, Set<PluginClass> additionalPlugins, Class<?> pluginClass, Class<?>... pluginClasses)
void	clear()
void	createNamespace(NamespaceMeta namespaceMeta)
void	deleteArtifact(Id.Artifact artifactId)
void	deleteNamespace(Id.Namespace namespace)
ApplicationManager	deployApplication(Id.Application appId, AppRequest appRequest)
ApplicationManager	deployApplication(Id.Namespace namespace, Class<? extends Application> applicationClz, Config configObject, File... bundleEmbeddedJars)
ApplicationManager	deployApplication(Id.Namespace namespace, Class<? extends Application> applicationClz, File... bundleEmbeddedJars)
void	deployDatasetModule(Id.Namespace namespace, String moduleName, Class<? extends DatasetModule> datasetModule)
ApplicationManager	getApplicationManager(Id.Application appId)
<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,
                      RESTClient restClient,
                      File tmpFolder)

Method Detail

deployApplication

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

Specified by:

deployApplication in interface TestManager

deployApplication

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

Specified by:

deployApplication in interface TestManager

deployApplication

public ApplicationManager deployApplication(Id.Application appId,
                                   AppRequest appRequest)
                                     throws Exception

Specified by:

deployApplication in interface TestManager

Throws:

Exception

getApplicationManager

public ApplicationManager getApplicationManager(Id.Application appId)

Specified by:

getApplicationManager in interface TestManager

addArtifact

public void addArtifact(Id.Artifact artifactId,
               File artifactFile)
                 throws Exception

Specified by:

addArtifact in interface TestManager

Throws:

Exception

addAppArtifact

public void addAppArtifact(Id.Artifact artifactId,
                  Class<?> appClass)
                    throws Exception

Specified by:

addAppArtifact in interface TestManager

Throws:

Exception

addAppArtifact

public void addAppArtifact(Id.Artifact artifactId,
                  Class<?> appClass,
                  String... exportPackages)
                    throws Exception

Specified by:

addAppArtifact in interface TestManager

Throws:

Exception

addAppArtifact

public void addAppArtifact(Id.Artifact artifactId,
                  Class<?> appClass,
                  Manifest manifest)
                    throws Exception

Specified by:

addAppArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

public void addPluginArtifact(Id.Artifact artifactId,
                     Id.Artifact parent,
                     Class<?> pluginClass,
                     Class<?>... pluginClasses)
                       throws Exception

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

public void addPluginArtifact(Id.Artifact artifactId,
                     Set<ArtifactRange> parents,
                     Class<?> pluginClass,
                     Class<?>... pluginClasses)
                       throws Exception

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

public void addPluginArtifact(Id.Artifact artifactId,
                     Id.Artifact parent,
                     Set<PluginClass> additionalPlugins,
                     Class<?> pluginClass,
                     Class<?>... pluginClasses)
                       throws Exception

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

public void addPluginArtifact(Id.Artifact artifactId,
                     Set<ArtifactRange> parents,
                     @Nullable
                     Set<PluginClass> additionalPlugins,
                     Class<?> pluginClass,
                     Class<?>... pluginClasses)
                       throws Exception

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

deleteArtifact

public void deleteArtifact(Id.Artifact artifactId)
                    throws Exception

Specified by:

deleteArtifact 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