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

A

addAppArtifact(Id.Artifact, Class<?>) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Build an application artifact from the specified class and then add it.

addAppArtifact(Id.Artifact, Class<?>, String...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Build an application artifact from the specified class and then add it.

addAppArtifact(Id.Artifact, Class<?>, Manifest) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Build an application artifact from the specified class and then add it.

addAppArtifact(Id.Artifact, Class<?>) - Method in class co.cask.cdap.test.UnitTestManager

addAppArtifact(Id.Artifact, Class<?>, String...) - Method in class co.cask.cdap.test.UnitTestManager

addAppArtifact(Id.Artifact, Class<?>, Manifest) - Method in class co.cask.cdap.test.UnitTestManager

addArtifact(Id.Artifact, File) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Add the specified artifact.

addArtifact(Id.Artifact, File) - Method in class co.cask.cdap.test.UnitTestManager

addDatasetInstance(Id.Namespace, String, String, DatasetProperties) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Adds an instance of a dataset.

addDatasetInstance(String, String, DatasetProperties) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Adds an instance of a dataset.

addDatasetInstance(Id.Namespace, String, String) - Method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Adds an instance of dataset.

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

Deprecated.

Adds an instance of dataset.

addDatasetInstance(Id.Namespace, String, String, DatasetProperties) - Method in class co.cask.cdap.test.UnitTestManager

addDatasetInstance(Id.Namespace, String, String) - Method in class co.cask.cdap.test.UnitTestManager

addPluginArtifact(Id.Artifact, Id.Artifact, Class<?>, Class<?>...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Build an artifact from the specified plugin classes and then add it.

addPluginArtifact(Id.Artifact, Id.Artifact, Set<PluginClass>, Class<?>, Class<?>...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Build an artifact from the specified plugin classes and then add it.

addPluginArtifact(Id.Artifact, Set<ArtifactRange>, Class<?>, Class<?>...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Build an artifact from the specified plugin classes and then add it.

addPluginArtifact(Id.Artifact, Id.Artifact, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.UnitTestManager

addPluginArtifact(Id.Artifact, Set<ArtifactRange>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.UnitTestManager

addPluginArtifact(Id.Artifact, Id.Artifact, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.UnitTestManager

addPluginArtifact(Id.Artifact, Set<ArtifactRange>, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.UnitTestManager

after() - Method in class co.cask.cdap.test.TestConfiguration

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

Deprecated.

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

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

B

before() - Method in class co.cask.cdap.test.TestConfiguration

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

Deprecated.

C

clear() - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

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

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

clearStats(String) - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

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

ConfigurableTestBase - Class in co.cask.cdap.test

Deprecated.

Unit-test classes should inherit from TestBase.

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

Deprecated.

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

create(Id.Stream) - Method in interface co.cask.cdap.test.internal.StreamManagerFactory

Return a StreamManager for the specified stream

create(Id.Stream) - Method in interface co.cask.cdap.test.internal.StreamWriterFactory

Deprecated.

createBatchWriter(String, String) - Method in class co.cask.cdap.test.internal.LocalStreamWriter

createNamespace(Id.Namespace) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Creates a Namespace.

createNamespace(NamespaceMeta) - Method in class co.cask.cdap.test.UnitTestManager

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

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

Deprecated.

D

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

A default implementation of ApplicationManager.

DefaultApplicationManager(CConfiguration, DatasetFramework, TransactionSystemClient, StreamWriterFactory, DiscoveryServiceClient, TemporaryFolder, AppFabricClient, MetricsManager, Id.Application, Location) - Constructor for class co.cask.cdap.test.internal.DefaultApplicationManager

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

A default implementation of FlowManager.

DefaultFlowManager(Id.Program, AppFabricClient, DefaultApplicationManager, MetricsManager) - Constructor for class co.cask.cdap.test.internal.DefaultFlowManager

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

A default implementation of ServiceManager.

DefaultServiceManager(Id.Program, AppFabricClient, DiscoveryServiceClient, DefaultApplicationManager, MetricsManager) - Constructor for class co.cask.cdap.test.internal.DefaultServiceManager

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

Default implementation of StreamManager for use in tests

DefaultStreamManager(StreamHandler, StreamFetchHandler, Id.Stream) - Constructor for class co.cask.cdap.test.internal.DefaultStreamManager

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

Deprecated.

Use DefaultStreamManager instead

DefaultStreamWriter(StreamManagerFactory, Id.Stream) - Constructor for class co.cask.cdap.test.internal.DefaultStreamWriter

Deprecated.

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

A default implementation of WorkerManager

DefaultWorkerManager(Id.Program, AppFabricClient, DefaultApplicationManager) - Constructor for class co.cask.cdap.test.internal.DefaultWorkerManager

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

A default implementation of FlowManager.

DefaultWorkflowManager(Id.Program, AppFabricClient, DefaultApplicationManager) - Constructor for class co.cask.cdap.test.internal.DefaultWorkflowManager

deleteArtifact(Id.Artifact) - Method in class co.cask.cdap.test.UnitTestManager

deleteNamespace(Id.Namespace) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Deletes a Namespace.

deleteNamespace(Id.Namespace) - Method in class co.cask.cdap.test.UnitTestManager

deployApplication(Id.Namespace, Class<? extends Application>, File...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Deploys an Application.

deployApplication(Id.Namespace, Class<? extends Application>, Config, File...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

deployApplication(Class<? extends Application>, File...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Deploys an Application.

deployApplication(Class<? extends Application>, Config, File...) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

deployApplication(Id.Application, AppRequest) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Deploys an Application.

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

Deploys an Application.

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

deployApplication(Id.Application, AppRequest) - Method in class co.cask.cdap.test.UnitTestManager

deployDatasetModule(Id.Namespace, String, Class<? extends DatasetModule>) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Deploys DatasetModule.

deployDatasetModule(String, Class<? extends DatasetModule>) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Deploys DatasetModule.

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

F

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

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

Deprecated.

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

Deprecated.

G

getDataset(Id.Namespace, String) - Method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Gets Dataset manager of Dataset instance of type

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

Deprecated.

Gets Dataset manager of Dataset instance of type

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

getDataset(Id.Namespace, String) - Method in class co.cask.cdap.test.UnitTestManager

Gets Dataset manager of Dataset instance of type

getEvents(String, String, int) - Method in class co.cask.cdap.test.internal.DefaultStreamManager

getEvents(long, long, int) - Method in class co.cask.cdap.test.internal.DefaultStreamManager

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

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

getFlowletMetrics(String, String, String, String) - Method in class co.cask.cdap.test.MetricsManager

returns flowlet related metrics

getFlowletMetrics(String, String, String, String) - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

getFlowletMetrics(String, String, String) - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

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

getHistory(Id.Program, ProgramRunStatus) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

getInstances() - Method in class co.cask.cdap.test.internal.DefaultWorkerManager

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

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

getMetricsManager() - Method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

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

getQueryClient(Id.Namespace) - Method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

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

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

Deprecated.

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

getQueryClient(Id.Namespace) - Method in class co.cask.cdap.test.UnitTestManager

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

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

getSchedule(String) - Method in class co.cask.cdap.test.internal.DefaultWorkflowManager

getSchedules() - Method in class co.cask.cdap.test.internal.DefaultWorkflowManager

getServiceHandlerMetrics(String, String, String, String) - Method in class co.cask.cdap.test.MetricsManager

returns service handler related metrics

getServiceHandlerMetrics(String, String, String, String) - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

getServiceHandlerMetrics(String, String, String) - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

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

getServiceMetrics(String, String, String) - Method in class co.cask.cdap.test.MetricsManager

returns service related metrics

getServiceMetrics(String, String, String) - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

getServiceMetrics(String, String) - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

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

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

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

getStreamManager(String) - Method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Returns a StreamManager for the specified stream in the default namespace

getStreamManager(Id.Namespace, String) - Method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Returns a StreamManager for the specified stream in the specified namespace

getStreamManager(Id.Stream) - Method in class co.cask.cdap.test.UnitTestManager

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

Deprecated.

getToken(String, WorkflowToken.Scope, String) - Method in class co.cask.cdap.test.internal.DefaultWorkflowManager

getTokenAtNode(String, String, WorkflowToken.Scope, String) - Method in class co.cask.cdap.test.internal.DefaultWorkflowManager

getTotalMetric(Map<String, String>, String) - Method in class co.cask.cdap.test.MetricsManager

get metrics total count value for a given context and metric.

getTxService() - Method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

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

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

I

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

initTestBase(Map<String, String>) - Static method in class co.cask.cdap.test.ConfigurableTestBase

Deprecated.

Use TestConfiguration instead.

isRunning(Id.Program) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

L

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

Implements StreamWriter to enable you to write to streams in tests without making HTTP requests

LocalStreamWriter(Id.Run, StreamWriterFactory) - Constructor for class co.cask.cdap.test.internal.LocalStreamWriter

M

MetricsManager - Class in co.cask.cdap.test

Used by tests for querying metrics system.

MetricsManager(MetricStore) - Constructor for class co.cask.cdap.test.MetricsManager

metricStore - Static variable in class co.cask.cdap.test.RuntimeStats

Deprecated.

P

PROPERTY_PREFIX - Static variable in class co.cask.cdap.test.TestConfiguration

Q

query(MetricDataQuery) - Method in class co.cask.cdap.test.MetricsManager

query the metric store and return the Collection

R

resetAll() - Method in class co.cask.cdap.test.MetricsManager

deletes all metrics

resetAll() - Static method in class co.cask.cdap.test.RuntimeStats

Deprecated.

RuntimeStats - Class in co.cask.cdap.test

Deprecated.

S

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

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

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

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

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

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

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

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

send(File, String) - Method in class co.cask.cdap.test.internal.DefaultStreamManager

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

Deprecated.

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

Deprecated.

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

Deprecated.

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

Deprecated.

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

Deprecated.

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

Deprecated.

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

Deprecated.

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

Deprecated.

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

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

setInstances(int) - Method in class co.cask.cdap.test.internal.DefaultWorkerManager

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

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

stopProgram(Id.Program) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

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

Factory to create StreamManager objects

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

Deprecated.

use StreamManagerFactory instead

T

TestBase - Class in co.cask.cdap.test

Base class to inherit from for unit-test.

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

TestConfiguration - Class in co.cask.cdap.test

This class can be used to setup CDAP configuration for unit-test.

TestConfiguration(Object...) - Constructor for class co.cask.cdap.test.TestConfiguration

Creates a new instance with the give list of configurations.

TestConfiguration(Map<String, String>) - Constructor for class co.cask.cdap.test.TestConfiguration

Creates a new instance with the given configurations.

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

Deprecated.

U

UnitTestManager - Class in co.cask.cdap.test

UnitTestManager(AppFabricClient, DatasetFramework, TransactionSystemClient, DiscoveryServiceClient, ApplicationManagerFactory, NamespaceAdmin, StreamManagerFactory, LocationFactory, MetricsManager, ArtifactRepository, CConfiguration) - Constructor for class co.cask.cdap.test.UnitTestManager

W

waitForTotalMetricCount(Map<String, String>, String, long, long, TimeUnit) - Method in class co.cask.cdap.test.MetricsManager

waitFor a metric value count for the metric identified by metricName and context.

write(String, String) - Method in class co.cask.cdap.test.internal.LocalStreamWriter

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

write(String, ByteBuffer) - Method in class co.cask.cdap.test.internal.LocalStreamWriter

write(String, StreamEventData) - Method in class co.cask.cdap.test.internal.LocalStreamWriter

writeFile(String, File, String) - Method in class co.cask.cdap.test.internal.LocalStreamWriter

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