co.cask.cdap.test

Class UnitTestManager

java.lang.Object

co.cask.cdap.test.AbstractTestManager

co.cask.cdap.test.UnitTestManager

All Implemented Interfaces:

TestManager

public class UnitTestManager
extends AbstractTestManager

TestManager for use in unit tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	UnitTestManager.UnitTestDatasetManager<T> Dataset manager used in unit tests.

Constructor Summary

Constructors

Constructor and Description

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

Method Summary

Methods

Modifier and Type	Method and Description
ArtifactManager	addAppArtifact(co.cask.cdap.proto.id.ArtifactId artifactId, Class<?> appClass)
ArtifactManager	addAppArtifact(co.cask.cdap.proto.id.ArtifactId artifactId, Class<?> appClass, Manifest manifest)
ArtifactManager	addAppArtifact(co.cask.cdap.proto.id.ArtifactId artifactId, Class<?> appClass, String... exportPackages)
ArtifactManager	addArtifact(co.cask.cdap.proto.id.ArtifactId artifactId, File artifactFile)
<T extends DatasetAdmin> T	addDatasetInstance(String datasetType, co.cask.cdap.proto.id.DatasetId datasetId, DatasetProperties props)
ArtifactManager	addPluginArtifact(co.cask.cdap.proto.id.ArtifactId artifactId, co.cask.cdap.proto.id.ArtifactId parent, Class<?> pluginClass, Class<?>... pluginClasses)
ArtifactManager	addPluginArtifact(co.cask.cdap.proto.id.ArtifactId artifactId, co.cask.cdap.proto.id.ArtifactId parent, Set<PluginClass> additionalPlugins, Class<?> pluginClass, Class<?>... pluginClasses)
ArtifactManager	addPluginArtifact(co.cask.cdap.proto.id.ArtifactId artifactId, Set<co.cask.cdap.proto.artifact.ArtifactRange> parents, Class<?> pluginClass, Class<?>... pluginClasses)
ArtifactManager	addPluginArtifact(co.cask.cdap.proto.id.ArtifactId 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	deleteAllApplications(co.cask.cdap.proto.id.NamespaceId namespaceId)
void	deleteArtifact(co.cask.cdap.proto.Id.Artifact artifactId)
void	deleteDatasetInstance(co.cask.cdap.proto.id.DatasetId datasetId)
void	deleteNamespace(co.cask.cdap.proto.Id.Namespace namespace)
ApplicationManager	deployApplication(co.cask.cdap.proto.id.ApplicationId appId, co.cask.cdap.proto.artifact.AppRequest appRequest)
ApplicationManager	deployApplication(co.cask.cdap.proto.id.NamespaceId namespace, Class<? extends Application> applicationClz, Config configObject, File... bundleEmbeddedJars)
void	deployDatasetModule(co.cask.cdap.proto.id.DatasetModuleId datasetModuleId, Class<? extends DatasetModule> datasetModule)
ApplicationManager	getApplicationManager(co.cask.cdap.proto.id.ApplicationId applicationId)
<T> DataSetManager<T>	getDataset(co.cask.cdap.proto.id.DatasetId datasetInstanceId)
Connection	getQueryClient(co.cask.cdap.proto.id.NamespaceId namespace)
StreamManager	getStreamManager(co.cask.cdap.proto.id.StreamId streamId)

Methods inherited from class co.cask.cdap.test.AbstractTestManager

addAppArtifact, addAppArtifact, addAppArtifact, addArtifact, addDatasetInstance, addDatasetInstance, addDatasetInstance, addPluginArtifact, addPluginArtifact, addPluginArtifact, addPluginArtifact, deleteDatasetInstance, deployApplication, deployApplication, deployApplication, deployApplication, deployDatasetModule, getDataset, getQueryClient, getStreamManager

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,
                      org.apache.tephra.TransactionSystemClient txSystemClient,
                      DiscoveryServiceClient discoveryClient,
                      ApplicationManagerFactory appManagerFactory,
                      co.cask.cdap.common.namespace.NamespaceAdmin namespaceAdmin,
                      StreamManagerFactory streamManagerFactory,
                      LocationFactory locationFactory,
                      MetricsManager metricsManager,
                      ArtifactRepository artifactRepository,
                      ArtifactManagerFactory artifactManagerFactory,
                      co.cask.cdap.common.conf.CConfiguration cConf)

Method Detail

deployApplication

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

deployApplication

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

Throws:

Exception

getApplicationManager

public ApplicationManager getApplicationManager(co.cask.cdap.proto.id.ApplicationId applicationId)

addArtifact

public ArtifactManager addArtifact(co.cask.cdap.proto.id.ArtifactId artifactId,
                          File artifactFile)
                            throws Exception

Throws:

Exception

addAppArtifact

public ArtifactManager addAppArtifact(co.cask.cdap.proto.id.ArtifactId artifactId,
                             Class<?> appClass)
                               throws Exception

Throws:

Exception

addAppArtifact

public ArtifactManager addAppArtifact(co.cask.cdap.proto.id.ArtifactId artifactId,
                             Class<?> appClass,
                             String... exportPackages)
                               throws Exception

Throws:

Exception

addAppArtifact

public ArtifactManager addAppArtifact(co.cask.cdap.proto.id.ArtifactId artifactId,
                             Class<?> appClass,
                             Manifest manifest)
                               throws Exception

Throws:

Exception

addPluginArtifact

public ArtifactManager addPluginArtifact(co.cask.cdap.proto.id.ArtifactId artifactId,
                                co.cask.cdap.proto.id.ArtifactId parent,
                                Class<?> pluginClass,
                                Class<?>... pluginClasses)
                                  throws Exception

Specified by:

addPluginArtifact in interface TestManager

Overrides:

addPluginArtifact in class AbstractTestManager

Throws:

Exception

addPluginArtifact

public ArtifactManager addPluginArtifact(co.cask.cdap.proto.id.ArtifactId artifactId,
                                Set<co.cask.cdap.proto.artifact.ArtifactRange> parents,
                                Class<?> pluginClass,
                                Class<?>... pluginClasses)
                                  throws Exception

Specified by:

addPluginArtifact in interface TestManager

Overrides:

addPluginArtifact in class AbstractTestManager

Throws:

Exception

addPluginArtifact

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

Specified by:

addPluginArtifact in interface TestManager

Overrides:

addPluginArtifact in class AbstractTestManager

Throws:

Exception

addPluginArtifact

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

Throws:

Exception

deleteArtifact

public void deleteArtifact(co.cask.cdap.proto.Id.Artifact artifactId)
                    throws Exception

Throws:

Exception

clear

public void clear()
           throws Exception

Throws:

Exception

deployDatasetModule

public void deployDatasetModule(co.cask.cdap.proto.id.DatasetModuleId datasetModuleId,
                       Class<? extends DatasetModule> datasetModule)
                         throws Exception

Throws:

Exception

addDatasetInstance

public <T extends DatasetAdmin> T addDatasetInstance(String datasetType,
                                            co.cask.cdap.proto.id.DatasetId datasetId,
                                            DatasetProperties props)
                                          throws Exception

Throws:

Exception

deleteDatasetInstance

public void deleteDatasetInstance(co.cask.cdap.proto.id.DatasetId datasetId)
                           throws Exception

Throws:

Exception

getDataset

public <T> DataSetManager<T> getDataset(co.cask.cdap.proto.id.DatasetId datasetInstanceId)
                             throws Exception

Throws:

Exception

getQueryClient

public Connection getQueryClient(co.cask.cdap.proto.id.NamespaceId namespace)
                          throws Exception

Throws:

Exception

createNamespace

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

Throws:

Exception

deleteNamespace

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

Throws:

Exception

getStreamManager

public StreamManager getStreamManager(co.cask.cdap.proto.id.StreamId streamId)

deleteAllApplications

public void deleteAllApplications(co.cask.cdap.proto.id.NamespaceId namespaceId)
                           throws Exception

Throws:

Exception