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

A

addAppArtifact(Id.Artifact, Class<?>) - Static method in class co.cask.cdap.test.TestBase
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.TestBase
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.TestBase
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.TestBase
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.TestBase
Adds an instance of a dataset.
addDatasetInstance(String, String, DatasetProperties) - Static method in class co.cask.cdap.test.TestBase
Adds an instance of a dataset.
addDatasetInstance(Id.Namespace, String, String) - Method in class co.cask.cdap.test.TestBase
Adds an instance of dataset.
addDatasetInstance(String, String) - Method in class co.cask.cdap.test.TestBase
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.TestBase
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.TestBase
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.TestBase
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.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

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

C

clear() - Static method in class co.cask.cdap.test.TestBase
Clear the state of app fabric, by removing all deployed applications, Datasets and Streams.
clear() - Method in class co.cask.cdap.test.UnitTestManager
 
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(Id.Application) - 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
createBatchWriter(String, String) - Method in class co.cask.cdap.test.internal.LocalStreamWriter
 
createNamespace(Id.Namespace) - Static method in class co.cask.cdap.test.TestBase
Creates a Namespace.
createNamespace(NamespaceMeta) - Method in class co.cask.cdap.test.UnitTestManager
 
createStream() - Method in class co.cask.cdap.test.internal.DefaultStreamManager
 

D

DefaultApplicationManager - Class in co.cask.cdap.test.internal
A default implementation of ApplicationManager.
DefaultApplicationManager(DiscoveryServiceClient, AppFabricClient, MetricsManager, Id.Application) - 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
 
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.TestBase
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.TestBase
Deploys an Application.
deployApplication(Id.Namespace, Class<? extends Application>, Config, File...) - Static method in class co.cask.cdap.test.TestBase
 
deployApplication(Class<? extends Application>, File...) - Static method in class co.cask.cdap.test.TestBase
Deploys an Application.
deployApplication(Class<? extends Application>, Config, File...) - Static method in class co.cask.cdap.test.TestBase
 
deployApplication(Id.Application, AppRequest) - Static method in class co.cask.cdap.test.TestBase
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.TestBase
Deploys DatasetModule.
deployDatasetModule(String, Class<? extends DatasetModule>) - Static method in class co.cask.cdap.test.TestBase
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
 
finish() - Static method in class co.cask.cdap.test.TestBase
 

G

getApplicationManager(Id.Application) - Method in class co.cask.cdap.test.UnitTestManager
 
getDataset(Id.Namespace, String) - Method in class co.cask.cdap.test.TestBase
Gets Dataset manager of Dataset instance of type
getDataset(String) - Method in class co.cask.cdap.test.TestBase
Gets Dataset manager of Dataset instance of type
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
 
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.TestBase
 
getProvisionedInstances() - Method in class co.cask.cdap.test.internal.DefaultServiceManager
 
getQueryClient(Id.Namespace) - Method in class co.cask.cdap.test.TestBase
Returns a JDBC connection that allows to run SQL queries over data sets.
getQueryClient() - Method in class co.cask.cdap.test.TestBase
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
 
getServiceManager(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
 
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.TestBase
Returns a StreamManager for the specified stream in the default namespace
getStreamManager(Id.Namespace, String) - Method in class co.cask.cdap.test.TestBase
Returns a StreamManager for the specified stream in the specified namespace
getStreamManager(Id.Stream) - Method in class co.cask.cdap.test.UnitTestManager
 
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
 
getTxService() - Method in class co.cask.cdap.test.TestBase
 
getWorkerManager(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
 
getWorkflowManager(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
 

I

initialize() - Static method in class co.cask.cdap.test.TestBase
 
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, StreamManagerFactory) - Constructor for class co.cask.cdap.test.internal.LocalStreamWriter
 

P

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

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

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

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

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 P S T U W 

Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.