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

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

<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