Index (CDAP Unit Test Framework 4.1.2 API)

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

A

abort(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
addAppArtifact(Id.Artifact, Class<?>) - Static method in class co.cask.cdap.test.TestBase: Deprecated.
since 3.4.0. Use TestBase.addArtifact(ArtifactId, File).
addAppArtifact(ArtifactId, 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: Deprecated.
since 3.4.0. Use TestBase.addAppArtifact(ArtifactId, Class, String...)
addAppArtifact(ArtifactId, 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: Deprecated.
since 3.4.0. Use TestBase.addAppArtifact(ArtifactId, Class, Manifest)
addAppArtifact(ArtifactId, Class<?>, Manifest) - Static method in class co.cask.cdap.test.TestBase: Build an application artifact from the specified class and then add it.
addAppArtifact(ArtifactId, Class<?>) - Method in class co.cask.cdap.test.UnitTestManager
addAppArtifact(ArtifactId, Class<?>, String...) - Method in class co.cask.cdap.test.UnitTestManager
addAppArtifact(ArtifactId, Class<?>, Manifest) - Method in class co.cask.cdap.test.UnitTestManager
addArtifact(Id.Artifact, File) - Static method in class co.cask.cdap.test.TestBase: Deprecated.
since 3.4.0. Use TestBase.addArtifact(ArtifactId, File)
addArtifact(ArtifactId, File) - Static method in class co.cask.cdap.test.TestBase: Add the specified artifact.
addArtifact(ArtifactId, File) - Method in class co.cask.cdap.test.UnitTestManager
addDatasetInstance(Id.Namespace, String, String, DatasetProperties) - Static method in class co.cask.cdap.test.TestBase: Deprecated.
since 4.0.0. Use TestBase.addDatasetInstance(String, DatasetId, DatasetProperties) instead.
addDatasetInstance(String, DatasetId, 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: Deprecated.
since 4.0.0. Use TestBase.addDatasetInstance(DatasetId, String) instead.
addDatasetInstance(DatasetId, 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(String, DatasetId, DatasetProperties) - Method in class co.cask.cdap.test.UnitTestManager
addPluginArtifact(Id.Artifact, Id.Artifact, Class<?>, Class<?>...) - Static method in class co.cask.cdap.test.TestBase: Deprecated.
since 3.4.0. Use TestBase.addPluginArtifact(ArtifactId, ArtifactId, Class, Class[])
addPluginArtifact(ArtifactId, ArtifactId, 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: Deprecated.
since 3.4.0. Use TestBase.addPluginArtifact(ArtifactId, ArtifactId, Set, Class, Class[])
addPluginArtifact(ArtifactId, ArtifactId, 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: Deprecated.
since 3.4.0. Use TestBase.addPluginArtifact(ArtifactId, Set, Class, Class[])
addPluginArtifact(ArtifactId, 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(ArtifactId, ArtifactId, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.UnitTestManager
addPluginArtifact(ArtifactId, Set<ArtifactRange>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.UnitTestManager
addPluginArtifact(ArtifactId, ArtifactId, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.UnitTestManager
addPluginArtifact(ArtifactId, 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
ArtifactManagerFactory - Interface in co.cask.cdap.test.internal: A Guice factory to create ArtifactManager.

B

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

C

canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.test.RevealingTxSystemClient
checkpoint(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
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
commit(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
create(ApplicationId) - Method in interface co.cask.cdap.test.internal.ApplicationManagerFactory
create(ArtifactId) - Method in interface co.cask.cdap.test.internal.ArtifactManagerFactory: Creates a ArtifactManager for the specified artifact.
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: Deprecated.
since 3.4.0. Use TestBase.getNamespaceAdmin() to perform namespace operations instead.
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, ApplicationId) - Constructor for class co.cask.cdap.test.internal.DefaultApplicationManager
DefaultArtifactManager - Class in co.cask.cdap.test.internal: ArtifactManager for use in unit tests
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(ProgramId, 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
delete() - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
delete() - Method in class co.cask.cdap.test.internal.DefaultArtifactManager
deleteAllApplications(NamespaceId) - Static method in class co.cask.cdap.test.TestBase: Deletes all applications in the specified namespace.
deleteAllApplications(NamespaceId) - Method in class co.cask.cdap.test.UnitTestManager
deleteArtifact(Id.Artifact) - Method in class co.cask.cdap.test.UnitTestManager
deleteDatasetInstance(NamespaceId, String) - Method in class co.cask.cdap.test.TestBase: Deprecated.
since 4.0.0. Use TestBase.deleteDatasetInstance(DatasetId) instead.
deleteDatasetInstance(DatasetId) - Method in class co.cask.cdap.test.TestBase: Deletes an instance of dataset.
deleteDatasetInstance(DatasetId) - Method in class co.cask.cdap.test.UnitTestManager
deleteNamespace(Id.Namespace) - Static method in class co.cask.cdap.test.TestBase: Deprecated.
since 3.4.0. Use TestBase.getNamespaceAdmin() to perform namespace operations instead.
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: Deprecated.
since 4.0.0. Use TestBase.deployApplication(NamespaceId, Class, File...) instead.
deployApplication(NamespaceId, 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: Deprecated.
since 4.0.0. Use TestBase.deployApplication(NamespaceId, Class, Config, File...) instead.
deployApplication(NamespaceId, Class<? extends Application>, Config, File...) - Static method in class co.cask.cdap.test.TestBase: Deploys an Application with a config.
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: Deploys an Application.
deployApplication(Id.Application, AppRequest) - Static method in class co.cask.cdap.test.TestBase: Deploys an Application.
deployApplication(ApplicationId, AppRequest) - Static method in class co.cask.cdap.test.TestBase: Deploys an Application with version.
deployApplication(NamespaceId, Class<? extends Application>, Config, File...) - Method in class co.cask.cdap.test.UnitTestManager
deployApplication(ApplicationId, 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: Deprecated.
since 4.0.0. Use TestBase.deployDatasetModule(DatasetModuleId, Class) instead.
deployDatasetModule(DatasetModuleId, 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(DatasetModuleId, Class<? extends DatasetModule>) - Method in class co.cask.cdap.test.UnitTestManager

E

execute(Runnable) - Method in class co.cask.cdap.test.UnitTestManager.UnitTestDatasetManager

F

finish() - Static method in class co.cask.cdap.test.TestBase
flush() - Method in class co.cask.cdap.test.UnitTestManager.UnitTestDatasetManager

G

get() - Method in class co.cask.cdap.test.UnitTestManager.UnitTestDatasetManager
getApplicationManager(ApplicationId) - Method in class co.cask.cdap.test.UnitTestManager
getAuthorizer() - Static method in class co.cask.cdap.test.TestBase: Returns an Authorizer for performing authorization operations.
getConfiguration() - Static method in class co.cask.cdap.test.TestBase: Returns the CConfiguration used in tests.
getDataset(Id.Namespace, String) - Method in class co.cask.cdap.test.TestBase: Deprecated.
since 4.0.0. Use TestBase.getDataset(DatasetId) instead.
getDataset(DatasetId) - Method in class co.cask.cdap.test.TestBase: Gets Dataset manager of Dataset instance of type <T>.
getDataset(String) - Method in class co.cask.cdap.test.TestBase: Gets Dataset manager of Dataset instance of type <T>.
getDataset(DatasetId) - Method in class co.cask.cdap.test.UnitTestManager
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(ProgramId, ProgramRunStatus) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
getInfo() - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
getInstances() - Method in class co.cask.cdap.test.internal.DefaultWorkerManager
getInvalidSize() - Method in class co.cask.cdap.test.RevealingTxSystemClient
getMapReduceManager(String) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
getMessagingAdmin(String) - Static method in class co.cask.cdap.test.TestBase: Returns a MessagingAdmin for the given namespace.
getMessagingAdmin(NamespaceId) - Static method in class co.cask.cdap.test.TestBase
getMessagingContext() - Method in class co.cask.cdap.test.TestBase: Returns a MessagingContext for interacting with the messaging system.
getMetrics() - Method in class co.cask.cdap.test.internal.DefaultServiceManager
getMetricsManager() - Method in class co.cask.cdap.test.TestBase
getNamespaceAdmin() - Static method in class co.cask.cdap.test.TestBase: Returns a NamespaceAdmin to interact with namespaces.
getPlugins() - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
getPreviewManager() - Static method in class co.cask.cdap.test.TestBase: Returns a PreviewManager to interact with preview.
getProvisionedInstances() - Method in class co.cask.cdap.test.internal.DefaultServiceManager
getQueryClient(Id.Namespace) - Method in class co.cask.cdap.test.TestBase: Deprecated.
since 4.0.0. Use TestBase.getQueryClient(NamespaceId) instead.
getQueryClient(NamespaceId) - Method in class co.cask.cdap.test.TestBase: Returns a JDBC connection that allows the running of SQL queries over data sets.
getQueryClient() - Method in class co.cask.cdap.test.TestBase: Returns a JDBC connection that allows the running of SQL queries over data sets.
getQueryClient(NamespaceId) - Method in class co.cask.cdap.test.UnitTestManager
getRequestedInstances() - Method in class co.cask.cdap.test.internal.DefaultServiceManager
getRuntimeArgs(ProgramId) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
getSchedule(String) - Method in class co.cask.cdap.test.internal.DefaultWorkflowManager
getSchedules() - Method in class co.cask.cdap.test.internal.DefaultWorkflowManager
getSecureStore() - Static method in class co.cask.cdap.test.TestBase: Returns a SecureStore to interact with secure storage.
getSecureStoreManager() - Static method in class co.cask.cdap.test.TestBase: Returns a SecureStoreManager to interact with secure storage.
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
getSnapshotInputStream() - Method in class co.cask.cdap.test.RevealingTxSystemClient
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: Deprecated.
since 4.0.0. Use TestBase.getStreamManager(StreamId) instead.
getStreamManager(StreamId) - Method in class co.cask.cdap.test.TestBase: Returns a StreamManager for the specified stream in the specified namespace
getStreamManager(StreamId) - 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
getWorkflowNodeStates(String) - Method in class co.cask.cdap.test.internal.DefaultWorkflowManager

I

initialize() - Static method in class co.cask.cdap.test.TestBase
invalidate(long) - Method in class co.cask.cdap.test.RevealingTxSystemClient
isRunning(ProgramId) - 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

R

removeProperties() - Method in class co.cask.cdap.test.internal.DefaultArtifactManager
resetState() - Method in class co.cask.cdap.test.RevealingTxSystemClient
RevealingTxSystemClient - Class in co.cask.cdap.test: A TransactionSystemClient that creates transaction objects with additional fields for validation.
RevealingTxSystemClient.RevealingTransaction - Class in co.cask.cdap.test: This transaction class allows us to return additional details about the transaction to the client.

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
setRuntimeArgs(ProgramId, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
startLong() - Method in class co.cask.cdap.test.RevealingTxSystemClient
startProgram(ProgramId, Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
startShort() - Method in class co.cask.cdap.test.RevealingTxSystemClient
startShort(int) - Method in class co.cask.cdap.test.RevealingTxSystemClient
status() - Method in class co.cask.cdap.test.RevealingTxSystemClient
stopAll() - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
stopProgram(ProgramId) - 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.
timeout - Variable in class co.cask.cdap.test.RevealingTxSystemClient.RevealingTransaction
TMP_FOLDER - Static variable in class co.cask.cdap.test.TestBase
tmpFolder - Static variable in class co.cask.cdap.test.TestBase: Deprecated.
toString() - Method in class co.cask.cdap.test.RevealingTxSystemClient.RevealingTransaction
truncateInvalidTx(Set<Long>) - Method in class co.cask.cdap.test.RevealingTxSystemClient
truncateInvalidTxBefore(long) - Method in class co.cask.cdap.test.RevealingTxSystemClient

U

UnitTestManager - Class in co.cask.cdap.test: TestManager for use in unit tests.
UnitTestManager(AppFabricClient, DatasetFramework, TransactionSystemClient, DiscoveryServiceClient, ApplicationManagerFactory, NamespaceAdmin, StreamManagerFactory, LocationFactory, MetricsManager, ArtifactRepository, ArtifactManagerFactory, CConfiguration) - Constructor for class co.cask.cdap.test.UnitTestManager
UnitTestManager.UnitTestDatasetManager<T> - Class in co.cask.cdap.test: Dataset manager used in unit tests.
update(AppRequest) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager

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
writeProperties(Map<String, String>) - Method in class co.cask.cdap.test.internal.DefaultArtifactManager

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