A C D F G I M P Q R S T W

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.

ApplicationManager - Interface in co.cask.cdap.test

Instance of this class is for managing deployed application.

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

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

D

DataSetManager<T> - Interface in co.cask.cdap.test

Instance of this class is for managing DataSet.

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

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

FlowManager - Interface in co.cask.cdap.test

Instance for this class is for managing a running Flow.

flush() - Method in interface co.cask.cdap.test.DataSetManager

Makes changes performed using dataset instance acquired via DataSetManager.get() visible to all other components.

G

get() - Method in interface co.cask.cdap.test.DataSetManager

getClient() - Method in interface co.cask.cdap.test.ProcedureManager

getDataSet(String) - Method in interface co.cask.cdap.test.ApplicationManager

Gets an instance of DataSet of the given dataset name.

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

getHistory() - Method in interface co.cask.cdap.test.WorkflowManager

Get the history of the workflow

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

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

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

getRunnableInstances(String) - Method in interface co.cask.cdap.test.ServiceManager

Returns the number of runnable instances.

getSchedule(String) - Method in interface co.cask.cdap.test.WorkflowManager

Get the ScheduleManager instance to manage the schedule

getSchedules() - Method in interface co.cask.cdap.test.WorkflowManager

Get the list of schedules of the workflow

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

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

getServiceURL() - Method in interface co.cask.cdap.test.ServiceManager

Used to discover the Service managed by this ServiceManager.

getServiceURL(long, TimeUnit) - Method in interface co.cask.cdap.test.ServiceManager

Used to discover the Service managed by this ServiceManager which allows a custom timeout value to wait for the service to be available.

getStreamWriter(String) - Method in interface co.cask.cdap.test.ApplicationManager

Gets a StreamWriter for writing data to the given stream.

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

isRunning() - Method in interface co.cask.cdap.test.ServiceManager

Checks if Service is Running

M

MapReduceManager - Interface in co.cask.cdap.test

Instance for this class is for managing a running MapReduce.

P

ProcedureClient - Interface in co.cask.cdap.test

Class for sending queries to running Procedure.

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

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

ProcedureManager - Interface in co.cask.cdap.test

Instance of this class is for managing a running Procedure.

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

Q

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

query(String, Map<String, String>) - Method in interface co.cask.cdap.test.ProcedureClient

Makes a query to the procedure with String result.

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

queryRaw(String, Map<String, String>) - Method in interface co.cask.cdap.test.ProcedureClient

Makes a query to the procedure.

R

resume() - Method in interface co.cask.cdap.test.ScheduleManager

Resumes the workflow schedule

S

ScheduleManager - Interface in co.cask.cdap.test

This interface is for managing the schedule of a workflow

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

send(String) - Method in interface co.cask.cdap.test.StreamWriter

Sends a UTF-8 encoded string to the stream.

send(byte[]) - Method in interface co.cask.cdap.test.StreamWriter

Sends a byte array to the stream.

send(byte[], int, int) - Method in interface co.cask.cdap.test.StreamWriter

Sends a byte array to the stream.

send(ByteBuffer) - Method in interface co.cask.cdap.test.StreamWriter

Sends the content of a ByteBuffer to the stream.

send(Map<String, String>, String) - Method in interface co.cask.cdap.test.StreamWriter

Sends a UTF-8 encoded string to the stream.

send(Map<String, String>, byte[]) - Method in interface co.cask.cdap.test.StreamWriter

Sends a byte array to the stream.

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

Sends a byte array to the stream.

send(Map<String, String>, ByteBuffer) - Method in interface co.cask.cdap.test.StreamWriter

Sends the content of a ByteBuffer to the stream.

ServiceManager - Interface in co.cask.cdap.test

Managing the running Service in an application.

setFlowletInstances(String, int) - Method in interface co.cask.cdap.test.FlowManager

Changes the number of flowlet instances.

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

setRunnableInstances(String, int) - Method in interface co.cask.cdap.test.ServiceManager

Changes the number of runnable instances.

SparkManager - Interface in co.cask.cdap.test

Instance for this class is for managing a running Spark.

startFlow(String) - Method in interface co.cask.cdap.test.ApplicationManager

Starts a flow.

startFlow(String, Map<String, String>) - Method in interface co.cask.cdap.test.ApplicationManager

Starts a flow.

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 interface co.cask.cdap.test.ApplicationManager

Starts a mapreduce job.

startMapReduce(String, Map<String, String>) - Method in interface co.cask.cdap.test.ApplicationManager

Starts a mapreduce job.

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 interface co.cask.cdap.test.ApplicationManager

Deprecated. As of version 2.6.0, replaced by Service

startProcedure(String, Map<String, String>) - Method in interface co.cask.cdap.test.ApplicationManager

Deprecated. As of version 2.6.0, replaced by Service

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 interface co.cask.cdap.test.ApplicationManager

Starts a service.

startService(String, Map<String, String>) - Method in interface co.cask.cdap.test.ApplicationManager

Starts a service.

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 interface co.cask.cdap.test.ApplicationManager

Starts a Spark job.

startSpark(String, Map<String, String>) - Method in interface co.cask.cdap.test.ApplicationManager

Starts a Spark job.

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 interface co.cask.cdap.test.ApplicationManager

Starts a workflow.

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

status() - Method in interface co.cask.cdap.test.ScheduleManager

returns the status of the workflow schedule

stop() - Method in interface co.cask.cdap.test.FlowManager

Stops the running flow.

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

stop() - Method in interface co.cask.cdap.test.MapReduceManager

Stops the running mapreduce job.

stop() - Method in interface co.cask.cdap.test.ProcedureManager

Stops the running procedure.

stop() - Method in interface co.cask.cdap.test.ServiceManager

Stops the running service.

stop() - Method in interface co.cask.cdap.test.SparkManager

Stops the running spark job.

stopAll() - Method in interface co.cask.cdap.test.ApplicationManager

Stops all processors managed by this manager and clear all associated runtime metrics.

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

StreamWriter - Interface in co.cask.cdap.test

This interface defines ways to send data to a stream.

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

This interface is using Guice assisted inject to create StreamWriter.

suspend() - Method in interface co.cask.cdap.test.ScheduleManager

suspends the workflow schedule

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

W

waitForFinish(long, TimeUnit) - Method in interface co.cask.cdap.test.MapReduceManager

Blocks until mapreduce job is finished or given timeout is reached

waitForFinish(long, TimeUnit) - Method in interface co.cask.cdap.test.SparkManager

Blocks until spark job is finished or given timeout is reached

WorkflowManager - Interface in co.cask.cdap.test

Workflow manager interface for managing the workflow and its schedules

A C D F G I M P Q R S T W