co.cask.cdap.test

Class UnitTestManager

java.lang.Object

co.cask.cdap.test.UnitTestManager

All Implemented Interfaces:

TestManager

public class UnitTestManager
extends Object
implements TestManager

Constructor Summary

Constructors

Constructor and Description

UnitTestManager(AppFabricClient appFabricClient, co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework, co.cask.tephra.TransactionSystemClient txSystemClient, DiscoveryServiceClient discoveryClient, ApplicationManagerFactory appManagerFactory, co.cask.cdap.common.namespace.NamespaceAdmin namespaceAdmin, StreamManagerFactory streamManagerFactory, LocationFactory locationFactory, MetricsManager metricsManager, ArtifactRepository artifactRepository, co.cask.cdap.common.conf.CConfiguration cConf)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAppArtifact(co.cask.cdap.proto.Id.Artifact artifactId, Class<?> appClass)
void	addAppArtifact(co.cask.cdap.proto.Id.Artifact artifactId, Class<?> appClass, Manifest manifest)
void	addAppArtifact(co.cask.cdap.proto.Id.Artifact artifactId, Class<?> appClass, String... exportPackages)
void	addArtifact(co.cask.cdap.proto.Id.Artifact artifactId, File artifactFile)
<T extends DatasetAdmin> T	addDatasetInstance(co.cask.cdap.proto.Id.Namespace namespace, String datasetTypeName, String datasetInstanceName)
<T extends DatasetAdmin> T	addDatasetInstance(co.cask.cdap.proto.Id.Namespace namespace, String datasetTypeName, String datasetInstanceName, DatasetProperties props)
void	addPluginArtifact(co.cask.cdap.proto.Id.Artifact artifactId, co.cask.cdap.proto.Id.Artifact parent, Class<?> pluginClass, Class<?>... pluginClasses)
void	addPluginArtifact(co.cask.cdap.proto.Id.Artifact artifactId, co.cask.cdap.proto.Id.Artifact parent, Set<PluginClass> additionalPlugins, Class<?> pluginClass, Class<?>... pluginClasses)
void	addPluginArtifact(co.cask.cdap.proto.Id.Artifact artifactId, Set<co.cask.cdap.proto.artifact.ArtifactRange> parents, Class<?> pluginClass, Class<?>... pluginClasses)
void	addPluginArtifact(co.cask.cdap.proto.Id.Artifact artifactId, Set<co.cask.cdap.proto.artifact.ArtifactRange> parents, Set<PluginClass> additionalPlugins, Class<?> pluginClass, Class<?>... pluginClasses)
void	clear()
void	createNamespace(co.cask.cdap.proto.NamespaceMeta namespaceMeta)
void	deleteArtifact(co.cask.cdap.proto.Id.Artifact artifactId)
void	deleteNamespace(co.cask.cdap.proto.Id.Namespace namespace)
ApplicationManager	deployApplication(co.cask.cdap.proto.Id.Application appId, co.cask.cdap.proto.artifact.AppRequest appRequest)
ApplicationManager	deployApplication(co.cask.cdap.proto.Id.Namespace namespace, Class<? extends Application> applicationClz, Config configObject, File... bundleEmbeddedJars)
ApplicationManager	deployApplication(co.cask.cdap.proto.Id.Namespace namespace, Class<? extends Application> applicationClz, File... bundleEmbeddedJars) Deploys an Application.
void	deployDatasetModule(co.cask.cdap.proto.Id.Namespace namespace, String moduleName, Class<? extends DatasetModule> datasetModule)
ApplicationManager	getApplicationManager(co.cask.cdap.proto.Id.Application appId)
<T> DataSetManager<T>	getDataset(co.cask.cdap.proto.Id.Namespace namespace, String datasetInstanceName) Gets Dataset manager of Dataset instance of type
Connection	getQueryClient(co.cask.cdap.proto.Id.Namespace namespace) Returns a JDBC connection that allows to run SQL queries over data sets.
StreamManager	getStreamManager(co.cask.cdap.proto.Id.Stream streamId)

Methods inherited from class java.lang.Object

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

Constructor Detail

UnitTestManager

@Inject
public UnitTestManager(AppFabricClient appFabricClient,
                      co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework,
                      co.cask.tephra.TransactionSystemClient txSystemClient,
                      DiscoveryServiceClient discoveryClient,
                      ApplicationManagerFactory appManagerFactory,
                      co.cask.cdap.common.namespace.NamespaceAdmin namespaceAdmin,
                      StreamManagerFactory streamManagerFactory,
                      LocationFactory locationFactory,
                      MetricsManager metricsManager,
                      ArtifactRepository artifactRepository,
                      co.cask.cdap.common.conf.CConfiguration cConf)

Method Detail

deployApplication

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

Deploys an Application. The Flows and other programs defined in the application must be in the same or children package as the application.

Specified by:

deployApplication in interface TestManager

Parameters:

applicationClz - The application class

Returns:

An ApplicationManager to manage the deployed application.

deployApplication

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

Specified by:

deployApplication in interface TestManager

deployApplication

public ApplicationManager deployApplication(co.cask.cdap.proto.Id.Application appId,
                                   co.cask.cdap.proto.artifact.AppRequest appRequest)
                                     throws Exception

Specified by:

deployApplication in interface TestManager

Throws:

Exception

getApplicationManager

public ApplicationManager getApplicationManager(co.cask.cdap.proto.Id.Application appId)

Specified by:

getApplicationManager in interface TestManager

addArtifact

public void addArtifact(co.cask.cdap.proto.Id.Artifact artifactId,
               File artifactFile)
                 throws Exception

Specified by:

addArtifact in interface TestManager

Throws:

Exception

addAppArtifact

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

Specified by:

addAppArtifact in interface TestManager

Throws:

Exception

addAppArtifact

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

Specified by:

addAppArtifact in interface TestManager

Throws:

Exception

addAppArtifact

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

Specified by:

addAppArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

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

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

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

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

public void addPluginArtifact(co.cask.cdap.proto.Id.Artifact artifactId,
                     co.cask.cdap.proto.Id.Artifact parent,
                     @Nullable
                     Set<PluginClass> additionalPlugins,
                     Class<?> pluginClass,
                     Class<?>... pluginClasses)
                       throws Exception

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

addPluginArtifact

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

Specified by:

addPluginArtifact in interface TestManager

Throws:

Exception

deleteArtifact

public void deleteArtifact(co.cask.cdap.proto.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

@Beta
public final void deployDatasetModule(co.cask.cdap.proto.Id.Namespace namespace,
                            String moduleName,
                            Class<? extends DatasetModule> datasetModule)
                               throws Exception

Specified by:

deployDatasetModule in interface TestManager

Throws:

Exception

addDatasetInstance

@Beta
public final <T extends DatasetAdmin> T addDatasetInstance(co.cask.cdap.proto.Id.Namespace namespace,
                                                 String datasetTypeName,
                                                 String datasetInstanceName,
                                                 DatasetProperties props)
                                                throws Exception

Specified by:

addDatasetInstance in interface TestManager

Throws:

Exception

addDatasetInstance

@Beta
public final <T extends DatasetAdmin> T addDatasetInstance(co.cask.cdap.proto.Id.Namespace namespace,
                                                 String datasetTypeName,
                                                 String datasetInstanceName)
                                                throws Exception

Specified by:

addDatasetInstance in interface TestManager

Throws:

Exception

getDataset

@Beta
public final <T> DataSetManager<T> getDataset(co.cask.cdap.proto.Id.Namespace namespace,
                                    String datasetInstanceName)
                                   throws Exception

Gets Dataset manager of Dataset instance of type

Specified by:

getDataset in interface TestManager

Parameters:

datasetInstanceName - - instance name of dataset

Returns:

Dataset Manager of Dataset instance of type

Throws:

Exception

getQueryClient

@Beta
public final Connection getQueryClient(co.cask.cdap.proto.Id.Namespace namespace)
                                throws Exception

Returns a JDBC connection that allows to run SQL queries over data sets.

Specified by:

getQueryClient in interface TestManager

Throws:

Exception

createNamespace

public void createNamespace(co.cask.cdap.proto.NamespaceMeta namespaceMeta)
                     throws Exception

Specified by:

createNamespace in interface TestManager

Throws:

Exception

deleteNamespace

public void deleteNamespace(co.cask.cdap.proto.Id.Namespace namespace)
                     throws Exception

Specified by:

deleteNamespace in interface TestManager

Throws:

Exception

getStreamManager

public StreamManager getStreamManager(co.cask.cdap.proto.Id.Stream streamId)

Specified by:

getStreamManager in interface TestManager