A C D E F G I R S T U

A

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

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

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

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

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

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

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

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

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

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

C

checkSystemServices() - Method in class co.cask.cdap.test.IntegrationTestBase

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

close() - Method in class co.cask.cdap.test.RemoteDatasetAdmin

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

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

create() - Method in class co.cask.cdap.test.RemoteDatasetAdmin

createNamespace(String) - Method in class co.cask.cdap.test.IntegrationTestBase

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

createStream() - Method in class co.cask.cdap.test.remote.RemoteStreamManager

D

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

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

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

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

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

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

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

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

drop() - Method in class co.cask.cdap.test.RemoteDatasetAdmin

E

exists() - Method in class co.cask.cdap.test.RemoteDatasetAdmin

F

fetchAccessToken() - Method in class co.cask.cdap.test.IntegrationTestBase

Uses BasicAuthenticationClient to fetch AccessToken - this implementation can be overridden if desired.

G

getAccessToken() - Method in class co.cask.cdap.test.IntegrationTestBase

CDAP access token for making requests to secure CDAP instances.

getApplicationClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getApplicationManager(Id.Application) - Method in class co.cask.cdap.test.IntegrationTestBase

getApplicationManager(Id.Application) - Method in class co.cask.cdap.test.IntegrationTestManager

getClientConfig() - Method in class co.cask.cdap.test.IntegrationTestBase

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

getDatasetClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getEvents(long, long, int) - Method in class co.cask.cdap.test.remote.RemoteStreamManager

getEvents(String, String, int) - Method in class co.cask.cdap.test.remote.RemoteStreamManager

getFlowletInstances(String) - Method in class co.cask.cdap.test.remote.RemoteFlowManager

getFlowletMetrics(String) - Method in class co.cask.cdap.test.remote.RemoteFlowManager

getFlowManager(String) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

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

getInstances() - Method in class co.cask.cdap.test.remote.RemoteWorkerManager

getInstanceURI() - Method in class co.cask.cdap.test.IntegrationTestBase

Reads the CDAP instance URI from the system property "instanceUri".

getMapReduceManager(String) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

getMetaClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getMetrics() - Method in class co.cask.cdap.test.remote.RemoteServiceManager

getMetricsClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getMonitorClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getNamespaceClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getProgramClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getProvisionedInstances() - Method in class co.cask.cdap.test.remote.RemoteServiceManager

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

getRequestedInstances() - Method in class co.cask.cdap.test.remote.RemoteServiceManager

getRestClient() - Method in class co.cask.cdap.test.IntegrationTestBase

getSchedule(String) - Method in class co.cask.cdap.test.remote.RemoteWorkflowManager

getSchedules() - Method in class co.cask.cdap.test.remote.RemoteWorkflowManager

getServiceManager(String) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

getServiceURL() - Method in class co.cask.cdap.test.remote.RemoteServiceManager

getServiceURL(long, TimeUnit) - Method in class co.cask.cdap.test.remote.RemoteServiceManager

getSparkManager(String) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

getStreamClient() - Method in class co.cask.cdap.test.IntegrationTestBase

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

getTestManager() - Method in class co.cask.cdap.test.IntegrationTestBase

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

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

getWorkerManager(String) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

getWorkflowManager(String) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

I

IntegrationTestBase - Class in co.cask.cdap.test

Abstract class for writing Integration tests for CDAP.

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

IntegrationTestManager - Class in co.cask.cdap.test

IntegrationTestManager(ClientConfig, RESTClient, File) - Constructor for class co.cask.cdap.test.IntegrationTestManager

isRunning(Id.Program) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

R

RemoteApplicationManager - Class in co.cask.cdap.test.remote

RemoteApplicationManager(Id.Application, ClientConfig, RESTClient) - Constructor for class co.cask.cdap.test.remote.RemoteApplicationManager

RemoteDatasetAdmin - Class in co.cask.cdap.test

Remote implementation of DatasetAdmin.

RemoteDatasetAdmin(DatasetClient, Id.DatasetInstance, DatasetInstanceConfiguration) - Constructor for class co.cask.cdap.test.RemoteDatasetAdmin

RemoteFlowManager - Class in co.cask.cdap.test.remote

Remote implementation of FlowManager.

RemoteFlowManager(Id.Flow, ClientConfig, RESTClient, RemoteApplicationManager) - Constructor for class co.cask.cdap.test.remote.RemoteFlowManager

RemoteServiceManager - Class in co.cask.cdap.test.remote

Remote implementation of ServiceManager.

RemoteServiceManager(Id.Service, ClientConfig, RESTClient, RemoteApplicationManager) - Constructor for class co.cask.cdap.test.remote.RemoteServiceManager

RemoteStreamManager - Class in co.cask.cdap.test.remote

Implementation of StreamManager that interacts with stream service via HTTP calls

RemoteStreamManager(ClientConfig, RESTClient, Id.Stream) - Constructor for class co.cask.cdap.test.remote.RemoteStreamManager

RemoteWorkerManager - Class in co.cask.cdap.test.remote

Remote implementation of WorkerManager

RemoteWorkerManager(Id.Worker, ClientConfig, RESTClient, RemoteApplicationManager) - Constructor for class co.cask.cdap.test.remote.RemoteWorkerManager

RemoteWorkflowManager - Class in co.cask.cdap.test.remote

Remote implementation of WorkflowManager.

RemoteWorkflowManager(Id.Workflow, ClientConfig, RESTClient, RemoteApplicationManager) - Constructor for class co.cask.cdap.test.remote.RemoteWorkflowManager

S

send(String) - Method in class co.cask.cdap.test.remote.RemoteStreamManager

send(byte[]) - Method in class co.cask.cdap.test.remote.RemoteStreamManager

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

send(ByteBuffer) - Method in class co.cask.cdap.test.remote.RemoteStreamManager

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

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

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

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

send(File, String) - Method in class co.cask.cdap.test.remote.RemoteStreamManager

setFlowletInstances(String, int) - Method in class co.cask.cdap.test.remote.RemoteFlowManager

setInstances(int) - Method in class co.cask.cdap.test.remote.RemoteServiceManager

setInstances(int) - Method in class co.cask.cdap.test.remote.RemoteWorkerManager

setUp() - Method in class co.cask.cdap.test.IntegrationTestBase

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

stopAll() - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

stopProgram(Id.Program) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager

T

tearDown() - Method in class co.cask.cdap.test.IntegrationTestBase

TEMP_FOLDER - Static variable in class co.cask.cdap.test.IntegrationTestBase

truncate() - Method in class co.cask.cdap.test.RemoteDatasetAdmin

U

upgrade() - Method in class co.cask.cdap.test.RemoteDatasetAdmin

A C D E F G I R S T U