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, NamespaceAdmin namespaceAdmin, StreamManagerFactory streamManagerFactory, LocationFactory locationFactory, co.cask.cdap.common.conf.CConfiguration cConf)

Method Summary

Methods

Modifier and Type	Method and Description
<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	addTemplatePluginJson(co.cask.cdap.proto.Id.ApplicationTemplate templateId, String fileName, String type, String name, String description, String className, PluginPropertyField... fields)
void	addTemplatePlugins(co.cask.cdap.proto.Id.ApplicationTemplate templateId, String jarName, Class<?> pluginClz, Class<?>... classes)
void	clear()
AdapterManager	createAdapter(co.cask.cdap.proto.Id.Adapter adapterId, co.cask.cdap.proto.AdapterConfig config)
void	createNamespace(co.cask.cdap.proto.NamespaceMeta namespaceMeta)
void	deleteNamespace(co.cask.cdap.proto.Id.Namespace namespace)
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)
void	deployTemplate(co.cask.cdap.proto.Id.Namespace namespace, co.cask.cdap.proto.Id.ApplicationTemplate templateId, Class<? extends ApplicationTemplate> templateClz, String... exportPackages)
<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,
                      NamespaceAdmin namespaceAdmin,
                      StreamManagerFactory streamManagerFactory,
                      LocationFactory locationFactory,
                      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

deployTemplate

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

Specified by:

deployTemplate in interface TestManager

Throws:

IOException

addTemplatePlugins

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

Specified by:

addTemplatePlugins in interface TestManager

Throws:

IOException

addTemplatePluginJson

public void addTemplatePluginJson(co.cask.cdap.proto.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(co.cask.cdap.proto.Id.Adapter adapterId,
                           co.cask.cdap.proto.AdapterConfig config)

Specified by:

createAdapter in interface TestManager

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