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, org.apache.twill.discovery.DiscoveryServiceClient discoveryClient, ApplicationManagerFactory appManagerFactory, NamespaceAdmin namespaceAdmin)

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	clear()
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, File... bundleEmbeddedJars) Deploys an Application.
void	deployDatasetModule(co.cask.cdap.proto.Id.Namespace namespace, String moduleName, Class<? extends DatasetModule> datasetModule)
<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.

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,
                      org.apache.twill.discovery.DiscoveryServiceClient discoveryClient,
                      ApplicationManagerFactory appManagerFactory,
                      NamespaceAdmin namespaceAdmin)

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 Procedures 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.

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