A B C D F G I P Q S T

A

addDatasetInstance(String, String, DatasetProperties) - Method in class co.cask.cdap.test.TestBase

Adds an instance of a dataset.

addDatasetInstance(String, String) - Method in class co.cask.cdap.test.TestBase

Adds an instance of dataset.

afterTest() - Method in class co.cask.cdap.test.TestBase

By default after each test finished, it will stop all apps started during the test.

ApplicationManagerFactory - Interface in co.cask.cdap.test.internal

B

beforeTest() - Method in class co.cask.cdap.test.TestBase

C

clear() - Method in class co.cask.cdap.test.TestBase

Clear the state of app fabric, by removing all deployed applications, Datasets and Streams.

co.cask.cdap.test - package co.cask.cdap.test

This package contains the public classes for unit tests.

co.cask.cdap.test.internal - package co.cask.cdap.test.internal

create(String, String, Location, ApplicationSpecification) - Method in interface co.cask.cdap.test.internal.ApplicationManagerFactory

create(String, String, String) - Method in interface co.cask.cdap.test.internal.ProcedureClientFactory

Deprecated.

create(QueueName, String, String) - Method in interface co.cask.cdap.test.internal.StreamWriterFactory

createStream() - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

D

DefaultApplicationManager - Class in co.cask.cdap.test.internal

A default implementation of ApplicationManager.

DefaultApplicationManager(LocationFactory, DatasetFramework, TransactionSystemClient, StreamWriterFactory, ProcedureClientFactory, CConfiguration, DiscoveryServiceClient, AppFabricHttpHandler, ServiceHttpHandler, TemporaryFolder, String, String, Location) - Constructor for class co.cask.cdap.test.internal.DefaultApplicationManager

DefaultFlowManager - Class in co.cask.cdap.test.internal

A default implementation of FlowManager.

DefaultFlowManager(String, DefaultApplicationManager.ProgramId, String, AppFabricClient, DefaultApplicationManager) - Constructor for class co.cask.cdap.test.internal.DefaultFlowManager

DefaultProcedureClient - Class in co.cask.cdap.test.internal

Simple procedure client that uses java URLConnection to fire requests.

DefaultProcedureClient(DiscoveryServiceClient, String, String, String) - Constructor for class co.cask.cdap.test.internal.DefaultProcedureClient

DefaultServiceManager - Class in co.cask.cdap.test.internal

A default implementation of ServiceManager.

DefaultServiceManager(String, DefaultApplicationManager.ProgramId, AppFabricClient, DiscoveryServiceClient, DefaultApplicationManager) - Constructor for class co.cask.cdap.test.internal.DefaultServiceManager

DefaultStreamWriter - Class in co.cask.cdap.test.internal

DefaultStreamWriter(StreamHandler, QueueName, String) - Constructor for class co.cask.cdap.test.internal.DefaultStreamWriter

deployApplication(Class<? extends Application>, File...) - Method in class co.cask.cdap.test.TestBase

Deploys an Application.

deployDatasetModule(String, Class<? extends DatasetModule>) - Method in class co.cask.cdap.test.TestBase

Deploys DatasetModule.

F

finalize() - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

finish() - Static method in class co.cask.cdap.test.TestBase

G

getDataSet(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

getDataset(String) - Method in class co.cask.cdap.test.TestBase

Gets Dataset manager of Dataset instance of type

getProvisionedInstances(String) - Method in class co.cask.cdap.test.internal.DefaultServiceManager

getQueryClient() - Method in class co.cask.cdap.test.TestBase

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

getRequestedInstances(String) - Method in class co.cask.cdap.test.internal.DefaultServiceManager

getServiceURL() - Method in class co.cask.cdap.test.internal.DefaultServiceManager

getServiceURL(long, TimeUnit) - Method in class co.cask.cdap.test.internal.DefaultServiceManager

getStreamWriter(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

I

init() - Static method in class co.cask.cdap.test.TestBase

isRunning() - Method in class co.cask.cdap.test.internal.DefaultFlowManager

isRunning() - Method in class co.cask.cdap.test.internal.DefaultServiceManager

P

ProcedureClientFactory - Interface in co.cask.cdap.test.internal

Deprecated. As of version 2.6.0, with no direct replacement, see Service

publish(Iterator<MetricValue>) - Method in class co.cask.cdap.test.internal.TestMetricsCollectionService

Q

query(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultProcedureClient

queryRaw(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultProcedureClient

S

send(String) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

send(byte[]) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

send(byte[], int, int) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

send(ByteBuffer) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

send(Map<String, String>, String) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

send(Map<String, String>, byte[]) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

send(Map<String, String>, byte[], int, int) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

send(Map<String, String>, ByteBuffer) - Method in class co.cask.cdap.test.internal.DefaultStreamWriter

setFlowletInstances(String, int) - Method in class co.cask.cdap.test.internal.DefaultFlowManager

setRunnableInstances(String, int) - Method in class co.cask.cdap.test.internal.DefaultServiceManager

startFlow(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startFlow(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startMapReduce(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startMapReduce(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startProcedure(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startProcedure(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startService(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startService(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startSpark(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startSpark(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

startWorkflow(String, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

stop() - Method in class co.cask.cdap.test.internal.DefaultFlowManager

stop() - Method in class co.cask.cdap.test.internal.DefaultServiceManager

stopAll() - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

StreamWriterFactory - Interface in co.cask.cdap.test.internal

This interface is using Guice assisted inject to create StreamWriter.

T

TestBase - Class in co.cask.cdap.test

Base class to inherit from, provides testing functionality for Application.

TestBase() - Constructor for class co.cask.cdap.test.TestBase

TestMetricsCollectionService - Class in co.cask.cdap.test.internal

TestMetricsCollectionService() - Constructor for class co.cask.cdap.test.internal.TestMetricsCollectionService

tmpFolder - Static variable in class co.cask.cdap.test.TestBase

A B C D F G I P Q S T