A B C D E F G H I J K L M N O P Q R S T U V W X 

A

abort(ConsumerWorkingSet, List<? extends PartitionKey>) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
Resets the process state of the given partition keys, as they were not successfully processed, or discards the partition if it has already been attempted the configured number of attempts.
abort(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
AbstractApplication<T extends Config> - Class in co.cask.cdap.api.app
A support class for Applications which reduces repetition and results in a more readable configuration.
AbstractApplication() - Constructor for class co.cask.cdap.api.app.AbstractApplication
 
AbstractApplicationManager - Class in co.cask.cdap.test
A base implementation of ApplicationManager.
AbstractApplicationManager(Id.Application) - Constructor for class co.cask.cdap.test.AbstractApplicationManager
 
AbstractApplicationManager(ApplicationId) - Constructor for class co.cask.cdap.test.AbstractApplicationManager
 
AbstractCloseableIterator<T> - Class in co.cask.cdap.api.dataset.lib
An abstract that Iterator helps implement an non-removable CloseableIterator.
AbstractCloseableIterator() - Constructor for class co.cask.cdap.api.dataset.lib.AbstractCloseableIterator
Constructor for use by subclasses.
AbstractCubeHttpHandler - Class in co.cask.cdap.api.dataset.lib.cube
A basic implementation of HttpServiceHandler that provides endpoints to explore and execute queries in Cube dataset.
AbstractCubeHttpHandler() - Constructor for class co.cask.cdap.api.dataset.lib.cube.AbstractCubeHttpHandler
 
AbstractCustomAction - Class in co.cask.cdap.api.customaction
This abstract class provides a default implementation of CustomAction methods for easy extensions.
AbstractCustomAction() - Constructor for class co.cask.cdap.api.customaction.AbstractCustomAction
 
AbstractCustomAction(String) - Constructor for class co.cask.cdap.api.customaction.AbstractCustomAction
 
AbstractDataset - Class in co.cask.cdap.api.dataset.lib
Handy abstract implementation of Dataset that acts on a list of underlying datasets and implements TransactionAware and MeteredDataset interfaces by propagating corresponded logic to each dataset in a list when possible.
AbstractDataset(String, Dataset, Dataset...) - Constructor for class co.cask.cdap.api.dataset.lib.AbstractDataset
 
AbstractDatasetDefinition<D extends Dataset,A extends DatasetAdmin> - Class in co.cask.cdap.api.dataset.lib
Basic abstract implementation of DatasetDefinition.
AbstractDatasetDefinition(String) - Constructor for class co.cask.cdap.api.dataset.lib.AbstractDatasetDefinition
Ctor that takes in name of this dataset type.
AbstractFlow - Class in co.cask.cdap.api.flow
This abstract class provides a default implementation of Flow methods for easy extension.
AbstractFlow() - Constructor for class co.cask.cdap.api.flow.AbstractFlow
 
AbstractFlowlet - Class in co.cask.cdap.api.flow.flowlet
This abstract class provides a default implementation of Flowlet methods for easy extension.
AbstractFlowlet() - Constructor for class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
 
AbstractHttpServiceHandler - Class in co.cask.cdap.api.service.http
An abstract implementation of HttpServiceHandler.
AbstractHttpServiceHandler() - Constructor for class co.cask.cdap.api.service.http.AbstractHttpServiceHandler
 
AbstractMapReduce - Class in co.cask.cdap.api.mapreduce
This abstract class provides a default implementation of MapReduce methods for easy extension.
AbstractMapReduce() - Constructor for class co.cask.cdap.api.mapreduce.AbstractMapReduce
 
AbstractPartitionConsumer - Class in co.cask.cdap.api.dataset.lib.partitioned
Abstract implementation of PartitionConsumer, which manages state persistence and serialization/deserialization before delegating to the abstract methods.
AbstractPartitionConsumer(PartitionedFileSet, StatePersistor) - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
Creates an instance of PartitionConsumer.
AbstractPartitionConsumer(PartitionedFileSet, StatePersistor, ConsumerConfiguration) - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
Creates an instance of PartitionConsumer.
AbstractProgramManager<T extends ProgramManager> - Class in co.cask.cdap.test
Abstract implementation of ProgramManager that includes common functionality for all implementations.
AbstractProgramManager(ProgramId, ApplicationManager) - Constructor for class co.cask.cdap.test.AbstractProgramManager
 
AbstractProgramManager(Id.Program, ApplicationManager) - Constructor for class co.cask.cdap.test.AbstractProgramManager
 
AbstractService - Class in co.cask.cdap.api.service
An abstract implementation of Service.
AbstractService() - Constructor for class co.cask.cdap.api.service.AbstractService
 
AbstractSpark - Class in co.cask.cdap.api.spark
This abstract class provides a default implementation of Spark methods for easy extension.
AbstractSpark() - Constructor for class co.cask.cdap.api.spark.AbstractSpark
 
AbstractTestManager - Class in co.cask.cdap.test
Class that delegates deprecated methods to their non-deprecated counterparts, and delegates methods with fewer arguments to the one with more arguments.
AbstractTestManager() - Constructor for class co.cask.cdap.test.AbstractTestManager
 
AbstractWorker - Class in co.cask.cdap.api.worker
Extend this class to add workers.
AbstractWorker() - Constructor for class co.cask.cdap.api.worker.AbstractWorker
 
AbstractWorkflow - Class in co.cask.cdap.api.workflow
Provides a default implementation of Workflow methods for easy extension.
AbstractWorkflow() - Constructor for class co.cask.cdap.api.workflow.AbstractWorkflow
 
AbstractWorkflowAction - Class in co.cask.cdap.api.workflow
Deprecated.
Deprecated as of 3.5.0. Please use AbstractCustomAction instead.
AbstractWorkflowAction() - Constructor for class co.cask.cdap.api.workflow.AbstractWorkflowAction
Deprecated.
 
AbstractWorkflowAction(String) - Constructor for class co.cask.cdap.api.workflow.AbstractWorkflowAction
Deprecated.
 
accept(PartitionDetail) - Method in interface co.cask.cdap.api.dataset.lib.partitioned.PartitionAcceptor
 
accept(PartitionDetail) - Method in class co.cask.cdap.api.dataset.lib.partitioned.PartitionAcceptor.Limit
 
Action - Class in co.cask.cdap.etl.api.action
Represents custom logic to be executed in the pipeline.
Action() - Constructor for class co.cask.cdap.etl.api.action.Action
 
ActionContext - Interface in co.cask.cdap.etl.api.action
Represents the context available to the action plugin during runtime.
add(byte[], byte[]) - Static method in class co.cask.cdap.api.common.Bytes
Concatenate two byte arrays.
add(byte[], byte[], byte[]) - Static method in class co.cask.cdap.api.common.Bytes
Concatenate three byte arrays.
add(String, String) - Method in class co.cask.cdap.api.dataset.DatasetProperties.Builder
Adds a property.
add(String, int) - Method in class co.cask.cdap.api.dataset.DatasetProperties.Builder
Adds a property.
add(String, long) - Method in class co.cask.cdap.api.dataset.DatasetProperties.Builder
Adds a property.
add(CubeFact) - Method in interface co.cask.cdap.api.dataset.lib.cube.Cube
Adds CubeFact to this Cube.
add(Collection<? extends CubeFact>) - Method in interface co.cask.cdap.api.dataset.lib.cube.Cube
Adds CubeFacts to this Cube.
add(DatasetDefinition) - Method in interface co.cask.cdap.api.dataset.module.DatasetDefinitionRegistry
Adds DatasetDefinition to the registry.
add(byte[], long) - Method in class co.cask.cdap.api.dataset.table.Increment
Adds a column and sets the column's value.
add(String, long) - Method in class co.cask.cdap.api.dataset.table.Increment
Adds a column and sets the column's value.
add(byte[], byte[]) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], String) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], boolean) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], short) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], int) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], long) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], float) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], double) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, byte[]) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, String) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, boolean) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, short) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, int) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, long) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, float) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(String, double) - Method in class co.cask.cdap.api.dataset.table.Put
Write a value to a column.
add(byte[], byte[]...) - Method in class co.cask.cdap.api.dataset.table.RowColumns
Specifies column(s) to be included.
add(byte[][]) - Method in class co.cask.cdap.api.dataset.table.RowColumns
Specifies column(s) to be included.
add(String, String...) - Method in class co.cask.cdap.api.dataset.table.RowColumns
Specifies column(s) to be included.
add(String[]) - Method in class co.cask.cdap.api.dataset.table.RowColumns
Specifies column(s) to be included.
add(MetricValues) - Method in interface co.cask.cdap.api.metrics.MetricStore
Adds MetricValues to the store.
add(Collection<? extends MetricValues>) - Method in interface co.cask.cdap.api.metrics.MetricStore
Adds MetricValuess to the store.
add(String, String) - Method in class co.cask.cdap.api.plugin.PluginProperties.Builder
Adds a property
add(Id.Artifact, Set<ArtifactRange>, InputSupplier<? extends InputStream>) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
add(ArtifactId, Set<ArtifactRange>, InputSupplier<? extends InputStream>) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(Id.Namespace, String, InputSupplier<? extends InputStream>, String) - Method in class co.cask.cdap.client.ArtifactClient
add(NamespaceId, String, InputSupplier<? extends InputStream>, String) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(Id.Namespace, String, InputSupplier<? extends InputStream>, String, Set<ArtifactRange>) - Method in class co.cask.cdap.client.ArtifactClient
add(NamespaceId, String, InputSupplier<? extends InputStream>, String, Set<ArtifactRange>) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(Id.Namespace, String, InputSupplier<? extends InputStream>, String, Set<ArtifactRange>, Set<PluginClass>) - Method in class co.cask.cdap.client.ArtifactClient
add(NamespaceId, String, InputSupplier<? extends InputStream>, String, Set<ArtifactRange>, Set<PluginClass>) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(Id.DatasetModule, String, File) - Method in class co.cask.cdap.client.DatasetModuleClient
Deprecated.
add(DatasetModuleId, String, File) - Method in class co.cask.cdap.client.DatasetModuleClient
Adds a new dataset module.
add(ScheduleId, ScheduleInstanceConfiguration) - Method in class co.cask.cdap.client.ScheduleClient
 
addAction(WorkflowAction) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Deprecated.
Deprecated as of 3.5.0. Please use AbstractWorkflow.addAction(CustomAction) instead.
addAction(CustomAction) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a custom action to the Workflow.
addAction(WorkflowAction) - Method in interface co.cask.cdap.api.workflow.WorkflowConditionConfigurer
Deprecated.
Deprecated as of 3.5.0. Please use WorkflowConditionConfigurer.addAction(CustomAction) instead.
addAction(CustomAction) - Method in interface co.cask.cdap.api.workflow.WorkflowConditionConfigurer
Adds custom action a a next sequential step to the current branch of the WorkflowConditionNode.
addAction(WorkflowAction) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Deprecated.
Deprecated as of 3.5.0. Please use WorkflowConfigurer.addAction(CustomAction action) instead.
addAction(CustomAction) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Adds a custom action as a next sequential step in the Workflow
addAction(WorkflowAction) - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Deprecated.
Deprecated as of 3.5.0. Please use WorkflowForkConfigurer.addAction(CustomAction) instead.
addAction(CustomAction) - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Adds custom action a a next sequential step to the current branch of the WorkflowForkNode
addAll(Map<String, String>) - Method in class co.cask.cdap.api.dataset.DatasetProperties.Builder
Adds multiple properties.
addAll(Map<String, String>) - Method in class co.cask.cdap.api.plugin.PluginProperties.Builder
Adds multiple properties.
addAppArtifact(Id.Artifact, Class<?>) - Method in class co.cask.cdap.test.AbstractTestManager
 
addAppArtifact(Id.Artifact, Class<?>, String...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addAppArtifact(Id.Artifact, Class<?>, Manifest) - Method in class co.cask.cdap.test.AbstractTestManager
 
addAppArtifact(ArtifactId, Class<?>) - Method in class co.cask.cdap.test.IntegrationTestBase
 
addAppArtifact(ArtifactId, Class<?>) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addAppArtifact(ArtifactId, Class<?>, String...) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addAppArtifact(ArtifactId, Class<?>, Manifest) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addAppArtifact(Id.Artifact, Class<?>) - Static method in class co.cask.cdap.test.TestBase
Deprecated.
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
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
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(Id.Artifact, Class<?>) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
addAppArtifact(ArtifactId, Class<?>) - Method in interface co.cask.cdap.test.TestManager
Builds an application artifact from the specified class and then adds it.
addAppArtifact(Id.Artifact, Class<?>, String...) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
addAppArtifact(ArtifactId, Class<?>, String...) - Method in interface co.cask.cdap.test.TestManager
Builds an application artifact from the specified class and then adds it.
addAppArtifact(Id.Artifact, Class<?>, Manifest) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
addAppArtifact(ArtifactId, Class<?>, Manifest) - Method in interface co.cask.cdap.test.TestManager
Builds an application artifact from the specified class and then adds 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) - Method in class co.cask.cdap.test.AbstractTestManager
 
addArtifact(ArtifactId, File) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addArtifact(Id.Artifact, File) - Static method in class co.cask.cdap.test.TestBase
Deprecated.
addArtifact(ArtifactId, File) - Static method in class co.cask.cdap.test.TestBase
Add the specified artifact.
addArtifact(Id.Artifact, File) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
addArtifact(ArtifactId, File) - Method in interface co.cask.cdap.test.TestManager
Adds the specified artifact.
addArtifact(ArtifactId, File) - Method in class co.cask.cdap.test.UnitTestManager
 
addDatasetInstance(Id.Namespace, String, String, DatasetProperties) - Method in class co.cask.cdap.test.AbstractTestManager
 
addDatasetInstance(Id.Namespace, String, String) - Method in class co.cask.cdap.test.AbstractTestManager
 
addDatasetInstance(String, DatasetId) - Method in class co.cask.cdap.test.AbstractTestManager
 
addDatasetInstance(String, DatasetId, DatasetProperties) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addDatasetInstance(Id.Namespace, String, String, DatasetProperties) - Static method in class co.cask.cdap.test.TestBase
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.
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(Id.Namespace, String, String, DatasetProperties) - Method in interface co.cask.cdap.test.TestManager
addDatasetInstance(String, DatasetId, DatasetProperties) - Method in interface co.cask.cdap.test.TestManager
Adds an instance of a dataset.
addDatasetInstance(Id.Namespace, String, String) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
addDatasetInstance(String, DatasetId) - Method in interface co.cask.cdap.test.TestManager
Adds an instance of dataset.
addDatasetInstance(String, DatasetId, DatasetProperties) - Method in class co.cask.cdap.test.UnitTestManager
 
addDatasetModule(String, Class<? extends DatasetModule>) - Method in interface co.cask.cdap.api.DatasetConfigurer
Adds a DatasetModule to be deployed automatically (if absent in the CDAP namespace) during application deployment.
addDatasetType(Class<? extends Dataset>) - Method in interface co.cask.cdap.api.DatasetConfigurer
Adds a DatasetModule to be deployed automatically during application deployment, using Dataset as a base for the DatasetModule.
addDimensionValue(String, String) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
Adds dimension value to this CubeFact.
addDimensionValues(Map<String, String>) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
Adds multiple dimensionValues to this CubeFact.
addFact(HttpServiceRequest, HttpServiceResponder) - Method in class co.cask.cdap.api.dataset.lib.cube.AbstractCubeHttpHandler
Adds facts to a Cube as defined by Cube.add(java.util.Collection).
addField(String, Partitioning.FieldType) - Method in class co.cask.cdap.api.dataset.lib.Partitioning.Builder
Add a field with a given name and type.
addField(String, Comparable) - Method in class co.cask.cdap.api.dataset.lib.PartitionKey.Builder
Add a field with a given name and value.
addFlow(Flow) - Method in class co.cask.cdap.api.app.AbstractApplication
 
addFlow(Flow) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Adds a Flow to the Application.
addFlowlet(Flowlet) - Method in class co.cask.cdap.api.flow.AbstractFlow
Adds a Flowlet to the Flow.
addFlowlet(Flowlet, int) - Method in class co.cask.cdap.api.flow.AbstractFlow
Add a flowlet to the flow with the minimum number of instances of the flowlet to start with.
addFlowlet(String, Flowlet) - Method in class co.cask.cdap.api.flow.AbstractFlow
Add a flowlet to flow with the specified name.
addFlowlet(String, Flowlet, int) - Method in class co.cask.cdap.api.flow.AbstractFlow
Add a flowlet to the flow with the minimum number of instances of the flowlet to start with.
addFlowlet(Flowlet) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Add a Flowlet to the Flow.
addFlowlet(Flowlet, int) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Add a flowlet to the flow with the minimum number of instances of the flowlet to start with.
addFlowlet(String, Flowlet) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Add a flowlet to flow with the specified name.
addFlowlet(String, Flowlet, int) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Add a flowlet to the flow with the minimum number of instances of the flowlet to start with.
addHandler(HttpServiceHandler) - Method in class co.cask.cdap.api.service.AbstractService
Add handler to the Service.
addHandlers(Iterable<? extends HttpServiceHandler>) - Method in class co.cask.cdap.api.service.AbstractService
Add a list of handlers to the Service.
addHandlers(Iterable<? extends HttpServiceHandler>) - Method in interface co.cask.cdap.api.service.ServiceConfigurer
Add a a list of request handlers to the Service.
addInput(Input) - Method in interface co.cask.cdap.api.mapreduce.MapReduceContext
Updates the input configuration of this MapReduce job to use the specified Input.
addInput(Input, Class<?>) - Method in interface co.cask.cdap.api.mapreduce.MapReduceContext
Updates the input configuration of this MapReduce job to use the specified Input.
addInputPartition(Map<String, String>, Partition) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
Sets a partition as input for a PartitionedFileSet.
addInputPartitions(Map<String, String>, Iterator<? extends Partition>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
Sets partitions as input for a PartitionedFileSet.
addInputPartitions(Map<String, String>, Iterable<? extends Partition>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
Sets partitions as input for a PartitionedFileSet.
addInputPath(Map<String, String>, String) - Static method in class co.cask.cdap.api.dataset.lib.FileSetArguments
Add an input path in the runtime arguments for a file dataset.
addIntField(String) - Method in class co.cask.cdap.api.dataset.lib.Partitioning.Builder
Add field of type INT.
addIntField(String, int) - Method in class co.cask.cdap.api.dataset.lib.PartitionKey.Builder
Add field of type INT.
addListener(RESTClient.Listener) - Method in class co.cask.cdap.client.util.RESTClient
 
addLongField(String) - Method in class co.cask.cdap.api.dataset.lib.Partitioning.Builder
Add field of type LONG.
addLongField(String, long) - Method in class co.cask.cdap.api.dataset.lib.PartitionKey.Builder
Add field of type LONG.
addMapReduce(MapReduce) - Method in class co.cask.cdap.api.app.AbstractApplication
 
addMapReduce(MapReduce) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Adds a MapReduce job to the Application.
addMapReduce(String) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a MapReduce program to the Workflow.
addMapReduce(String) - Method in interface co.cask.cdap.api.workflow.WorkflowConditionConfigurer
Adds a MapReduce program as a next sequential step to the current branch of the WorkflowConditionNode.
addMapReduce(String) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Adds a MapReduce program as a next sequential step in the Workflow.
addMapReduce(String) - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Adds a MapReduce program as a next sequential step to the current branch of the WorkflowForkNode
addMeasurement(String, MeasureType, long) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
Adds a Measurement to this CubeFact.
addMeasurement(Measurement) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
Adds a Measurement to this CubeFact.
addMeasurements(Collection<Measurement>) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
Adds multiple Measurements to this CubeFact
addMetadata(PartitionKey, String, String) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Adds a new metadata entry for a particular partition.
addMetadata(PartitionKey, Map<String, String>) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Adds a set of new metadata entries for a particular partition.
addMetadata(long, String, String) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Adds a new metadata entry for a particular partition.
addMetadata(long, Map<String, String>) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Adds a set of new metadata entries for a particular partition Note that existing entries can not be updated.
addOutput(Output) - Method in interface co.cask.cdap.api.mapreduce.MapReduceContext
Updates the output configuration of this MapReduce job to use the specified Output.
addOutput(String) - Method in interface co.cask.cdap.etl.api.batch.BatchSinkContext
Deprecated.
Deprecated since 3.4.0. Use BatchSinkContext.addOutput(Output) instead
addOutput(String, Map<String, String>) - Method in interface co.cask.cdap.etl.api.batch.BatchSinkContext
Deprecated.
Deprecated since 3.4.0. Use BatchSinkContext.addOutput(Output) instead
addOutput(String, OutputFormatProvider) - Method in interface co.cask.cdap.etl.api.batch.BatchSinkContext
Deprecated.
Deprecated since 3.4.0. Use BatchSinkContext.addOutput(Output) instead
addOutput(Output) - Method in interface co.cask.cdap.etl.api.batch.BatchSinkContext
Updates the output configuration of this job to also allow writing using the given output.
addPartition(PartitionKey) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerWorkingSet
Adds a new partition to the working set.
addPartition(PartitionKey, String) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Add a partition for a given partition key, stored at a given path (relative to the file set's base path).
addPartition(PartitionKey, String, Map<String, String>) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Add a partition for a given partition key, stored at a given path (relative to the file set's base path), with the given metadata.
addPartition() - Method in interface co.cask.cdap.api.dataset.lib.PartitionOutput
Add the partition to the partitioned file set.
addPartition(long, String) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Add a partition for a given time, stored at a given path (relative to the file set's base path).
addPartition(long, String, Map<String, String>) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Add a partition for a given time, stored at a given path (relative to the file set's base path), with given metadata.
addPluginArtifact(Id.Artifact, Id.Artifact, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addPluginArtifact(Id.Artifact, Set<ArtifactRange>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addPluginArtifact(Id.Artifact, Id.Artifact, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addPluginArtifact(Id.Artifact, Set<ArtifactRange>, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addPluginArtifact(ArtifactId, ArtifactId, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addPluginArtifact(ArtifactId, Set<ArtifactRange>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addPluginArtifact(ArtifactId, ArtifactId, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.AbstractTestManager
 
addPluginArtifact(ArtifactId, ArtifactId, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addPluginArtifact(ArtifactId, Set<ArtifactRange>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addPluginArtifact(ArtifactId, ArtifactId, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addPluginArtifact(ArtifactId, Set<ArtifactRange>, Set<PluginClass>, Class<?>, Class<?>...) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addPluginArtifact(Id.Artifact, Id.Artifact, Class<?>, Class<?>...) - Static method in class co.cask.cdap.test.TestBase
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
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
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(Id.Artifact, Id.Artifact, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
addPluginArtifact(ArtifactId, ArtifactId, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
Builds an artifact from the specified plugin classes and then adds it.
addPluginArtifact(Id.Artifact, Set<ArtifactRange>, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
addPluginArtifact(ArtifactId, Set<ArtifactRange>, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
Builds an artifact from the specified plugin classes and then adds it.
addPluginArtifact(Id.Artifact, Id.Artifact, Set<PluginClass>, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
addPluginArtifact(ArtifactId, ArtifactId, Set<PluginClass>, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
Builds an artifact from the specified plugin classes and then adds it.
addPluginArtifact(Id.Artifact, Set<ArtifactRange>, Set<PluginClass>, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
addPluginArtifact(ArtifactId, Set<ArtifactRange>, Set<PluginClass>, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
Builds an artifact from the specified plugin classes and then adds 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
 
addRangeCondition(String, T, T) - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Builder
Add a condition for a given field name with an inclusive lower and an exclusive upper bound.
addRoleToPrincipal(Role, Principal) - Method in class co.cask.cdap.client.AuthorizationClient
 
addSchedule(Schedule, SchedulableProgramType, String, Map<String, String>) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Adds a Schedule to the specified program in the Application
addScope(Scope, String, Map<String, String>) - Static method in class co.cask.cdap.api.common.RuntimeArguments
Add a scope prefix to all arguments.
addScope(Scope, String, String) - Static method in class co.cask.cdap.api.common.RuntimeArguments
Add a scope prefix to an argument name.
addScope(String, String, String) - Static method in class co.cask.cdap.api.common.RuntimeArguments
Add a scope prefix to an argument name.
addService(Service) - Method in class co.cask.cdap.api.app.AbstractApplication
 
addService(String, HttpServiceHandler, HttpServiceHandler...) - Method in class co.cask.cdap.api.app.AbstractApplication
Adds a Service that consists of the given HttpServiceHandler.
addService(Service) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Adds a custom Service to the Application.
addSpark(Spark) - Method in class co.cask.cdap.api.app.AbstractApplication
 
addSpark(Spark) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Adds a Spark job to the Application.
addSpark(String) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a Spark program to the Workflow.
addSpark(String) - Method in interface co.cask.cdap.api.workflow.WorkflowConditionConfigurer
Adds a Spark program as a next sequential step to the current branch of the WorkflowConditionNode.
addSpark(String) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Adds a Spark program as a next sequential step in the Workflow.
addSpark(String) - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Adds a Spark program as a next sequential step to the current branch of the WorkflowForkNode
addStream(Stream) - Method in interface co.cask.cdap.api.DatasetConfigurer
Adds a Stream.
addStream(String) - Method in interface co.cask.cdap.api.DatasetConfigurer
Adds a Stream given the name of the stream.
addStringField(String) - Method in class co.cask.cdap.api.dataset.lib.Partitioning.Builder
Add field of type STRING.
addStringField(String, String) - Method in class co.cask.cdap.api.dataset.lib.PartitionKey.Builder
Add field of type STRING.
addValueCondition(String, T) - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Builder
Add a condition that matches by equality.
addWorker(Worker) - Method in class co.cask.cdap.api.app.AbstractApplication
 
addWorker(Worker) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Adds a Worker to the Application.
addWorkflow(Workflow) - Method in class co.cask.cdap.api.app.AbstractApplication
 
addWorkflow(Workflow) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Adds a Workflow to the Application.
Admin - Interface in co.cask.cdap.api
This interface provides methods for operational calls from within a CDAP application.
after() - Method in class co.cask.cdap.test.SingletonExternalResource
 
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.
aggregate(GROUP_KEY, Iterator<GROUP_VALUE>, Emitter<OUT>) - Method in interface co.cask.cdap.etl.api.Aggregator
Aggregate all objects in the same group into zero or more output objects.
AggregationFunction - Enum in co.cask.cdap.api.dataset.lib.cube
Function to be used when aggregating multiple data points.
Aggregator<GROUP_KEY,GROUP_VALUE,OUT> - Interface in co.cask.cdap.etl.api
Groups all input objects into collections and performs an aggregation on the entire group.
alias(String) - Method in class co.cask.cdap.api.data.batch.Input
Sets an alias to be used as the input name.
alias(String) - Method in class co.cask.cdap.api.data.batch.Output
Sets an alias to be used as the output name.
ALL - Static variable in class co.cask.cdap.api.data.format.Formats
 
ALL_PROGRAMS - Static variable in class co.cask.cdap.client.app.FakeApp
 
allSystemServicesOk() - Method in class co.cask.cdap.client.MonitorClient
 
also() - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Adds a branch to the WorkflowForkNode
ALWAYS_MATCH - Static variable in class co.cask.cdap.api.dataset.lib.PartitionFilter
 
ANOTHER_FAKE_NAME - Static variable in class co.cask.cdap.client.app.FakeWorkflow.FakeAction
 
ANY_INPUT - Static variable in class co.cask.cdap.api.flow.FlowletDefinition
 
AppenderContext - Class in co.cask.cdap.api.logging
Context provided to Appender via the ContextAware.setContext(Context) method.
AppenderContext() - Constructor for class co.cask.cdap.api.logging.AppenderContext
 
Application<T extends Config> - Interface in co.cask.cdap.api.app
Defines a CDAP Application.
application - Variable in class co.cask.cdap.test.AbstractApplicationManager
 
ApplicationClient - Class in co.cask.cdap.client
Provides ways to interact with CDAP applications.
ApplicationClient(ClientConfig, RESTClient) - Constructor for class co.cask.cdap.client.ApplicationClient
 
ApplicationClient(ClientConfig) - Constructor for class co.cask.cdap.client.ApplicationClient
 
ApplicationConfigurer - Interface in co.cask.cdap.api.app
Configures a CDAP Application.
ApplicationContext<T extends Config> - Interface in co.cask.cdap.api.app
Provides access to the environment, application configuration, and application (deployment) arguments.
ApplicationManager - Interface in co.cask.cdap.test
Instance of this class is for managing deployed application.
ApplicationSpecification - Interface in co.cask.cdap.api.app
Application Specification used in core code.
apply(T) - Method in interface co.cask.cdap.api.Predicate
Returns the result of applying this predicate to input.
AppReturnsArgs - Class in co.cask.cdap.client.app
Test Application with service which returns the runtime arguments.
AppReturnsArgs() - Constructor for class co.cask.cdap.client.app.AppReturnsArgs
 
AppReturnsArgs.ArgService - Class in co.cask.cdap.client.app
 
AppReturnsArgs.ArgService() - Constructor for class co.cask.cdap.client.app.AppReturnsArgs.ArgService
 
arrayOf(Schema) - Static method in class co.cask.cdap.api.data.schema.Schema
Creates an ARRAY Schema of the given component type.
ArtifactClient - Class in co.cask.cdap.client
Provides ways to interact with CDAP Artifacts.
ArtifactClient(ClientConfig, RESTClient) - Constructor for class co.cask.cdap.client.ArtifactClient
 
ArtifactClient(ClientConfig) - Constructor for class co.cask.cdap.client.ArtifactClient
 
ArtifactId - Class in co.cask.cdap.api.artifact
Uniquely describes an artifact within a namespace.
ArtifactId(String, ArtifactVersion, ArtifactScope) - Constructor for class co.cask.cdap.api.artifact.ArtifactId
 
ArtifactManager - Interface in co.cask.cdap.test
An interface to manage interactions with an artifact in tests.
ArtifactScope - Enum in co.cask.cdap.api.artifact
The scope of an artifact.
ArtifactVersion - Class in co.cask.cdap.api.artifact
Represents version of an artifact.
ArtifactVersion(String) - Constructor for class co.cask.cdap.api.artifact.ArtifactVersion
Constructs an instance by parsing the given string.
ArtifactVersion(String, boolean) - Constructor for class co.cask.cdap.api.artifact.ArtifactVersion
Constructs an instance by parsing the given string.
asMap() - Method in class co.cask.cdap.api.dataset.lib.PartitionMetadata
 
asMap() - Method in interface co.cask.cdap.etl.api.action.SettableArguments
Returns an map that represents all arguments.
assertInProgress(ConsumablePartition) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
ensure that caller doesn't try to commit/abort a partition that isn't in progress
asyncSendEvent(Id.Stream, String) - Method in class co.cask.cdap.client.StreamClient
Deprecated.
asyncSendEvent(StreamId, String) - Method in class co.cask.cdap.client.StreamClient
Sends an event to a stream.
AUTHORIZATION_BASE - Static variable in class co.cask.cdap.client.AuthorizationClient
 
AuthorizationClient - Class in co.cask.cdap.client
Provides ways to interact with the CDAP authorization system.
AuthorizationClient(ClientConfig, RESTClient) - Constructor for class co.cask.cdap.client.AuthorizationClient
 
AuthorizationClient(ClientConfig) - Constructor for class co.cask.cdap.client.AuthorizationClient
 
AVRO - Static variable in class co.cask.cdap.api.data.format.Formats
 

B

BASE_PATH - Static variable in class co.cask.cdap.api.dataset.lib.FileSetProperties
The base path of the dataset.
BasicService - Class in co.cask.cdap.api.service
A Service that composes of one or more HttpServiceHandler.
BasicService(String, HttpServiceHandler, HttpServiceHandler...) - Constructor for class co.cask.cdap.api.service.BasicService
 
BasicService(String, Iterable<? extends HttpServiceHandler>) - Constructor for class co.cask.cdap.api.service.BasicService
 
Batch - Annotation Type in co.cask.cdap.api.annotation
Annotates a Flowlet's method to indicate that it will process its input in batch.
BatchActionContext - Interface in co.cask.cdap.etl.api.batch
Context for a batch action, giving access to whether the run was successful, the workflow token, and the state of each phase in the workflow.
BatchAggregator<GROUP_KEY,GROUP_VALUE,OUT> - Class in co.cask.cdap.etl.api.batch
An Aggregator used in batch programs.
BatchAggregator() - Constructor for class co.cask.cdap.etl.api.batch.BatchAggregator
 
BatchAggregatorContext - Interface in co.cask.cdap.etl.api.batch
Context of a Batch Aggregator.
BatchConfigurable<T extends BatchContext> - Class in co.cask.cdap.etl.api.batch
Base class for Batch run configuration methods.
BatchConfigurable() - Constructor for class co.cask.cdap.etl.api.batch.BatchConfigurable
 
BatchContext - Interface in co.cask.cdap.etl.api.batch
Context passed to Batch Source and Sink.
BatchJoiner<JOIN_KEY,INPUT_RECORD,OUT> - Class in co.cask.cdap.etl.api.batch
A Joiner used for batch programs.
BatchJoiner() - Constructor for class co.cask.cdap.etl.api.batch.BatchJoiner
 
BatchJoinerContext - Interface in co.cask.cdap.etl.api.batch
Context of a Batch Joiner
BatchJoinerRuntimeContext - Interface in co.cask.cdap.etl.api.batch
Runtime context for batch joiner
BatchReadable<KEY,VALUE> - Interface in co.cask.cdap.api.data.batch
Interface for datasets that can be input to a batch job.
BatchRuntimeContext - Interface in co.cask.cdap.etl.api.batch
Context passed to Batch Source and Sink.
BatchSink<IN,KEY_OUT,VAL_OUT> - Class in co.cask.cdap.etl.api.batch
Batch Sink forms the last stage of a Batch ETL Pipeline.
BatchSink() - Constructor for class co.cask.cdap.etl.api.batch.BatchSink
 
BatchSinkContext - Interface in co.cask.cdap.etl.api.batch
Context of a Batch Sink.
BatchSource<KEY_IN,VAL_IN,OUT> - Class in co.cask.cdap.etl.api.batch
Batch Source forms the first stage of a Batch ETL Pipeline.
BatchSource() - Constructor for class co.cask.cdap.etl.api.batch.BatchSource
 
BatchSourceContext - Interface in co.cask.cdap.etl.api.batch
Context of a Batch Source.
BatchWritable<KEY,VALUE> - Interface in co.cask.cdap.api.data.batch
Interface for the dataset that a batch job can output to.
before() - Method in class co.cask.cdap.test.SingletonExternalResource
 
before() - Method in class co.cask.cdap.test.TestConfiguration
 
beforeSubmit(MapReduceContext) - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
Deprecated.
beforeSubmit(MapReduceContext) - Method in interface co.cask.cdap.api.mapreduce.MapReduce
Deprecated.
Deprecated as of 3.5.0. Please use ProgramLifecycle.initialize(T) instead, to initialize the MapReduce program.
beforeSubmit(SparkClientContext) - Method in class co.cask.cdap.api.spark.AbstractSpark
Deprecated.
beforeSubmit(SparkClientContext) - Method in interface co.cask.cdap.api.spark.Spark
Deprecated.
Deprecated as of 3.5.0. Please use ProgramLifecycle.initialize(T) instead, to initialize the Spark program.
beforeTest() - Method in class co.cask.cdap.test.TestBase
 
Beta - Annotation Type in co.cask.cdap.api.annotation
Annotates a public API that may be subjected to incompatible changes up to the extent of removal from the library in future releases.
build() - Method in interface co.cask.cdap.api.builder.Creator
 
build() - Method in class co.cask.cdap.api.data.format.StructuredRecord.Builder
Build a StructuredRecord with the fields set by this builder.
build() - Method in class co.cask.cdap.api.dataset.DatasetProperties.Builder
Create a DatasetProperties from this builder, using the private DatasetProperties constructor.
build() - Method in class co.cask.cdap.api.dataset.DatasetSpecification.Builder
Create a DataSetSpecification from this builder, using the private DataSetSpecification constructor.
build() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery.Builder.Build
 
build() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.Build
 
build() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.Limit
 
build() - Method in class co.cask.cdap.api.dataset.lib.ObjectMappedTableProperties.Builder
Create a DatasetProperties from this builder.
build() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerConfiguration.Builder
Create a ConsumerConfiguration from this builder, using the private ConsumerConfiguration constructor.
build() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Builder
Create the PartitionFilter.
build() - Method in class co.cask.cdap.api.dataset.lib.Partitioning.Builder
Create the partitioning.
build() - Method in class co.cask.cdap.api.dataset.lib.PartitionKey.Builder
Create the partition key.
build() - Method in class co.cask.cdap.api.plugin.PluginProperties.Builder
Creates a new instance of PluginProperties with the properties added to this builder prior to this call.
build() - Method in class co.cask.cdap.client.config.ClientConfig.Builder
 
build() - Method in class co.cask.cdap.client.config.ConnectionConfig.Builder
 
builder(Schema) - Static method in class co.cask.cdap.api.data.format.StructuredRecord
Get a builder for creating a record with the given schema.
builder() - Static method in class co.cask.cdap.api.dataset.DatasetProperties
 
builder(String, String) - Static method in class co.cask.cdap.api.dataset.DatasetSpecification
 
builder() - Static method in class co.cask.cdap.api.dataset.ExploreProperties
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.ObjectMappedTableProperties
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerConfiguration
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetProperties
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.PartitionFilter
Use this to create PartitionFilters.
builder() - Static method in class co.cask.cdap.api.dataset.lib.Partitioning
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.PartitionKey
 
builder(Partitioning) - Static method in class co.cask.cdap.api.dataset.lib.PartitionKey
 
builder() - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
builder() - Static method in class co.cask.cdap.api.plugin.PluginProperties
 
builder(String) - Static method in class co.cask.cdap.api.schedule.Schedules
Get a builder used to create a schedule.
builder() - Static method in class co.cask.cdap.client.config.ClientConfig
 
builder() - Static method in class co.cask.cdap.client.config.ConnectionConfig
 
builder(ConnectionConfig) - Static method in class co.cask.cdap.client.config.ConnectionConfig
 
Bytes - Class in co.cask.cdap.api.common
Utility class that handles byte arrays, conversions to/from other types, comparisons, hash code generation, manufacturing keys for HashMaps or HashSets, etc.
Bytes() - Constructor for class co.cask.cdap.api.common.Bytes
 
Bytes.ByteArrayComparator - Class in co.cask.cdap.api.common
Byte array comparator class.
Bytes.ByteArrayComparator() - Constructor for class co.cask.cdap.api.common.Bytes.ByteArrayComparator
Constructor.
BYTES_COMPARATOR - Static variable in class co.cask.cdap.api.common.Bytes
Pass this to TreeMaps where byte [] are keys.

C

CacheConfig - Class in co.cask.cdap.etl.api
Cache configuration.
CacheConfig(long, int) - Constructor for class co.cask.cdap.etl.api.CacheConfig
 
CacheConfig() - Constructor for class co.cask.cdap.etl.api.CacheConfig
 
Callback - Interface in co.cask.cdap.api.flow.flowlet
Interface for flowlet to implement in order to receive callback on process result.
callServiceMethod(ServiceId, String) - Method in class co.cask.cdap.client.ServiceClient
Calls the non-versioned service endpoint for a given method and get routed to a specific version by the Router
canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
checkAvailability(Id.Service) - Method in class co.cask.cdap.client.ServiceClient
Deprecated.
since 4.0.0. Please use ServiceClient.checkAvailability(ServiceId) instead
checkAvailability(ServiceId) - Method in class co.cask.cdap.client.ServiceClient
Checks whether the Service is active.
checkpoint(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
checkSystemServices() - Method in class co.cask.cdap.test.IntegrationTestBase
 
childContext(Map<String, String>) - Method in interface co.cask.cdap.api.metrics.MetricsContext
Creates child MetricsContext that inherits the metrics context from this one and adds extra context information.
childContext(String, String) - Method in interface co.cask.cdap.api.metrics.MetricsContext
Convenience method that acts as MetricsContext.childContext(java.util.Map) by supplying single tag.
childContext(Map<String, String>) - Method in class co.cask.cdap.api.metrics.NoopMetricsContext
 
childContext(String, String) - Method in class co.cask.cdap.api.metrics.NoopMetricsContext
 
clear() - Method in class co.cask.cdap.test.IntegrationTestManager
 
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 interface co.cask.cdap.test.TestManager
Clear the state of app fabric, by removing all deployed applications, Datasets and Streams.
clear() - Method in class co.cask.cdap.test.UnitTestManager
 
clearState() - Method in class co.cask.cdap.etl.api.realtime.SourceState
Clear the internal state.
ClientConfig - Class in co.cask.cdap.client.config
Configuration for the Java client API
ClientConfig.Builder - Class in co.cask.cdap.client.config
Builder for ClientConfig.
ClientConfig.Builder() - Constructor for class co.cask.cdap.client.config.ClientConfig.Builder
 
ClientConfig.Builder(ClientConfig) - Constructor for class co.cask.cdap.client.config.ClientConfig.Builder
 
ClientLocalizationContext - Interface in co.cask.cdap.api
Context that adds the capability to localize resources in programs.
close() - Method in class co.cask.cdap.api.data.batch.RecordScanner
Close the record reader.
close() - Method in class co.cask.cdap.api.data.batch.SplitReader
Close the record reader.
close() - Method in class co.cask.cdap.api.data.batch.SplitReaderAdapter
 
close() - Method in class co.cask.cdap.api.data.batch.SplitReaderBase
 
close() - Method in class co.cask.cdap.api.dataset.lib.AbstractDataset
 
close() - Method in interface co.cask.cdap.api.dataset.lib.CloseableIterator
 
close() - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetAdmin
 
close() - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable.KeyValueScanner
 
close() - Method in interface co.cask.cdap.api.dataset.table.Scanner
Closes the scanner and releases any resources.
close() - Method in class co.cask.cdap.test.RemoteDatasetAdmin
 
CloseableIterator<T> - Interface in co.cask.cdap.api.dataset.lib
Iterator that can be closed.
co.cask.cdap.api - package co.cask.cdap.api
Interfaces for program and resource specifications, program lifecycle, runtime context and processors.
co.cask.cdap.api.annotation - package co.cask.cdap.api.annotation
Annotations used when creating Applications.
co.cask.cdap.api.app - package co.cask.cdap.api.app
An Application is a logical grouping of Streams, Datasets, Flows, and other deployable elements.
co.cask.cdap.api.artifact - package co.cask.cdap.api.artifact
Classes related to artifacts.
co.cask.cdap.api.builder - package co.cask.cdap.api.builder
Interfaces for constructing specifications.
co.cask.cdap.api.common - package co.cask.cdap.api.common
Commonly used utility functions.
co.cask.cdap.api.customaction - package co.cask.cdap.api.customaction
 
co.cask.cdap.api.data - package co.cask.cdap.api.data
Defines means of integration between programs and data access.
co.cask.cdap.api.data.batch - package co.cask.cdap.api.data.batch
Allows MapReduce jobs to read from and write to datasets.
co.cask.cdap.api.data.format - package co.cask.cdap.api.data.format
Defines data formats for use in programs and data exploration.
co.cask.cdap.api.data.schema - package co.cask.cdap.api.data.schema
This package contains beta classes for schema in CDAP.
co.cask.cdap.api.data.stream - package co.cask.cdap.api.data.stream
Stream specification and configuration.
co.cask.cdap.api.dataset - package co.cask.cdap.api.dataset
Defines APIs for accessing and managing data within CDAP.
co.cask.cdap.api.dataset.lib - package co.cask.cdap.api.dataset.lib
Collection of Dataset implementations available out-of-the-box in CDAP.
co.cask.cdap.api.dataset.lib.app.partitioned - package co.cask.cdap.api.dataset.lib.app.partitioned
 
co.cask.cdap.api.dataset.lib.cube - package co.cask.cdap.api.dataset.lib.cube
Implementation of a Cube dataset in CDAP.
co.cask.cdap.api.dataset.lib.partitioned - package co.cask.cdap.api.dataset.lib.partitioned
Implementation of classes which use partitioned datasets (such as partition consumers) in CDAP.
co.cask.cdap.api.dataset.metrics - package co.cask.cdap.api.dataset.metrics
Defines integration points for Datasets and Metrics system.
co.cask.cdap.api.dataset.module - package co.cask.cdap.api.dataset.module
Defines deployment of custom Datasets to make them available within CDAP.
co.cask.cdap.api.dataset.table - package co.cask.cdap.api.dataset.table
Provides access to the system-level table Datasets available within CDAP.
co.cask.cdap.api.flow - package co.cask.cdap.api.flow
Flow implementations.
co.cask.cdap.api.flow.flowlet - package co.cask.cdap.api.flow.flowlet
Interfaces used in flows and flowlets.
co.cask.cdap.api.logging - package co.cask.cdap.api.logging
 
co.cask.cdap.api.macro - package co.cask.cdap.api.macro
 
co.cask.cdap.api.mapreduce - package co.cask.cdap.api.mapreduce
Defines MapReduce jobs.
co.cask.cdap.api.messaging - package co.cask.cdap.api.messaging
Classes and interfaces for interacting with the Transactional Messaging System.
co.cask.cdap.api.metrics - package co.cask.cdap.api.metrics
Defines a way to collect user-defined metrics.
co.cask.cdap.api.plugin - package co.cask.cdap.api.plugin
Packages for plugins in CDAP.
co.cask.cdap.api.preview - package co.cask.cdap.api.preview
 
co.cask.cdap.api.retry - package co.cask.cdap.api.retry
 
co.cask.cdap.api.schedule - package co.cask.cdap.api.schedule
For running programs periodically.
co.cask.cdap.api.security.store - package co.cask.cdap.api.security.store
 
co.cask.cdap.api.service - package co.cask.cdap.api.service
Defines ServiceSpecification.
co.cask.cdap.api.service.http - package co.cask.cdap.api.service.http
Defines a service for handling HTTP requests.
co.cask.cdap.api.spark - package co.cask.cdap.api.spark
Defines APIs for defining Spark jobs in CDAP.
co.cask.cdap.api.stream - package co.cask.cdap.api.stream
Interfaces for stream interactions.
co.cask.cdap.api.webapp - package co.cask.cdap.api.webapp
For web application.
co.cask.cdap.api.worker - package co.cask.cdap.api.worker
Configuration and specification of workers in CDAP.
co.cask.cdap.api.workflow - package co.cask.cdap.api.workflow
For constructing workflows.
co.cask.cdap.client - package co.cask.cdap.client
 
co.cask.cdap.client.app - package co.cask.cdap.client.app
 
co.cask.cdap.client.config - package co.cask.cdap.client.config
 
co.cask.cdap.client.exception - package co.cask.cdap.client.exception
 
co.cask.cdap.client.util - package co.cask.cdap.client.util
 
co.cask.cdap.etl.api - package co.cask.cdap.etl.api
Packages for ETL Application Templates.
co.cask.cdap.etl.api.action - package co.cask.cdap.etl.api.action
 
co.cask.cdap.etl.api.batch - package co.cask.cdap.etl.api.batch
Interfaces for Spark plugins.
co.cask.cdap.etl.api.lookup - package co.cask.cdap.etl.api.lookup
Packages for ETL Application Templates.
co.cask.cdap.etl.api.realtime - package co.cask.cdap.etl.api.realtime
Packages for ETL Application Templates.
co.cask.cdap.etl.api.streaming - package co.cask.cdap.etl.api.streaming
 
co.cask.cdap.test - package co.cask.cdap.test
This package contains the public classes for unit tests.
COMBINED_LOG_FORMAT - Static variable in class co.cask.cdap.api.data.format.Formats
 
commit(ConsumerWorkingSet, List<? extends PartitionKey>) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
Removes the given partition keys from the working set, as they have been successfully processed.
commit(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
commitTx() - Method in class co.cask.cdap.api.dataset.lib.AbstractDataset
 
ComparableCodec - Class in co.cask.cdap.api.dataset.lib.partitioned
Responsible for serialization and deserialization of Comparable.
ComparableCodec() - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.ComparableCodec
 
compare(byte[], byte[]) - Method in class co.cask.cdap.api.common.Bytes.ByteArrayComparator
 
compareAndSwap(byte[], byte[], byte[], byte[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Perform a swap operation by primary key.
compareAndSwap(byte[], byte[], byte[]) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
Compares-and-swaps (atomically) the value of the specified row and column by looking for the specified expected value and, if found, replacing with the specified new value.
compareAndSwap(byte[], byte[], byte[], byte[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Compares-and-swaps (atomically) the value of the specified row and column by looking for an expected value and, if found, replacing it with the new value.
compareTo(ArtifactId) - Method in class co.cask.cdap.api.artifact.ArtifactId
 
compareTo(ArtifactVersion) - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
compareTo(byte[], byte[]) - Static method in class co.cask.cdap.api.common.Bytes
Lexicographically compare two arrays.
compareTo(byte[], int, int, byte[], int, int) - Static method in class co.cask.cdap.api.common.Bytes
Lexicographically compare two arrays.
compareTo(TimeValue) - Method in class co.cask.cdap.api.dataset.lib.cube.TimeValue
 
complete() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.ConsumablePartition
Marks the ProcessState as COMPLETED
complete() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
CompositeDatasetAdmin - Class in co.cask.cdap.api.dataset.lib
Implementation of DatasetAdmin that propagates administrative operations to the given list of DatasetAdmins
CompositeDatasetAdmin(Map<String, ? extends DatasetAdmin>) - Constructor for class co.cask.cdap.api.dataset.lib.CompositeDatasetAdmin
Constructor that takes list of dataset admins
CompositeDatasetDefinition<D extends Dataset> - Class in co.cask.cdap.api.dataset.lib
Handy implementation of DatasetDefinition that implements basic methods by delegating logic execution to underlying dataset definitions.
CompositeDatasetDefinition(String, Map<String, ? extends DatasetDefinition>) - Constructor for class co.cask.cdap.api.dataset.lib.CompositeDatasetDefinition
Constructor that takes an info about underlying datasets
CompositeDatasetDefinition(String, String, DatasetDefinition) - Constructor for class co.cask.cdap.api.dataset.lib.CompositeDatasetDefinition
Constructor that takes one underlying dataset.
CompositeDatasetDefinition(String, String, DatasetDefinition, String, DatasetDefinition) - Constructor for class co.cask.cdap.api.dataset.lib.CompositeDatasetDefinition
Constructor that takes two underlying datasets.
computeNext() - Method in class co.cask.cdap.api.dataset.lib.AbstractCloseableIterator
Returns the next element.
concat(byte[]...) - Static method in class co.cask.cdap.api.common.Bytes
Returns the values from each provided array combined into a single array.
ConcurrentPartitionConsumer - Class in co.cask.cdap.api.dataset.lib.partitioned
A PartitionConsumer that supports multiple instances consuming the same set of partitions by using a working set of partitions, and keeping track of their progress state during processing of those partitions.
ConcurrentPartitionConsumer(PartitionedFileSet, StatePersistor) - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
 
ConcurrentPartitionConsumer(PartitionedFileSet, StatePersistor, ConsumerConfiguration) - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
 
condition(Predicate<WorkflowContext>) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a condition to the Workflow.
condition(Predicate<WorkflowContext>) - Method in interface co.cask.cdap.api.workflow.WorkflowConditionConfigurer
Adds a nested condition to the current condition.
condition(Predicate<WorkflowContext>) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Adds a condition to the Workflow.
condition(Predicate<WorkflowContext>) - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Adds a condition to the current branch of the fork.
ConditionCodec - Class in co.cask.cdap.api.dataset.lib
Codec used to serialize and deserialize PartitionFilter.Conditions.
ConditionCodec() - Constructor for class co.cask.cdap.api.dataset.lib.ConditionCodec
 
Config - Class in co.cask.cdap.api
Configuration class of an configurable entity, such as Application.
Config() - Constructor for class co.cask.cdap.api.Config
 
ConfigTestApp - Class in co.cask.cdap.client.app
Test Application to test passing in Configuration during Application creation time.
ConfigTestApp() - Constructor for class co.cask.cdap.client.app.ConfigTestApp
 
ConfigTestApp.ConfigClass - Class in co.cask.cdap.client.app
Application Config Class.
ConfigTestApp.ConfigClass() - Constructor for class co.cask.cdap.client.app.ConfigTestApp.ConfigClass
 
ConfigTestApp.ConfigClass(String, String) - Constructor for class co.cask.cdap.client.app.ConfigTestApp.ConfigClass
 
ConfigurableProgramsApp - Class in co.cask.cdap.client.app
Test Application that will register different programs based on the config.
ConfigurableProgramsApp() - Constructor for class co.cask.cdap.client.app.ConfigurableProgramsApp
 
ConfigurableProgramsApp.Programs - Class in co.cask.cdap.client.app
Application Config Class.
ConfigurableProgramsApp.Programs() - Constructor for class co.cask.cdap.client.app.ConfigurableProgramsApp.Programs
 
ConfigurableProgramsApp.Programs(String, String, String, String) - Constructor for class co.cask.cdap.client.app.ConfigurableProgramsApp.Programs
 
ConfigurableProgramsApp2 - Class in co.cask.cdap.client.app
Test Application that will register different programs based on the config.
ConfigurableProgramsApp2() - Constructor for class co.cask.cdap.client.app.ConfigurableProgramsApp2
 
ConfigurableProgramsApp2.Programs - Class in co.cask.cdap.client.app
Application Config Class.
ConfigurableProgramsApp2.Programs() - Constructor for class co.cask.cdap.client.app.ConfigurableProgramsApp2.Programs
 
ConfigurableProgramsApp2.Programs(String, String, String, String, String) - Constructor for class co.cask.cdap.client.app.ConfigurableProgramsApp2.Programs
 
configure() - Method in class co.cask.cdap.api.app.AbstractApplication
Override this method to declare and configure the application.
configure(ApplicationConfigurer, ApplicationContext<T>) - Method in class co.cask.cdap.api.app.AbstractApplication
 
configure(ApplicationConfigurer, ApplicationContext<T>) - Method in interface co.cask.cdap.api.app.Application
Configures the Application.
configure(CustomActionConfigurer) - Method in class co.cask.cdap.api.customaction.AbstractCustomAction
 
configure() - Method in class co.cask.cdap.api.customaction.AbstractCustomAction
 
configure(CustomActionConfigurer) - Method in interface co.cask.cdap.api.customaction.CustomAction
Configure the custom action.
configure(Map<String, String>) - Method in class co.cask.cdap.api.data.format.RecordFormat
Configure the format with the given properties.
configure() - Method in class co.cask.cdap.api.data.stream.Stream
Configures Stream by returning a StreamSpecification.
configure(String, DatasetProperties) - Method in interface co.cask.cdap.api.dataset.DatasetDefinition
Configures new instance of the dataset.
configure() - Method in class co.cask.cdap.api.dataset.lib.app.partitioned.PartitionExploreCorrector
 
configure(String, DatasetProperties) - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetDefinition
 
configure(String, DatasetProperties) - Method in class co.cask.cdap.api.dataset.lib.IndexedTableDefinition
 
configure(FlowConfigurer) - Method in class co.cask.cdap.api.flow.AbstractFlow
 
configure() - Method in class co.cask.cdap.api.flow.AbstractFlow
Configure the Flow.
configure(FlowConfigurer) - Method in interface co.cask.cdap.api.flow.Flow
Configure the Flow using a FlowConfigurer.
configure(FlowletConfigurer) - Method in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
 
configure() - Method in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
Configure the Flowlet
configure(FlowletConfigurer) - Method in interface co.cask.cdap.api.flow.flowlet.Flowlet
Provides an interface to configure a Flowlet.
configure(MapReduceConfigurer) - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
 
configure() - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
Override this method to configure this MapReduce job.
configure(MapReduceConfigurer) - Method in interface co.cask.cdap.api.mapreduce.MapReduce
Configures a MapReduce job using the given MapReduceConfigurer.
configure(ServiceConfigurer) - Method in class co.cask.cdap.api.service.AbstractService
 
configure() - Method in class co.cask.cdap.api.service.AbstractService
Implements this method to configure this Service.
configure() - Method in class co.cask.cdap.api.service.BasicService
 
configure() - Method in class co.cask.cdap.api.service.http.AbstractHttpServiceHandler
This can be overridden in child classes to add custom user properties during configure time.
configure(HttpServiceConfigurer) - Method in class co.cask.cdap.api.service.http.AbstractHttpServiceHandler
configure(HttpServiceConfigurer) - Method in interface co.cask.cdap.api.service.http.HttpServiceHandler
Configures this HttpServiceHandler with the given HttpServiceConfigurer.
configure(ServiceConfigurer) - Method in interface co.cask.cdap.api.service.Service
Configure the Service by adding HttpServiceHandlers to handle requests.
configure() - Method in class co.cask.cdap.api.SingleRunnableApplication
 
configure(SparkConfigurer) - Method in class co.cask.cdap.api.spark.AbstractSpark
 
configure() - Method in class co.cask.cdap.api.spark.AbstractSpark
Override this method to configure this Spark job.
configure(SparkConfigurer) - Method in interface co.cask.cdap.api.spark.Spark
Configures a Spark job using the given SparkConfigurer.
configure(WorkerConfigurer) - Method in class co.cask.cdap.api.worker.AbstractWorker
 
configure() - Method in class co.cask.cdap.api.worker.AbstractWorker
Configures the worker.
configure(WorkerConfigurer) - Method in interface co.cask.cdap.api.worker.Worker
Configure a Worker.
configure(WorkflowConfigurer) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
 
configure() - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Override this method to configure this Workflow.
configure(WorkflowActionConfigurer) - Method in class co.cask.cdap.api.workflow.AbstractWorkflowAction
Deprecated.
 
configure() - Method in class co.cask.cdap.api.workflow.AbstractWorkflowAction
Deprecated.
Configure the WorkflowAction.
configure(WorkflowConfigurer) - Method in interface co.cask.cdap.api.workflow.Workflow
Configures a Workflow using the given WorkflowConfigurer.
configure(WorkflowActionConfigurer) - Method in interface co.cask.cdap.api.workflow.WorkflowAction
Deprecated.
Configures the WorkflowAction with the given WorkflowActionConfigurer.
configure() - Method in class co.cask.cdap.client.app.AppReturnsArgs
 
configure() - Method in class co.cask.cdap.client.app.ConfigTestApp
 
configure() - Method in class co.cask.cdap.client.app.ConfigurableProgramsApp
 
configure() - Method in class co.cask.cdap.client.app.ConfigurableProgramsApp2
 
configure() - Method in class co.cask.cdap.client.app.FakeApp
 
configure(String, DatasetProperties) - Method in class co.cask.cdap.client.app.FakeDatasetDefinition
 
configure() - Method in class co.cask.cdap.client.app.FakeFlow
 
configure() - Method in class co.cask.cdap.client.app.FakeSpark
 
configure(WorkflowConfigurer) - Method in class co.cask.cdap.client.app.FakeWorkflow
 
configure(String, DatasetProperties) - Method in class co.cask.cdap.client.app.StandaloneDatasetDefinition
 
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.action.Action
 
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.batch.BatchAggregator
Configure the pipeline.
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.batch.BatchConfigurable
 
configurePipeline(MultiInputPipelineConfigurer) - Method in class co.cask.cdap.etl.api.batch.BatchJoiner
Configure the pipeline.
configurePipeline(MultiInputPipelineConfigurer) - Method in class co.cask.cdap.etl.api.batch.MultiInputBatchConfigurable
 
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.batch.PostAction
Configure the pipeline.
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.batch.SparkCompute
Configure a pipeline.
configurePipeline(MultiInputPipelineConfigurer) - Method in interface co.cask.cdap.etl.api.MultiInputPipelineConfigurable
Configure an ETL pipeline, adding datasets and streams that the stage needs.
configurePipeline(PipelineConfigurer) - Method in interface co.cask.cdap.etl.api.PipelineConfigurable
Configure an ETL pipeline, adding datasets and streams that the stage needs.
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.realtime.RealtimeSink
 
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.realtime.RealtimeSource
 
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.streaming.StreamingSource
 
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.streaming.Windower
 
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.api.Transform
Configure an ETL pipeline.
ConflictDetection - Enum in co.cask.cdap.api.dataset.table
Conflict detection level of a table.
connect(String, String) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a source flowlet to a destination flowlet using their names.
connect(Flowlet, Flowlet) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a Flowlet instance to another Flowlet instance.
connect(String, Flowlet) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a Flowlet to another Flowlet
connect(Flowlet, String) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a Flowlet instance to another Flowlet.
connect(Flowlet, Flowlet) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a Flowlet instance to another Flowlet instance.
connect(String, String) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a source flowlet to a destination flowlet using their names.
connect(Flowlet, String) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a Flowlet instance to another Flowlet.
connect(String, Flowlet) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a Flowlet to another Flowlet
ConnectionConfig - Class in co.cask.cdap.client.config
Connection information to a CDAP instance.
ConnectionConfig(ConnectionConfig) - Constructor for class co.cask.cdap.client.config.ConnectionConfig
 
ConnectionConfig(String, int, boolean) - Constructor for class co.cask.cdap.client.config.ConnectionConfig
 
ConnectionConfig.Builder - Class in co.cask.cdap.client.config
Builder for ConnectionConfig.
ConnectionConfig.Builder() - Constructor for class co.cask.cdap.client.config.ConnectionConfig.Builder
 
ConnectionConfig.Builder(ConnectionConfig) - Constructor for class co.cask.cdap.client.config.ConnectionConfig.Builder
 
connectStream(String, Flowlet) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a Stream to a destination Flowlet
connectStream(String, String, Flowlet) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a Stream to a destination Flowlet
connectStream(String, String) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a Stream to a destination Flowlet
connectStream(String, String, String) - Method in class co.cask.cdap.api.flow.AbstractFlow
Connect a Stream to a destination Flowlet
connectStream(String, Flowlet) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a Stream to a destination Flowlet
connectStream(String, String, Flowlet) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a Stream to a destination Flowlet
connectStream(String, String) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a Stream to a destination Flowlet
connectStream(String, String, String) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Connect a Stream to a destination Flowlet
ConsumablePartition - Interface in co.cask.cdap.api.dataset.lib.partitioned
Represents a Partition available for consuming.
consumePartitions() - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
 
consumePartitions(int) - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
 
consumePartitions(PartitionAcceptor) - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
 
consumePartitions() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.PartitionConsumer
 
consumePartitions(int) - Method in interface co.cask.cdap.api.dataset.lib.partitioned.PartitionConsumer
 
consumePartitions(PartitionAcceptor) - Method in interface co.cask.cdap.api.dataset.lib.partitioned.PartitionConsumer
 
consumePartitions() - Method in class co.cask.cdap.api.dataset.lib.partitioned.TransactionalPartitionConsumer
 
consumePartitions(int) - Method in class co.cask.cdap.api.dataset.lib.partitioned.TransactionalPartitionConsumer
 
consumePartitions(PartitionAcceptor) - Method in class co.cask.cdap.api.dataset.lib.partitioned.TransactionalPartitionConsumer
 
consumePartitions(PartitionConsumerState) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Incrementally consumes partitions.
consumePartitions(PartitionConsumerState, int, Predicate<PartitionDetail>) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Incrementally consumes partitions.
ConsumerConfiguration - Class in co.cask.cdap.api.dataset.lib.partitioned
Configuration parameters to be used by a PartitionConsumer.
ConsumerConfiguration.Builder - Class in co.cask.cdap.api.dataset.lib.partitioned
A Builder to construct ConsumerConfiguration instances.
ConsumerWorkingSet - Class in co.cask.cdap.api.dataset.lib.partitioned
Keeps track of a list of partitions that are either available for consuming or are currently being consumed.
ConsumerWorkingSet() - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.ConsumerWorkingSet
Constructs an empty working set.
containsMacro(String) - Method in class co.cask.cdap.api.plugin.PluginConfig
Returns true if property value contains a macro; false otherwise.
convertAndSet(String, Date) - Method in class co.cask.cdap.api.data.format.StructuredRecord.Builder
Convert the given date into the type of the given field, and set the value for that field.
convertAndSet(String, Date, DateFormat) - Method in class co.cask.cdap.api.data.format.StructuredRecord.Builder
Convert the given date into the type of the given field, and set the value for that field.
convertAndSet(String, String) - Method in class co.cask.cdap.api.data.format.StructuredRecord.Builder
Convert the given string into the type of the given field, and set the value for that field.
convertKey(FROM_KEY) - Method in class co.cask.cdap.api.data.batch.SplitReaderAdapter
 
convertValue(FROM_VALUE) - Method in class co.cask.cdap.api.data.batch.SplitReaderAdapter
 
count(String, int) - Method in interface co.cask.cdap.api.metrics.Metrics
Increases the value of the specific metric by delta.
count(String, int) - Method in interface co.cask.cdap.etl.api.StageMetrics
Increases the value of the specific metric by delta.
CounterTimeseriesTable - Class in co.cask.cdap.api.dataset.lib
A Dataset for incrementing counts over time periods.
CounterTimeseriesTable(DatasetSpecification, Table) - Constructor for class co.cask.cdap.api.dataset.lib.CounterTimeseriesTable
Creates an instance of the DataSet.
CounterTimeseriesTable.Counter - Class in co.cask.cdap.api.dataset.lib
Defines an object for counters in CounterTimeseriesTable.
CounterTimeseriesTableDefinition - Class in co.cask.cdap.api.dataset.lib
CounterTimeseriesTableDefinition(String, DatasetDefinition<? extends Table, ?>) - Constructor for class co.cask.cdap.api.dataset.lib.CounterTimeseriesTableDefinition
 
create() - Method in class co.cask.cdap.api.data.stream.StreamSpecification.Builder
Create StreamSpecification.
create() - Method in interface co.cask.cdap.api.dataset.DatasetAdmin
Creates dataset.
create() - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetAdmin
 
create(Id.DatasetInstance, DatasetInstanceConfiguration) - Method in class co.cask.cdap.client.DatasetClient
create(DatasetId, DatasetInstanceConfiguration) - Method in class co.cask.cdap.client.DatasetClient
Creates a dataset.
create(Id.DatasetInstance, String) - Method in class co.cask.cdap.client.DatasetClient
Deprecated.
since 4.0.0. Use DatasetClient.create(DatasetId, String) instead.
create(DatasetId, String) - Method in class co.cask.cdap.client.DatasetClient
Creates a dataset.
create(Id.Stream) - Method in class co.cask.cdap.client.StreamClient
Deprecated.
since 4.0.0. Use StreamClient.create(StreamId) instead.
create(StreamId) - Method in class co.cask.cdap.client.StreamClient
Creates a stream.
create(Id.Stream, StreamProperties) - Method in class co.cask.cdap.client.StreamClient
Deprecated.
create(StreamId, StreamProperties) - Method in class co.cask.cdap.client.StreamClient
Creates a stream with StreamProperties properties.
create() - Method in class co.cask.cdap.test.RemoteDatasetAdmin
 
createBatchWriter(String, String) - Method in interface co.cask.cdap.api.data.stream.StreamWriter
Writes in batch using StreamBatchWriter to a stream
createDataSchedule(Schedules.Source, String, int) - Method in class co.cask.cdap.api.schedule.Schedules.Builder
Create a data schedule that runs where a certain amount of data is available.
createDataset(String, String, DatasetProperties) - Method in interface co.cask.cdap.api.dataset.DatasetManager
Create a new dataset instance.
createDataset(String, String, DatasetProperties) - Method in interface co.cask.cdap.api.DatasetConfigurer
Adds a Dataset instance, created automatically if absent in the CDAP namespace.
createDataset(String, String) - Method in interface co.cask.cdap.api.DatasetConfigurer
Adds a Dataset instance with DatasetProperties.EMPTY created automatically if absent in the CDAP namespace.
createDataset(String, Class<? extends Dataset>, DatasetProperties) - Method in interface co.cask.cdap.api.DatasetConfigurer
Deploys a Dataset type using the datasetClass parameter (see DatasetConfigurer.addDatasetType(Class)), then adds a Dataset instance, if absent in the CDAP namespace, or if the Dataset instance already exists, updates the existing instance with the new properties.
createDataset(String, Class<? extends Dataset>) - Method in interface co.cask.cdap.api.DatasetConfigurer
Deploys a Dataset type using the datasetClass parameter (see DatasetConfigurer.addDatasetType(Class)), then adds a Dataset instance, if absent in the CDAP namespace, or if the Dataset instance already exists, updates the existing instance with empty properties.
createDataset(String, String, DatasetProperties) - Method in interface co.cask.cdap.etl.api.batch.BatchContext
Create a new dataset instance.
createFilter(Principal) - Method in class co.cask.cdap.client.AuthorizationClient
 
createIndexedObjectStore(ApplicationConfigurer, String, Type, DatasetProperties) - Static method in class co.cask.cdap.api.dataset.lib.ObjectStores
Adds IndexedObjectStore dataset to be created at application deploy if not exists.
createIndexedObjectStore(ApplicationConfigurer, String, Type) - Static method in class co.cask.cdap.api.dataset.lib.ObjectStores
createIterator(Split) - Method in class co.cask.cdap.api.data.batch.IteratorBasedSplitReader
Creates an iterator to iterate through all records of a given split.
createIterator(Split) - Method in class co.cask.cdap.api.dataset.lib.TimeseriesTable.TimeseriesTableRecordsReader
 
createKey(SecureKeyId, SecureKeyCreateRequest) - Method in class co.cask.cdap.client.SecureStoreClient
Creates a secure key
createLocalDataset(String, String, DatasetProperties) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a local dataset instance to the Workflow.
createLocalDataset(String, String) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a local dataset instance with DatasetProperties.EMPTY to the Workflow.
createLocalDataset(String, Class<? extends Dataset>, DatasetProperties) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a local dataset instance to the Workflow.
createLocalDataset(String, Class<? extends Dataset>) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a local dataset instance with DatasetProperties.EMPTY to the Workflow.
createLocalDataset(String, String, DatasetProperties) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Adds a local dataset instance to the Workflow.
createLocalDataset(String, Class<? extends Dataset>, DatasetProperties) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Adds a local dataset instance to the Workflow.
createNamespace(String) - Method in class co.cask.cdap.test.IntegrationTestBase
Deprecated.
createNamespace(NamespaceMeta) - Method in class co.cask.cdap.test.IntegrationTestManager
 
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 interface co.cask.cdap.test.TestManager
Deprecated.
since 3.4.0. Use NamespaceAdmin exposed by TestBase for namespace operations.
createNamespace(NamespaceMeta) - Method in class co.cask.cdap.test.UnitTestManager
 
createObjectStore(ApplicationConfigurer, String, Type, DatasetProperties) - Static method in class co.cask.cdap.api.dataset.lib.ObjectStores
Adds an ObjectStore dataset to be created at application deploy if it does not exist.
createObjectStore(ApplicationConfigurer, String, Type) - Static method in class co.cask.cdap.api.dataset.lib.ObjectStores
createOrUpdate(Id.Stream.View, ViewSpecification) - Method in class co.cask.cdap.client.StreamViewClient
createOrUpdate(StreamViewId, ViewSpecification) - Method in class co.cask.cdap.client.StreamViewClient
Creates or updates a view.
createRole(Role) - Method in class co.cask.cdap.client.AuthorizationClient
 
createSplitReader(Split) - Method in interface co.cask.cdap.api.data.batch.BatchReadable
Creates a reader for the split of a dataset.
createSplitReader(Split) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
createSplitReader(Split) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
 
createSplitReader(Split) - Method in class co.cask.cdap.api.dataset.lib.TimeseriesTable
 
createSplitReader(Split) - Method in class co.cask.cdap.client.app.FakeDataset
 
createSplitReader(Split) - Method in class co.cask.cdap.client.app.StandaloneDataset
 
createSplitRecordScanner(Split) - Method in interface co.cask.cdap.api.data.batch.RecordScannable
Creates a reader for the split of a dataset.
createSplitRecordScanner(Split) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
createSplitRecordScanner(Split) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
 
createSplitRecordScanner(Split) - Method in class co.cask.cdap.client.app.FakeDataset
 
createSplitRecordScanner(Split) - Method in class co.cask.cdap.client.app.StandaloneDataset
 
createStream() - Method in interface co.cask.cdap.test.StreamManager
Create the stream.
createTable(ApplicationConfigurer, String, int) - Static method in class co.cask.cdap.api.dataset.lib.TimeseriesTables
Adds TimeseriesTable data set to be created at application deploy if not exists.
createTable(ApplicationConfigurer, String) - Static method in class co.cask.cdap.api.dataset.table.Tables
Adds Table data set to be created at application deploy if not exists.
createTable(ApplicationConfigurer, String, int) - Static method in class co.cask.cdap.api.dataset.table.Tables
Adds Table data set to be created at application deploy if not exists.
createTable(ApplicationConfigurer, String, ConflictDetection) - Static method in class co.cask.cdap.api.dataset.table.Tables
Adds Table data set to be created at application deploy if not exists.
createTable(ApplicationConfigurer, String, ConflictDetection, int) - Static method in class co.cask.cdap.api.dataset.table.Tables
Adds Table data set to be created at application deploy if not exists.
createTable(ApplicationConfigurer, String, ConflictDetection, int, DatasetProperties) - Static method in class co.cask.cdap.api.dataset.table.Tables
Adds Table data set to be created at application deploy if not exists.
createTimeSchedule(String) - Method in class co.cask.cdap.api.schedule.Schedules.Builder
Create a time schedule based on the specified cron expression.
createTopic(String) - Method in interface co.cask.cdap.api.messaging.MessagingAdmin
Creates a new topic with the default topic properties.
createTopic(String, Map<String, String>) - Method in interface co.cask.cdap.api.messaging.MessagingAdmin
Creates a new topic.
Creator<T> - Interface in co.cask.cdap.api.builder
 
CSV - Static variable in class co.cask.cdap.api.data.format.Formats
 
Cube - Interface in co.cask.cdap.api.dataset.lib.cube
Cube data set.
CubeDeleteQuery - Class in co.cask.cdap.api.dataset.lib.cube
Defines a query for deleting data in Cube.
CubeDeleteQuery(long, long, int, Map<String, String>, Collection<String>) - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
Creates instance of CubeDeleteQuery that defines selection of data to delete from Cube.
CubeDeleteQuery(long, long, int, Map<String, String>, String) - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
Creates instance of CubeDeleteQuery that defines selection of data to delete from Cube.
CubeDeleteQuery(long, long, int, Map<String, String>) - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
Creates instance of CubeDeleteQuery that defines selection of data to delete from Cube.
CubeExploreQuery - Class in co.cask.cdap.api.dataset.lib.cube
Defines a query to perform exploration of the Cube data, e.g.
CubeExploreQuery(long, long, int, int, List<DimensionValue>) - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
Creates instance of CubeExploreQuery that defines selection of data of Cube to explore in.
CubeExploreQuery.Builder - Class in co.cask.cdap.api.dataset.lib.cube
CubeExploreQuery.Builder() - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery.Builder
 
CubeExploreQuery.Builder.Build - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeExploreQuery.
CubeExploreQuery.Builder.Dimension - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeExploreQuery.
CubeExploreQuery.Builder.From - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeExploreQuery.
CubeExploreQuery.Builder.Limit - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeExploreQuery.
CubeExploreQuery.Builder.Where - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeExploreQuery.
CubeFact - Class in co.cask.cdap.api.dataset.lib.cube
Time-based measurement with associated dimensionValues (dimensions) to be stored in Cube.
CubeFact(long) - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeFact
Creates an instance of CubeFact with no dimensionValues and no measurements.
CubeQuery - Class in co.cask.cdap.api.dataset.lib.cube
Defines a query to perform on Cube data.
CubeQuery(String, long, long, int, int, Map<String, AggregationFunction>, Map<String, String>, List<String>, Interpolator) - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeQuery
Creates CubeQuery with given parameters.
CubeQuery.Builder - Class in co.cask.cdap.api.dataset.lib.cube
Builds CubeQuery.
CubeQuery.Builder() - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder
 
CubeQuery.Builder.Build - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.Dimension - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.From - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.GroupBy - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.GroupByDimension - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.Limit - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.Measurement - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.Select - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CubeQuery.Builder.Where - Class in co.cask.cdap.api.dataset.lib.cube
Builder for configuring CubeQuery.
CustomAction - Interface in co.cask.cdap.api.customaction
Defines custom action in the Workflow.
CustomActionConfigurer - Interface in co.cask.cdap.api.customaction
Configurer for configuring the CustomAction in the Workflow.
CustomActionContext - Interface in co.cask.cdap.api.customaction
Represents runtime context of the CustomAction in the Workflow.
CustomActionSpecification - Interface in co.cask.cdap.api.customaction
Specification for the custom java code that will be executed as a part of Workflow.

D

DATA_EXTERNAL - Static variable in class co.cask.cdap.api.dataset.lib.FileSetProperties
Whether the files in the dataset are "external", that is, managed by an external process.
DATA_POSSESS_EXISTING - Static variable in class co.cask.cdap.api.dataset.lib.FileSetProperties
If true, the file set will use an existing directory as its base path and an existing Explore table, and it will take possession of them.
DATA_USE_EXISTING - Static variable in class co.cask.cdap.api.dataset.lib.FileSetProperties
If true, the file set will use an existing directory as its base path and an existing Explore table.
Dataset - Interface in co.cask.cdap.api.dataset
Implementations of this class perform data operations on dataset instance.
DatasetAdmin - Interface in co.cask.cdap.api.dataset
Defines the minimum administrative operations a dataset should support.
DatasetClient - Class in co.cask.cdap.client
Provides ways to interact with CDAP Datasets.
DatasetClient(ClientConfig, RESTClient) - Constructor for class co.cask.cdap.client.DatasetClient
 
DatasetClient(ClientConfig) - Constructor for class co.cask.cdap.client.DatasetClient
 
DatasetConfigurer - Interface in co.cask.cdap.api
Provides the ability to add stream, datasets.
DatasetContext - Interface in co.cask.cdap.api.data
This interface provides methods that instantiate or dismiss a Dataset during the runtime of a program.
DatasetContext - Class in co.cask.cdap.api.dataset
Provides access to the context for a dataset including its environment and configuration
DatasetDefinition<D extends Dataset,A extends DatasetAdmin> - Interface in co.cask.cdap.api.dataset
Defines named dataset type implementation.
DatasetDefinitionRegistry - Interface in co.cask.cdap.api.dataset.module
Registry of dataset definitions and other components in a Datasets System.
DataSetException - Exception in co.cask.cdap.api.dataset
Thrown when a data operation fails.
DataSetException(String) - Constructor for exception co.cask.cdap.api.dataset.DataSetException
 
DataSetException(String, Throwable) - Constructor for exception co.cask.cdap.api.dataset.DataSetException
 
datasetExists(String) - Method in interface co.cask.cdap.api.dataset.DatasetManager
Check whether a dataset exists in the current namespace.
datasetExists(String) - Method in interface co.cask.cdap.etl.api.batch.BatchContext
Check whether a dataset exists in the current namespace.
DatasetInstantiationException - Exception in co.cask.cdap.api.data
This exception is thrown if - for whatever reason - a data set cannot be instantiated at runtime.
DatasetInstantiationException(String, Throwable) - Constructor for exception co.cask.cdap.api.data.DatasetInstantiationException
 
DatasetInstantiationException(String) - Constructor for exception co.cask.cdap.api.data.DatasetInstantiationException
 
DatasetManagementException - Exception in co.cask.cdap.api.dataset
Thrown when there's an error during dataset modules, types or instances management operations.
DatasetManagementException(String) - Constructor for exception co.cask.cdap.api.dataset.DatasetManagementException
 
DatasetManagementException(String, Throwable) - Constructor for exception co.cask.cdap.api.dataset.DatasetManagementException
 
DatasetManager - Interface in co.cask.cdap.api.dataset
Provides dataset management functions.
DataSetManager<T> - Interface in co.cask.cdap.test
Instances of this class are for managing Datasets.
DatasetModule - Interface in co.cask.cdap.api.dataset.module
Implementation of DatasetModule announces dataset types and other components to the system.
DatasetModuleClient - Class in co.cask.cdap.client
Provides ways to interact with CDAP Dataset modules.
DatasetModuleClient(ClientConfig, RESTClient) - Constructor for class co.cask.cdap.client.DatasetModuleClient
 
DatasetModuleClient(ClientConfig) - Constructor for class co.cask.cdap.client.DatasetModuleClient
 
DatasetOutputCommitter - Interface in co.cask.cdap.api.data.batch
This interface is implemented by a dataset if at the end of a batch job (MapReduce, Spark, ...) the output needs to be committed, or rolled back, depending on success of the job.
DatasetProperties - Class in co.cask.cdap.api.dataset
Dataset instance properties.
DatasetProperties.Builder - Class in co.cask.cdap.api.dataset
A Builder to construct DatasetProperties instances.
DatasetProperties.Builder() - Constructor for class co.cask.cdap.api.dataset.DatasetProperties.Builder
 
datasets(DatasetSpecification...) - Method in class co.cask.cdap.api.dataset.DatasetSpecification.Builder
Add underlying dataset specs.
datasets(Collection<? extends DatasetSpecification>) - Method in class co.cask.cdap.api.dataset.DatasetSpecification.Builder
Add underlying dataset specs.
DatasetSpecification - Class in co.cask.cdap.api.dataset
A DatasetSpecification is a hierarchical meta data object that contains all meta data needed to instantiate a dataset at runtime.
DatasetSpecification.Builder - Class in co.cask.cdap.api.dataset
A Builder to construct DatasetSpecification instances.
DatasetStatePersistor - Interface in co.cask.cdap.api.dataset.lib
Defines how some state will be persisted/managed, using a DatasetContext to read and persist state.
DatasetType - Annotation Type in co.cask.cdap.api.dataset.module
Annotation to declare a dataset type from Dataset.
DatasetTypeClient - Class in co.cask.cdap.client
Provides ways to interact with CDAP Dataset types.
DatasetTypeClient(ClientConfig, RESTClient) - Constructor for class co.cask.cdap.client.DatasetTypeClient
 
DatasetTypeClient(ClientConfig) - Constructor for class co.cask.cdap.client.DatasetTypeClient
 
DataTracer - Interface in co.cask.cdap.api.preview
Interface used by the CDAP applications to trace the data.
DataWriter - Interface in co.cask.cdap.etl.api.realtime
Used in Realtime Sink to write to CDAP Streams and Datasets.
decode(StreamEvent, StreamEventDecoder.DecodeResult<K, V>) - Method in interface co.cask.cdap.api.stream.StreamEventDecoder
Decode a StreamEvent.
DEFAULT - Static variable in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerConfiguration
Instance of ConsumerConfiguration with default parameters
DEFAULT - Static variable in class co.cask.cdap.client.config.ConnectionConfig
 
DEFAULT_COLUMN_FAMILY - Static variable in interface co.cask.cdap.api.dataset.table.Table
The default column family.
DEFAULT_MAX_ALLOWED_GAP - Static variable in class co.cask.cdap.api.dataset.lib.cube.Interpolators
 
DEFAULT_MAX_RETRIES - Static variable in annotation type co.cask.cdap.api.annotation.ProcessInput
 
DEFAULT_OUTPUT - Static variable in class co.cask.cdap.api.flow.FlowletDefinition
 
DEFAULT_STREAM - Static variable in class co.cask.cdap.client.app.ConfigTestApp
 
DEFAULT_TABLE - Static variable in class co.cask.cdap.client.app.ConfigTestApp
 
DEFAULT_TYPE - Static variable in annotation type co.cask.cdap.api.annotation.Plugin
Default plugin type name.
DEFAULT_TYPE_NAME - Static variable in annotation type co.cask.cdap.api.dataset.module.EmbeddedDataset
 
DefaultConsumablePartition - Class in co.cask.cdap.api.dataset.lib.partitioned
Default implementation of ConsumablePartition.
DefaultConsumablePartition(PartitionKey) - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
DefaultConsumablePartition(PartitionKey, ProcessState, long, int) - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
DefaultMapReduceManager - Class in co.cask.cdap.test
A default implementation of MapReduceManager.
DefaultMapReduceManager(Id.Program, ApplicationManager) - Constructor for class co.cask.cdap.test.DefaultMapReduceManager
 
DefaultSparkManager - Class in co.cask.cdap.test
A default implementation of SparkManager.
DefaultSparkManager(Id.Program, ApplicationManager) - Constructor for class co.cask.cdap.test.DefaultSparkManager
 
delegates - Variable in class co.cask.cdap.api.dataset.lib.CompositeDatasetAdmin
 
DelegatingStatePersistor - Class in co.cask.cdap.api.dataset.lib.partitioned
An implementation of StatePersistor that uses a DatasetContext to read and persist state.
DelegatingStatePersistor(DatasetContext, DatasetStatePersistor) - Constructor for class co.cask.cdap.api.dataset.lib.partitioned.DelegatingStatePersistor
 
delete(CubeDeleteQuery) - Method in interface co.cask.cdap.api.dataset.lib.cube.Cube
Deletes the data specified by CubeQuery from all the fact tables.
delete(Delete) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Perform a delete on the data table.
delete(byte[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
delete(byte[], byte[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
delete(byte[], byte[][]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
delete(byte[]) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
Delete a key.
delete(String) - Method in interface co.cask.cdap.api.dataset.lib.ObjectMappedTable
Delete the object for the specified key.
delete(byte[]) - Method in interface co.cask.cdap.api.dataset.lib.ObjectMappedTable
Delete the object for the specified key.
delete(byte[]) - Method in interface co.cask.cdap.api.dataset.lib.ObjectStore
Delete the object for the specified key.
Delete - Class in co.cask.cdap.api.dataset.table
A Delete removes one, multiple, or all columns from a row.
Delete(byte[]) - Constructor for class co.cask.cdap.api.dataset.table.Delete
Delete whole row.
Delete(byte[], byte[]...) - Constructor for class co.cask.cdap.api.dataset.table.Delete
Delete a set of columns from a row.
Delete(byte[], Collection<byte[]>) - Constructor for class co.cask.cdap.api.dataset.table.Delete
Delete a set of columns from a row.
Delete(String) - Constructor for class co.cask.cdap.api.dataset.table.Delete
Delete a whole row.
Delete(String, String...) - Constructor for class co.cask.cdap.api.dataset.table.Delete
Delete a set of columns from a row.
Delete(String, Collection<String>) - Constructor for class co.cask.cdap.api.dataset.table.Delete
Delete a set of columns from a row.
delete(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Deletes all columns of the specified row.
delete(byte[], byte[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Deletes specified column of the specified row.
delete(byte[], byte[][]) - Method in interface co.cask.cdap.api.dataset.table.Table
Deletes specified columns of the specified row.
delete(Delete) - Method in interface co.cask.cdap.api.dataset.table.Table
Deletes columns of a row as defined by the Delete parameter.
delete(MetricDeleteQuery) - Method in interface co.cask.cdap.api.metrics.MetricStore
Deletes all metric data specified by the MetricDeleteQuery
delete(Id.Application) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
since 4.0.0. Please use () instead
delete(ApplicationId) - Method in class co.cask.cdap.client.ApplicationClient
Deletes an application.
delete(Id.Artifact) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
since 4.0.0. Use ArtifactClient.delete(ArtifactId) instead.
delete(ArtifactId) - Method in class co.cask.cdap.client.ArtifactClient
Delete an artifact.
delete(Id.DatasetInstance) - Method in class co.cask.cdap.client.DatasetClient
Deprecated.
since 4.0.0. Use DatasetClient.delete(DatasetId) instead.
delete(DatasetId) - Method in class co.cask.cdap.client.DatasetClient
Deletes a dataset.
delete(Id.DatasetModule) - Method in class co.cask.cdap.client.DatasetModuleClient
Deprecated.
delete(DatasetModuleId) - Method in class co.cask.cdap.client.DatasetModuleClient
Deletes a dataset module.
delete(ScheduleId) - Method in class co.cask.cdap.client.ScheduleClient
 
delete(Id.Stream) - Method in class co.cask.cdap.client.StreamClient
Deprecated.
since 4.0.0. Use StreamClient.delete(StreamId) instead.
delete(StreamId) - Method in class co.cask.cdap.client.StreamClient
Deletes a stream.
delete(Id.Stream.View) - Method in class co.cask.cdap.client.StreamViewClient
Deprecated.
since 4.0.0. Use StreamViewClient.delete(StreamViewId) instead.
delete(StreamViewId) - Method in class co.cask.cdap.client.StreamViewClient
Deletes a view.
delete() - Method in interface co.cask.cdap.test.ApplicationManager
Deletes the application;
delete() - Method in interface co.cask.cdap.test.ArtifactManager
Delete the artifact
deleteAll() - Method in interface co.cask.cdap.api.metrics.MetricStore
Deletes all metrics data.
deleteAll(Id.Namespace) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
deleteAll(NamespaceId) - Method in class co.cask.cdap.client.ApplicationClient
Deletes all applications in a namespace.
deleteAll(Id.Namespace) - Method in class co.cask.cdap.client.DatasetModuleClient
Deprecated.
deleteAll(NamespaceId) - Method in class co.cask.cdap.client.DatasetModuleClient
Deletes all dataset modules in a namespace.
deleteAllApplications(NamespaceId) - Method in class co.cask.cdap.test.IntegrationTestManager
 
deleteAllApplications(NamespaceId) - Static method in class co.cask.cdap.test.TestBase
Deletes all applications in the specified namespace.
deleteAllApplications(NamespaceId) - Method in interface co.cask.cdap.test.TestManager
Removes all apps in the specified namespace.
deleteAllApplications(NamespaceId) - Method in class co.cask.cdap.test.UnitTestManager
 
deleteApplicationPreferences(Id.Application) - Method in class co.cask.cdap.client.PreferencesClient
deleteApplicationPreferences(ApplicationId) - Method in class co.cask.cdap.client.PreferencesClient
Deletes Preferences at the Application Level.
deleteArtifact(Id.Artifact) - Method in class co.cask.cdap.test.IntegrationTestManager
 
deleteArtifact(Id.Artifact) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
since 3.4.0. Use ArtifactManager.delete() instead
deleteArtifact(Id.Artifact) - Method in class co.cask.cdap.test.UnitTestManager
 
deleteBefore(long) - Method in interface co.cask.cdap.api.metrics.MetricStore
Deletes all metric data before given timestamp.
deleteDatasetInstance(NamespaceId, String) - Method in class co.cask.cdap.test.AbstractTestManager
 
deleteDatasetInstance(DatasetId) - Method in class co.cask.cdap.test.IntegrationTestManager
 
deleteDatasetInstance(NamespaceId, String) - Method in class co.cask.cdap.test.TestBase
Deprecated.
deleteDatasetInstance(DatasetId) - Method in class co.cask.cdap.test.TestBase
Deletes an instance of dataset.
deleteDatasetInstance(NamespaceId, String) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
deleteDatasetInstance(DatasetId) - Method in interface co.cask.cdap.test.TestManager
Deletes an instance of dataset
deleteDatasetInstance(DatasetId) - Method in class co.cask.cdap.test.UnitTestManager
 
deleteInstancePreferences() - Method in class co.cask.cdap.client.PreferencesClient
Deletes Preferences at the Instance Level.
deleteKey(SecureKeyId) - Method in class co.cask.cdap.client.SecureStoreClient
Delete the secure key
deleteNamespace(Id.Namespace) - Method in class co.cask.cdap.test.IntegrationTestManager
 
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 interface co.cask.cdap.test.TestManager
Deprecated.
since 3.4.0. Use NamespaceAdmin exposed by TestBase for namespace operations.
deleteNamespace(Id.Namespace) - Method in class co.cask.cdap.test.UnitTestManager
 
deleteNamespacePreferences(Id.Namespace) - Method in class co.cask.cdap.client.PreferencesClient
Deprecated.
deleteNamespacePreferences(NamespaceId) - Method in class co.cask.cdap.client.PreferencesClient
Deletes Preferences at the Namespace Level.
deleteProgramPreferences(Id.Program) - Method in class co.cask.cdap.client.PreferencesClient
Deprecated.
deleteProgramPreferences(ProgramId) - Method in class co.cask.cdap.client.PreferencesClient
Deletes Preferences at the Program Level.
deleteProperties(Id.Artifact) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
deleteProperties(ArtifactId) - Method in class co.cask.cdap.client.ArtifactClient
Delete all properties for an artifact.
deleteProperty(Id.Artifact, String) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
deleteProperty(ArtifactId, String) - Method in class co.cask.cdap.client.ArtifactClient
Delete a property for an artifact.
deleteRouteConfig(ServiceId) - Method in class co.cask.cdap.client.ServiceClient
Deletes RouteConfig of a service with different application versions.
deleteSecureData(String, String) - Method in interface co.cask.cdap.api.security.store.SecureStoreManager
Deletes the element with the given name.
deleteTopic(String) - Method in interface co.cask.cdap.api.messaging.MessagingAdmin
Deletes a topic.
deleteWorkflowLocalDatasets(ProgramRunId) - Method in class co.cask.cdap.client.WorkflowClient
 
deploy(Id.Namespace, File) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
deploy(NamespaceId, File) - Method in class co.cask.cdap.client.ApplicationClient
Deploys an application.
deploy(Id.Namespace, File, String) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
deploy(NamespaceId, File, String) - Method in class co.cask.cdap.client.ApplicationClient
Deploys an application with a serialized application configuration string.
deploy(NamespaceId, File, String, String) - Method in class co.cask.cdap.client.ApplicationClient
Deploys an application with a serialized application configuration string and an owner.
deploy(Id.Namespace, File, Config) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
deploy(NamespaceId, File, Config) - Method in class co.cask.cdap.client.ApplicationClient
Deploys an application with an application configuration object.
deploy(Id.Application, AppRequest<?>) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
deploy(ApplicationId, AppRequest<?>) - Method in class co.cask.cdap.client.ApplicationClient
Creates an application with a version using an existing artifact.
deployApplication(Id.Namespace, Class<? extends Application>, File...) - Method in class co.cask.cdap.test.AbstractTestManager
 
deployApplication(Id.Namespace, Class<? extends Application>, Config, File...) - Method in class co.cask.cdap.test.AbstractTestManager
 
deployApplication(Id.Application, AppRequest) - Method in class co.cask.cdap.test.AbstractTestManager
 
deployApplication(NamespaceId, Class<? extends Application>, File...) - Method in class co.cask.cdap.test.AbstractTestManager
 
deployApplication(Id.Namespace, Class<? extends Application>, File...) - Method in class co.cask.cdap.test.IntegrationTestBase
Deprecated.
deployApplication(NamespaceId, 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(ApplicationId, AppRequest) - Method in class co.cask.cdap.test.IntegrationTestBase
 
deployApplication(NamespaceId, Class<? extends Application>, Config, File...) - Method in class co.cask.cdap.test.IntegrationTestManager
 
deployApplication(ApplicationId, AppRequest) - Method in class co.cask.cdap.test.IntegrationTestManager
 
deployApplication(Id.Namespace, Class<? extends Application>, File...) - Static method in class co.cask.cdap.test.TestBase
Deprecated.
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
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(Id.Namespace, Class<? extends Application>, File...) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
deployApplication(NamespaceId, Class<? extends Application>, File...) - Method in interface co.cask.cdap.test.TestManager
Deploys an Application.
deployApplication(Id.Namespace, Class<? extends Application>, Config, File...) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
deployApplication(NamespaceId, Class<? extends Application>, Config, File...) - Method in interface co.cask.cdap.test.TestManager
Deploys an Application.
deployApplication(Id.Application, AppRequest) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
deployApplication(ApplicationId, AppRequest) - Method in interface co.cask.cdap.test.TestManager
Creates an Application with a version using an existing artifact.
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>) - Method in class co.cask.cdap.test.AbstractTestManager
 
deployDatasetModule(DatasetModuleId, Class<? extends DatasetModule>) - Method in class co.cask.cdap.test.IntegrationTestManager
 
deployDatasetModule(Id.Namespace, String, Class<? extends DatasetModule>) - Static method in class co.cask.cdap.test.TestBase
Deprecated.
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(Id.Namespace, String, Class<? extends DatasetModule>) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
deployDatasetModule(DatasetModuleId, Class<? extends DatasetModule>) - Method in interface co.cask.cdap.test.TestManager
Deploys DatasetModule.
deployDatasetModule(DatasetModuleId, Class<? extends DatasetModule>) - Method in class co.cask.cdap.test.UnitTestManager
 
Description - Annotation Type in co.cask.cdap.api.annotation
Annotates the description for the element.
DescriptionSetter<T> - Interface in co.cask.cdap.api.builder
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.cdap.api.dataset.lib.ConditionCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.cdap.api.dataset.lib.partitioned.PartitionKeyCodec
 
deserializeComparable(JsonElement, JsonDeserializationContext) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ComparableCodec
 
destroy() - Method in class co.cask.cdap.api.customaction.AbstractCustomAction
 
destroy() - Method in class co.cask.cdap.api.dataset.lib.DynamicPartitioner
Destroys a DynamicPartitioner.
destroy() - Method in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
 
destroy() - Method in interface co.cask.cdap.api.flow.flowlet.Flowlet
Destroy is the last thing that gets called before the flowlet is shutdown.
destroy() - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
Classes derived from AbstractMapReduce can override this method to destroy the MapReduce.
destroy() - Method in interface co.cask.cdap.api.ProgramLifecycle
Destroy is the last thing that gets called before the program is shutdown.
destroy() - Method in class co.cask.cdap.api.service.http.AbstractHttpServiceHandler
An implementation of HttpServiceHandler.destroy() which does nothing
destroy() - Method in interface co.cask.cdap.api.service.http.HttpServiceHandler
Invoked whenever an instance of this HttpServiceHandler is destroyed.
destroy() - Method in class co.cask.cdap.api.spark.AbstractSpark
 
destroy() - Method in class co.cask.cdap.api.worker.AbstractWorker
By default, this method is a no-op.
destroy() - Method in interface co.cask.cdap.api.worker.Worker
Destroy the Worker.
destroy() - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
 
destroy() - Method in class co.cask.cdap.api.workflow.AbstractWorkflowAction
Deprecated.
 
destroy() - Method in interface co.cask.cdap.api.workflow.WorkflowAction
Deprecated.
This method is called after the Runnable.run() method completes and it can be used for resource cleanup.
destroy() - Method in class co.cask.cdap.etl.api.batch.BatchAggregator
Destroy the Batch Aggregator.
destroy() - Method in class co.cask.cdap.etl.api.batch.BatchJoiner
Destroy the Batch Joiner.
destroy() - Method in class co.cask.cdap.etl.api.batch.BatchSink
Destroy the Batch Sink stage.
destroy() - Method in class co.cask.cdap.etl.api.batch.BatchSource
Destroy the Batch Source stage.
destroy() - Method in interface co.cask.cdap.etl.api.Destroyable
Invoked for resources cleanup.
destroy() - Method in class co.cask.cdap.etl.api.realtime.RealtimeSink
Destroy the Sink.
destroy() - Method in class co.cask.cdap.etl.api.realtime.RealtimeSource
Destroy the Source.
destroy() - Method in class co.cask.cdap.etl.api.Transform
Destroy the Transform Stage.
Destroyable - Interface in co.cask.cdap.etl.api
Interface for stage that supports destroy call for resources cleanup.
dimension(String, String) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery.Builder.Dimension
Adds dimension value to filter by.
dimension(String, String) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.Dimension
Adds dimension value to filter by.
dimension(String) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.GroupByDimension
Adds dimension to use for grouping results into time series.
dimensions(List<DimensionValue>) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery.Builder.Dimension
Adds dimension values to filter by.
dimensions(Map<String, String>) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.Dimension
Adds dimension values to filter by.
dimensions(List<String>) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.GroupByDimension
Adds dimensions to use for grouping results into time series.
DimensionValue - Class in co.cask.cdap.api.dataset.lib.cube
Represents dimension and its value associated with CubeFact.
DimensionValue(String, String) - Constructor for class co.cask.cdap.api.dataset.lib.cube.DimensionValue
 
discard() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.ConsumablePartition
Marks the ProcessState as DISCARDED
discard() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
discardDataset(Dataset) - Method in interface co.cask.cdap.api.data.DatasetContext
Calling this means that the dataset is not used by the caller any more, and the DatasetContext must close and discard it as soon as possible.
DisconnectedException - Exception in co.cask.cdap.client.exception
Thrown when the client is not connected, but a request was attempted.
DisconnectedException(ConnectionConfig) - Constructor for exception co.cask.cdap.client.exception.DisconnectedException
 
DisconnectedException() - Constructor for exception co.cask.cdap.client.exception.DisconnectedException
 
doConsume(ConsumerWorkingSet, PartitionAcceptor) - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
This method will be called whenever a PartitionConsumer requests partitions, to consume partitions from the working set, while marking them as IN_PROGRESS
doConsume(ConsumerWorkingSet, PartitionAcceptor) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
 
doExpiry(ConsumerWorkingSet) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
Goes through all partitions.
doFinish(ConsumerWorkingSet, List<? extends PartitionKey>, boolean) - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
This method will be called on any partitions returned by the #consumePartitions method.
doFinish(ConsumerWorkingSet, List<? extends PartitionKey>, boolean) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
 
drop() - Method in interface co.cask.cdap.api.dataset.DatasetAdmin
Drops dataset.
drop() - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetAdmin
 
drop() - Method in class co.cask.cdap.test.RemoteDatasetAdmin
 
dropDataset(String) - Method in interface co.cask.cdap.api.dataset.DatasetManager
Delete a dataset instance.
dropPartition(PartitionKey) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Remove a partition for a given partition key, silently ignoring if the key is not found.
dropPartition(long) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Remove a partition for a given time.
dropRole(Role) - Method in class co.cask.cdap.client.AuthorizationClient
 
DS_NAME - Static variable in class co.cask.cdap.client.app.FakeApp
 
DYNAMIC_PARTITIONER_ALLOW_CONCURRENCY - Static variable in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
 
DYNAMIC_PARTITIONER_CLASS_NAME - Static variable in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
 
DynamicPartitioner<K,V> - Class in co.cask.cdap.api.dataset.lib
Responsible for dynamically determining a @{link PartitionKey}.
DynamicPartitioner() - Constructor for class co.cask.cdap.api.dataset.lib.DynamicPartitioner
 

E

echo(HttpServiceRequest, HttpServiceResponder) - Method in class co.cask.cdap.client.app.PrefixedEchoHandler
 
EmbeddedDataset - Annotation Type in co.cask.cdap.api.dataset.module
Annotation to declare a parameter to be used in Dataset constructor which will be injected with Dataset instance.
emit(T) - Method in interface co.cask.cdap.api.flow.flowlet.OutputEmitter
Emits an event of type T.
emit(T, Map<String, Object>) - Method in interface co.cask.cdap.api.flow.flowlet.OutputEmitter
Emits an event of type T, associated with set of partitions hashes for selecting downstream partitioned consumers (Flowlet).
emit(T, String, Object) - Method in interface co.cask.cdap.api.flow.flowlet.OutputEmitter
Emits an event of type T, associated with a partition hash for selecting downstream partitioned consumers (Flowlet).
emit(T) - Method in interface co.cask.cdap.etl.api.Emitter
Emit an object.
emitError(InvalidEntry<T>) - Method in interface co.cask.cdap.etl.api.Emitter
Emit an Error object.
Emitter<T> - Interface in co.cask.cdap.etl.api
Used to emit one or more key, value pairs to the next stage.
EMPTY - Static variable in class co.cask.cdap.api.dataset.DatasetProperties
Empty properties.
EMPTY_BYTE_ARRAY - Static variable in class co.cask.cdap.api.common.Bytes
Byte array of size zero.
EmptyRow - Class in co.cask.cdap.api.dataset.table
Represents an empty row (a row with no columns).
end() - Method in interface co.cask.cdap.api.workflow.WorkflowConditionConfigurer
Ends the current condition.
endOfData() - Method in class co.cask.cdap.api.dataset.lib.AbstractCloseableIterator
Implementations of AbstractCloseableIterator.computeNext() must invoke this method when there are no elements left in the iteration.
ENDPOINT - Static variable in class co.cask.cdap.client.app.AppReturnsArgs
 
EndpointPluginContext - Interface in co.cask.cdap.api.plugin
Provides access to load plugin class from plugin endpoint methods.
enforce(EntityId, Principal, Action) - Method in class co.cask.cdap.client.AuthorizationClient
 
enforce(EntityId, Principal, Set<Action>) - Method in class co.cask.cdap.client.AuthorizationClient
 
enumWith(String...) - Static method in class co.cask.cdap.api.data.schema.Schema
Creates a Schema of ENUM type, with the given enum values.
enumWith(Iterable<String>) - Static method in class co.cask.cdap.api.data.schema.Schema
Creates a Schema of ENUM type, with the given enum values.
enumWith(Class<Enum<?>>) - Static method in class co.cask.cdap.api.data.schema.Schema
Creates a Schema of ENUM type, with values extracted from the given Enum class.
equals(Object) - Method in class co.cask.cdap.api.artifact.ArtifactId
 
equals(Object) - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
equals(byte[], byte[]) - Static method in class co.cask.cdap.api.common.Bytes
Checks two byte arrays for equality.
equals(byte[], int, int, byte[], int, int) - Static method in class co.cask.cdap.api.common.Bytes
Checks segments of two byte arrays for equality.
equals(Object) - Method in class co.cask.cdap.api.data.format.FormatSpecification
 
equals(Object) - Method in class co.cask.cdap.api.data.format.StructuredRecord
 
equals(Object) - Method in class co.cask.cdap.api.data.schema.Schema
 
equals(Object) - Method in class co.cask.cdap.api.data.schema.SchemaHash
 
equals(Object) - Method in class co.cask.cdap.api.data.stream.StreamSpecification
 
equals(Object) - Method in class co.cask.cdap.api.dataset.DatasetSpecification
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.cube.DimensionValue
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.cube.TimeSeries
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.cube.TimeValue
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.PartitionConsumerState
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerWorkingSet
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Condition
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.PartitionKey
 
equals(Object) - Method in class co.cask.cdap.api.dataset.lib.PartitionMetadata
 
equals(Object) - Method in class co.cask.cdap.api.metrics.MetricTimeSeries
 
equals(Object) - Method in class co.cask.cdap.api.metrics.TagValue
 
equals(Object) - Method in class co.cask.cdap.api.plugin.Plugin
 
equals(Object) - Method in class co.cask.cdap.api.plugin.PluginClass
 
equals(Object) - Method in class co.cask.cdap.api.plugin.PluginPropertyField
 
equals(Object) - Method in class co.cask.cdap.api.Resources
 
equals(Object) - Method in class co.cask.cdap.api.schedule.RunConstraints
 
equals(Object) - Method in class co.cask.cdap.api.schedule.Schedule
 
equals(Object) - Method in class co.cask.cdap.api.schedule.ScheduleSpecification
 
equals(Object) - Method in class co.cask.cdap.api.security.store.SecureStoreMetadata
 
equals(Object) - Method in class co.cask.cdap.api.service.http.ServiceHttpEndpoint
 
equals(Object) - Method in class co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult
 
equals(Object) - Method in class co.cask.cdap.api.workflow.NodeValue
 
equals(Object) - Method in class co.cask.cdap.api.workflow.ScheduleProgramInfo
 
equals(Object) - Method in class co.cask.cdap.api.workflow.Value
 
equals(Object) - Method in class co.cask.cdap.client.config.ConnectionConfig
 
equals(Object) - Method in class co.cask.cdap.etl.api.realtime.SourceState
 
ErrorRecord<T> - Interface in co.cask.cdap.etl.api
Information about a record that was emitted using Emitter.emitError(InvalidEntry).
ErrorTransform<IN,OUT> - Class in co.cask.cdap.etl.api
A special type of Transform that will get as input all errors emitted by the previous stage.
ErrorTransform() - Constructor for class co.cask.cdap.etl.api.ErrorTransform
 
evaluate(String, String...) - Method in interface co.cask.cdap.api.macro.MacroEvaluator
Use the macro function and call the function with provided arguments, function uses the arguments and returns the evaluated response.
execute(int, TxRunnable) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Transactions with a custom timeout are not supported in Spark.
execute(TxRunnable) - Method in interface co.cask.cdap.api.Transactional
Executes a set of operations via a TxRunnable that are committed as a single transaction.
execute(int, TxRunnable) - Method in interface co.cask.cdap.api.Transactional
Executes a set of operations via a TxRunnable that are committed as a single transaction with a given timeout.
execute(HttpRequest, int...) - Method in class co.cask.cdap.client.MetadataClient
 
execute(HttpRequest) - Method in class co.cask.cdap.client.NamespaceClient
 
execute(NamespaceId, String) - Method in class co.cask.cdap.client.QueryClient
Executes a query asynchronously.
execute(HttpRequest, AccessToken, int...) - Method in class co.cask.cdap.client.util.RESTClient
 
execute(HttpMethod, URL, AccessToken, int...) - Method in class co.cask.cdap.client.util.RESTClient
 
execute(HttpMethod, URL, Map<String, String>, AccessToken, int...) - Method in class co.cask.cdap.client.util.RESTClient
 
execute(HttpMethod, URL, String, Map<String, String>, AccessToken, int...) - Method in class co.cask.cdap.client.util.RESTClient
 
execute(Runnable) - Method in class co.cask.cdap.test.UnitTestManager.UnitTestDatasetManager
 
exists() - Method in interface co.cask.cdap.api.dataset.DatasetAdmin
 
exists() - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetAdmin
 
exists(Id.Application) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
since 4.0.0. Use ApplicationClient.exists(ApplicationId) instead.
exists(ApplicationId) - Method in class co.cask.cdap.client.ApplicationClient
Checks if an application exists.
exists(Id.DatasetInstance) - Method in class co.cask.cdap.client.DatasetClient
Deprecated.
since 4.0.0. Use DatasetClient.exists(DatasetId) instead.
exists(DatasetId) - Method in class co.cask.cdap.client.DatasetClient
Checks if a dataset exists.
exists(Id.DatasetModule) - Method in class co.cask.cdap.client.DatasetModuleClient
Deprecated.
exists(DatasetModuleId) - Method in class co.cask.cdap.client.DatasetModuleClient
Checks if a dataset module exists.
exists(Id.DatasetType) - Method in class co.cask.cdap.client.DatasetTypeClient
Deprecated.
since 4.0.0. Use DatasetTypeClient.exists(DatasetTypeId) instead.
exists(DatasetTypeId) - Method in class co.cask.cdap.client.DatasetTypeClient
Checks if a dataset type exists.
exists() - Method in class co.cask.cdap.test.RemoteDatasetAdmin
 
ExploreProperties - Class in co.cask.cdap.api.dataset
Useful class to configure dataset properties for Explore.
ExploreProperties() - Constructor for class co.cask.cdap.api.dataset.ExploreProperties
 
ExploreProperties.AbstractBuilder<B extends ExploreProperties.AbstractBuilder> - Class in co.cask.cdap.api.dataset
A builder for dataset properties for Explore.
ExploreProperties.AbstractBuilder() - Constructor for class co.cask.cdap.api.dataset.ExploreProperties.AbstractBuilder
 
ExploreProperties.Builder - Class in co.cask.cdap.api.dataset
A builder for dataset properties for Explore.
ExploreProperties.Builder() - Constructor for class co.cask.cdap.api.dataset.ExploreProperties.Builder
 
extractScope(Scope, String, Map<String, String>) - Static method in class co.cask.cdap.api.common.RuntimeArguments
Identifies arguments with a given scope prefix and adds them back without the scope prefix.
extractScope(String, String, Map<String, String>) - Static method in class co.cask.cdap.api.common.RuntimeArguments
Identifies arguments with a given scope prefix and adds them back without the scope prefix.

F

FailurePolicy - Enum in co.cask.cdap.api.flow.flowlet
Enumerates class that defines policy for handling failure.
FailureReason - Class in co.cask.cdap.api.flow.flowlet
This class carries information about the reason of failure.
FailureReason(FailureReason.Type, String, Throwable) - Constructor for class co.cask.cdap.api.flow.flowlet.FailureReason
Immutable object creation.
FailureReason.Type - Enum in co.cask.cdap.api.flow.flowlet
Specifies the type of errors that can be seen during processing of input and while applying the operations generated during the processing.
FAKE_LOG - Static variable in class co.cask.cdap.client.app.FakeWorkflow
 
FakeApp - Class in co.cask.cdap.client.app
 
FakeApp() - Constructor for class co.cask.cdap.client.app.FakeApp
 
FakeApp.AppConfig - Class in co.cask.cdap.client.app
Application Config Class to control schedule creation
FakeApp.AppConfig() - Constructor for class co.cask.cdap.client.app.FakeApp.AppConfig
 
FakeApp.AppConfig(boolean, boolean, String, String, String) - Constructor for class co.cask.cdap.client.app.FakeApp.AppConfig
 
FakeDataset - Class in co.cask.cdap.client.app
 
FakeDataset(String, KeyValueTable) - Constructor for class co.cask.cdap.client.app.FakeDataset
 
FakeDatasetDefinition - Class in co.cask.cdap.client.app
 
FakeDatasetDefinition(String, DatasetDefinition<? extends KeyValueTable, ?>) - Constructor for class co.cask.cdap.client.app.FakeDatasetDefinition
 
FakeDatasetModule - Class in co.cask.cdap.client.app
 
FakeDatasetModule() - Constructor for class co.cask.cdap.client.app.FakeDatasetModule
 
FakeFlow - Class in co.cask.cdap.client.app
 
FakeFlow() - Constructor for class co.cask.cdap.client.app.FakeFlow
 
FakeFlow.FakeFlowlet - Class in co.cask.cdap.client.app
 
FakeFlow.FakeFlowlet() - Constructor for class co.cask.cdap.client.app.FakeFlow.FakeFlowlet
 
FakeSpark - Class in co.cask.cdap.client.app
A Fake spark program to test CLI integration with Spark
FakeSpark() - Constructor for class co.cask.cdap.client.app.FakeSpark
 
FakeWorkflow - Class in co.cask.cdap.client.app
 
FakeWorkflow() - Constructor for class co.cask.cdap.client.app.FakeWorkflow
 
FakeWorkflow.FakeAction - Class in co.cask.cdap.client.app
DummyAction
FakeWorkflow.FakeAction() - Constructor for class co.cask.cdap.client.app.FakeWorkflow.FakeAction
 
FakeWorkflow.FakeAction(String) - Constructor for class co.cask.cdap.client.app.FakeWorkflow.FakeAction
 
fetch(String, String, int, long) - Method in interface co.cask.cdap.api.messaging.MessageFetcher
Fetches messages from the given topic that were published on or after the given timestamp.
fetch(String, String, int, String) - Method in interface co.cask.cdap.api.messaging.MessageFetcher
Fetches messages from the given topic that were published after a message, identified by the given message id.
fetchAccessToken() - Method in class co.cask.cdap.test.IntegrationTestBase
Uses BasicAuthenticationClient to fetch AccessToken - this implementation can be overridden if desired.
fetchAccessToken(String, String) - Method in class co.cask.cdap.test.IntegrationTestBase
 
fetchNextKeyValue() - Method in class co.cask.cdap.api.data.batch.IteratorBasedSplitReader
 
fetchNextKeyValue() - Method in class co.cask.cdap.api.data.batch.SplitReaderBase
Fetches the next data item of the split being read.
FileSet - Interface in co.cask.cdap.api.dataset.lib
This dataset represents a collection of files on the file system.
FileSetArguments - Class in co.cask.cdap.api.dataset.lib
Constants and helper methods to configure runtime arguments for a file dataset.
FileSetArguments() - Constructor for class co.cask.cdap.api.dataset.lib.FileSetArguments
 
FileSetProperties - Class in co.cask.cdap.api.dataset.lib
Helper to build properties for files datasets.
FileSetProperties() - Constructor for class co.cask.cdap.api.dataset.lib.FileSetProperties
 
FileSetProperties.Builder - Class in co.cask.cdap.api.dataset.lib
A Builder to construct properties for FileSet datasets.
Filter - Interface in co.cask.cdap.api.dataset.table
Filter to be applied to Scan.
findDimensionValues(CubeExploreQuery) - Method in interface co.cask.cdap.api.dataset.lib.cube.Cube
Finds dimension values, each of which is present in aggregated data selection defined with CubeExploreQuery.
findMeasureNames(CubeExploreQuery) - Method in interface co.cask.cdap.api.dataset.lib.cube.Cube
Queries data for available measureNames for the query specified by CubeExploreQuery
findMetricNames(MetricSearchQuery) - Method in interface co.cask.cdap.api.metrics.MetricStore
Given a list of tags in the MetricSearchQuery, returns the list of measures available
findNextAvailableTags(MetricSearchQuery) - Method in interface co.cask.cdap.api.metrics.MetricStore
Given a list of tags in the MetricSearchQuery, returns the list of next available tags
finish() - Static method in class co.cask.cdap.test.TestBase
 
Flow - Interface in co.cask.cdap.api.flow
Flow is a collection of Flowlets that are wired together into a Direct Acylic Graph (DAG).
FLOW_NAME - Static variable in class co.cask.cdap.client.app.ConfigTestApp
 
FlowConfigurer - Interface in co.cask.cdap.api.flow
Configurer for configuring Flow.
Flowlet - Interface in co.cask.cdap.api.flow.flowlet
Defines the Flowlet interface.
FLOWLET_NAME - Static variable in class co.cask.cdap.client.app.ConfigTestApp
 
FLOWLET_NAME - Static variable in class co.cask.cdap.client.app.FakeFlow
 
FlowletConfigurer - Interface in co.cask.cdap.api.flow.flowlet
Configurer for configuring Flowlet.
FlowletConnection - Class in co.cask.cdap.api.flow
Defines a connection between two Flowlets or from a Stream to a Flowlet.
FlowletConnection(FlowletConnection.Type, String, String) - Constructor for class co.cask.cdap.api.flow.FlowletConnection
 
FlowletConnection(FlowletConnection.Type, String, String, String) - Constructor for class co.cask.cdap.api.flow.FlowletConnection
 
FlowletConnection.Type - Enum in co.cask.cdap.api.flow
Defines different types of sources a flowlet can be connected to.
FlowletContext - Interface in co.cask.cdap.api.flow.flowlet
This interface represents the Flowlet context.
FlowletDefinition - Class in co.cask.cdap.api.flow
Class defining the definition for a flowlet.
FlowletDefinition(String, Flowlet, int) - Constructor for class co.cask.cdap.api.flow.FlowletDefinition
 
FlowletDefinition(FlowletDefinition, int) - Constructor for class co.cask.cdap.api.flow.FlowletDefinition
Creates a definition from a copy and overrides the number of instances.
FlowletDefinition(FlowletDefinition, String, String) - Constructor for class co.cask.cdap.api.flow.FlowletDefinition
Creates a definition from a copy and overrides the stream connection.
FlowletException - Exception in co.cask.cdap.api.flow.flowlet
Exception thrown when there is an error during Flowlet initialization.
FlowletException(String) - Constructor for exception co.cask.cdap.api.flow.flowlet.FlowletException
 
FlowletException(String, Throwable) - Constructor for exception co.cask.cdap.api.flow.flowlet.FlowletException
 
FlowletException(Throwable) - Constructor for exception co.cask.cdap.api.flow.flowlet.FlowletException
 
FlowletSpecification - Interface in co.cask.cdap.api.flow.flowlet
This class provides specification of a Flowlet.
FlowManager - Interface in co.cask.cdap.test
Instance for this class is for managing a running Flow.
FLOWS - Static variable in class co.cask.cdap.client.app.FakeApp
 
FlowSpecification - Interface in co.cask.cdap.api.flow
This class provides the specification of a Flow.
flush() - Method in interface co.cask.cdap.test.DataSetManager
Makes changes performed using the dataset instance acquired via DataSetManager.get() visible to all other components.
flush() - Method in class co.cask.cdap.test.UnitTestManager.UnitTestDatasetManager
 
fork() - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a fork to the Workflow.
fork() - Method in interface co.cask.cdap.api.workflow.WorkflowConditionConfigurer
Forks the current branch of the WorkflowConditionNode.
fork() - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Forks the execution of the Workflow into multiple branches
fork() - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Adds a nested fork to the current fork
Formats - Class in co.cask.cdap.api.data.format
Names of RecordFormats built into the platform.
Formats() - Constructor for class co.cask.cdap.api.data.format.Formats
 
FormatSpecification - Class in co.cask.cdap.api.data.format
Specification for a RecordFormat, including the class, schema, and settings to use for the format.
FormatSpecification(String, Schema, Map<String, String>) - Constructor for class co.cask.cdap.api.data.format.FormatSpecification
 
FormatSpecification(String, Schema) - Constructor for class co.cask.cdap.api.data.format.FormatSpecification
 
from(String) - Static method in class co.cask.cdap.api.dataset.DatasetContext
Constructs a new DatasetContext containing the specified namespace id
from() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery.Builder
 
from(String) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.Measurement
Defines aggregation view to query from.
from() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.Measurement
Sets aggregation view to query from to be auto-selected based on other parameters of the query.
FROM_BEGINNING - Static variable in class co.cask.cdap.api.dataset.lib.PartitionConsumerState
 
fromByte(byte) - Static method in enum co.cask.cdap.api.dataset.lib.partitioned.ProcessState
 
fromBytes(byte[]) - Static method in class co.cask.cdap.api.dataset.lib.PartitionConsumerState
 
fromBytes(byte[]) - Static method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerWorkingSet
 
fromDataset(String) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD from the given Dataset.
fromDataset(String, String) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD from the given Dataset.
fromDataset(String, Map<String, String>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD from the given Dataset with the given set of dataset arguments.
fromDataset(String, String, Map<String, String>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD from the given Dataset with the given set of dataset arguments.
fromDataset(String, Map<String, String>, Iterable<? extends Split>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD from the given Dataset with the given set of dataset arguments and custom list of Splits.
fromDataset(String, String, Map<String, String>, Iterable<? extends Split>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD from the given Dataset with the given set of dataset arguments and custom list of Splits.
fromDataset(String) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaPairRDD from the given Dataset.
fromDataset(String, Map<String, String>) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaPairRDD from the given Dataset with the given set of Dataset arguments.
fromDataset(String, Map<String, String>, Iterable<? extends Split>) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaPairRDD from the given Dataset with the given set of Dataset arguments and custom list of Splits.
fromHexString(String) - Static method in class co.cask.cdap.api.common.Bytes
Returns a byte[] by decoding from the given hexadecimal string.
fromNamespace(String) - Method in class co.cask.cdap.api.data.batch.Input.DatasetInput
 
fromNamespace(String) - Method in class co.cask.cdap.api.data.batch.Input
Sets the namespace of the input.
fromNamespace(String) - Method in class co.cask.cdap.api.data.batch.Input.InputFormatProviderInput
 
fromNamespace(String) - Method in class co.cask.cdap.api.data.batch.Input.StreamInput
 
fromNamespace(String) - Method in class co.cask.cdap.api.data.batch.Output.DatasetOutput
 
fromNamespace(String) - Method in class co.cask.cdap.api.data.batch.Output
Sets the namespace of the output.
fromNamespace(String) - Method in class co.cask.cdap.api.data.batch.Output.OutputFormatProviderOutput
 
fromPosixArray(String[]) - Static method in class co.cask.cdap.api.common.RuntimeArguments
Converts a POSIX compliant program argument array to a String-to-String Map.
fromStream(String) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaRDD that represents all events from the given stream.
fromStream(String, String) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaRDD that represents all events from the given stream.
fromStream(String, long, long) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaRDD that represents events from the given stream in the given time range.
fromStream(String, String, long, long) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaRDD that represents events from the given stream in the given time range.
fromStream(String, Class<V>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents all events from the given stream.
fromStream(String, String, Class<V>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents all events from the given stream.
fromStream(String, long, long, Class<V>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents events from the given stream in the given time range.
fromStream(String, String, long, long, Class<V>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents events from the given stream in the given time range.
fromStream(String, long, long, Class<? extends StreamEventDecoder<K, V>>, Class<K>, Class<V>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents events from the given stream in the given time range.
fromStream(String, String, long, long, Class<? extends StreamEventDecoder<K, V>>, Class<K>, Class<V>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents events from the given stream in the given time range.
fromStream(String, FormatSpecification, Class<T>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents all events from the given stream.
fromStream(String, String, FormatSpecification, Class<T>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents all events from the given stream.
fromStream(String, FormatSpecification, long, long, Class<T>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents data from the given stream for events in the given time range.
fromStream(String, String, FormatSpecification, long, long, Class<T>) - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Creates a JavaPairRDD that represents data from the given stream for events in the given time range.
fromStream(String) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaRDD that represents all events from the given stream.
fromStream(String, long, long) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaRDD that represents events from the given stream in the given time range.
fromStream(String, Class<V>) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaPairRDD that represents all events from the given stream.
fromStream(String, long, long, Class<V>) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaPairRDD that represents events from the given stream in the given time range.
fromStream(String, long, long, Class<? extends StreamEventDecoder<K, V>>, Class<K>, Class<V>) - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Creates a JavaPairRDD that represents events from the given stream in the given time range.

G

gauge(String, long) - Method in interface co.cask.cdap.api.metrics.Metrics
Sets the specific metric to the provided value.
gauge(String, long) - Method in interface co.cask.cdap.api.metrics.MetricsCollector
Gauge a metric value at the current time.
gauge(String, long) - Method in class co.cask.cdap.api.metrics.NoopMetricsContext
 
gauge(String, long) - Method in interface co.cask.cdap.etl.api.StageMetrics
Sets the specific metric to the provided value.
generateSchema(SchemaGenerator) - Method in class co.cask.cdap.api.flow.FlowletDefinition
Generate schemas for all input and output types with the given SchemaGenerator.
GenericStreamEventData<T> - Class in co.cask.cdap.api.stream
Represents data in one stream event with the body as a specific type.
GenericStreamEventData(Map<String, String>, T) - Constructor for class co.cask.cdap.api.stream.GenericStreamEventData
Constructs a GenericStreamEventData instance.
get(String) - Method in class co.cask.cdap.api.data.batch.SimpleSplit
Gets an attribute value.
get(String, String) - Method in class co.cask.cdap.api.data.batch.SimpleSplit
Gets an attribute value.
get(String) - Method in class co.cask.cdap.api.data.format.StructuredRecord
Get the value of a field in the record.
get(Get) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Read a row by row key from the data table.
get(byte[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
get(byte[], byte[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
get(byte[], byte[][]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
get(byte[], byte[], byte[], int) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
get(List<Get>) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
get(String) - Method in class co.cask.cdap.api.dataset.lib.PartitionMetadata
Performs a get on the underlying map of user-defined metadata.
get(String) - Method in interface co.cask.cdap.api.dataset.module.DatasetDefinitionRegistry
Gets DatasetDefinition previously added to the registry.
get(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
get(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
Get - Class in co.cask.cdap.api.dataset.table
A Get reads one, multiple, or all columns of a row.
Get(byte[]) - Constructor for class co.cask.cdap.api.dataset.table.Get
Get all of the columns of a row.
Get(byte[], byte[]...) - Constructor for class co.cask.cdap.api.dataset.table.Get
Get a set of columns of a row.
Get(byte[], Collection<byte[]>) - Constructor for class co.cask.cdap.api.dataset.table.Get
Get a set of columns of a row.
Get(String) - Constructor for class co.cask.cdap.api.dataset.table.Get
Get all of the columns of a row.
Get(String, String...) - Constructor for class co.cask.cdap.api.dataset.table.Get
Get a set of columns of a row.
Get(String, Collection<String>) - Constructor for class co.cask.cdap.api.dataset.table.Get
Get a set of columns of a row.
get(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
get(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
get(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
get(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
get(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Reads values of all columns of the specified row.
get(byte[], byte[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Reads the value of the specified column of the specified row.
get(byte[], byte[][]) - Method in interface co.cask.cdap.api.dataset.table.Table
Reads the values of the specified columns of the specified row.
get(byte[], byte[], byte[], int) - Method in interface co.cask.cdap.api.dataset.table.Table
Reads the values of all columns in the specified row that are between the specified start (inclusive) and stop (exclusive) columns.
get(Get) - Method in interface co.cask.cdap.api.dataset.table.Table
Reads values of columns as defined by Get parameter.
get(List<Get>) - Method in interface co.cask.cdap.api.dataset.table.Table
Reads values for the rows and columns defined by the Get parameters.
get() - Method in class co.cask.cdap.api.security.store.SecureStoreData
 
get(String) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Get the most recent value added for the specified key for a WorkflowToken.Scope.USER scope.
get(String, WorkflowToken.Scope) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Get the most recent value for the specified key for a given scope.
get(String, String) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Get the value set for the specified key by the specified node for a WorkflowToken.Scope.USER scope.
get(String, String, WorkflowToken.Scope) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Get the value set for the specified key by the specified node for a given scope.
get(byte[]) - Method in class co.cask.cdap.client.app.FakeDataset
 
get(byte[]) - Method in class co.cask.cdap.client.app.StandaloneDataset
 
get(Id.Application) - Method in class co.cask.cdap.client.ApplicationClient
Deprecated.
since 4.0.0. Please use () instead
get(ApplicationId) - Method in class co.cask.cdap.client.ApplicationClient
Get details about the specified application.
get(Id.DatasetInstance) - Method in class co.cask.cdap.client.DatasetClient
Deprecated.
since 4.0.0. Use DatasetClient.get(DatasetId) instead.
get(DatasetId) - Method in class co.cask.cdap.client.DatasetClient
Gets information about a dataset.
get(Id.DatasetModule) - Method in class co.cask.cdap.client.DatasetModuleClient
Deprecated.
get(DatasetModuleId) - Method in class co.cask.cdap.client.DatasetModuleClient
Gets information about a dataset module.
get(Id.DatasetType) - Method in class co.cask.cdap.client.DatasetTypeClient
Deprecated.
since 4.0.0. Use DatasetTypeClient.get(DatasetTypeId) instead.
get(DatasetTypeId) - Method in class co.cask.cdap.client.DatasetTypeClient
Gets information about a dataset type.
get(Id.Service) - Method in class co.cask.cdap.client.ServiceClient
Deprecated.
since 4.0.0. Please use ServiceClient.get(ProgramId) instead
get(ProgramId) - Method in class co.cask.cdap.client.ServiceClient
get(Id.Stream.View) - Method in class co.cask.cdap.client.StreamViewClient
Deprecated.
since 4.0.0. Use StreamViewClient.get(StreamViewId) instead.
get(StreamViewId) - Method in class co.cask.cdap.client.StreamViewClient
Gets detailed information about a view.
get(String) - Method in interface co.cask.cdap.etl.api.action.SettableArguments
Returns the value for the given argument name if it exist, otherwise null is returned.
get() - Method in interface co.cask.cdap.test.DataSetManager
The returned instance of the dataset will see only changes made before the manager was acquired, or before the latest call to DataSetManager.flush().
get() - Method in class co.cask.cdap.test.SingletonExternalResource
Returns the underlying ExternalResource.
get() - Method in class co.cask.cdap.test.UnitTestManager.UnitTestDatasetManager
 
getAccessToken() - Method in class co.cask.cdap.client.config.ClientConfig
 
getAccessToken() - Method in class co.cask.cdap.test.IntegrationTestBase
CDAP access token for making requests to secure CDAP instances.
getAccessTokenSupplier() - Method in class co.cask.cdap.client.config.ClientConfig
 
getActionSpecification() - Method in class co.cask.cdap.api.workflow.WorkflowActionNode
Deprecated.
getAdmin(DatasetContext, DatasetSpecification, ClassLoader) - Method in interface co.cask.cdap.api.dataset.DatasetDefinition
Provides dataset admin to be used to perform administrative operations on the dataset instance defined by passed DatasetSpecification.
getAdmin(DatasetContext, DatasetSpecification, ClassLoader) - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetDefinition
 
getAdmin() - Method in interface co.cask.cdap.api.RuntimeContext
 
getAdmin(DatasetContext, DatasetSpecification, ClassLoader) - Method in class co.cask.cdap.client.app.FakeDatasetDefinition
 
getAdmin(DatasetContext, DatasetSpecification, ClassLoader) - Method in class co.cask.cdap.client.app.StandaloneDatasetDefinition
 
getAggregation() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getAlias() - Method in class co.cask.cdap.api.data.batch.Input
 
getAlias() - Method in class co.cask.cdap.api.data.batch.Output
 
getAll(String) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Same key can be added to the WorkflowToken by multiple nodes.
getAll(String, WorkflowToken.Scope) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Same key can be added to the WorkflowToken by multiple nodes.
getAll() - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Same key can be added to the WorkflowToken by multiple nodes.
getAll(WorkflowToken.Scope) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Same key can be added to the WorkflowToken by multiple nodes.
getAllFromNode(String) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Get the Map of key to Values that were added to the WorkflowToken by specific node for a WorkflowToken.Scope.USER scope.
getAllFromNode(String, WorkflowToken.Scope) - Method in interface co.cask.cdap.api.workflow.WorkflowToken
Get the Map of key to Values that were added to the WorkflowToken by specific node for a given scope.
getAllHeaders() - Method in interface co.cask.cdap.api.service.http.HttpServiceRequest
 
getAllLocalFiles() - Method in interface co.cask.cdap.api.TaskLocalizationContext
 
getAllProgramRuns(Id.Program, long, long, int) - Method in class co.cask.cdap.client.ProgramClient
getAllProgramRuns(ProgramId, long, long, int) - Method in class co.cask.cdap.client.ProgramClient
Gets the run records of a program.
getAllSystemServiceStatus() - Method in class co.cask.cdap.client.MonitorClient
Gets the status of all system services.
getApiVersion() - Method in class co.cask.cdap.client.config.ClientConfig
 
getApplicationClasses(Id.Namespace) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getApplicationClasses(NamespaceId) - Method in class co.cask.cdap.client.ArtifactClient
Get summaries of all application classes in the given namespace, including classes from system artifacts.
getApplicationClasses(Id.Namespace, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
getApplicationClasses(NamespaceId, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Get summaries of all application classes in the given namespace, optionally including classes from system artifacts.
getApplicationClasses(Id.Namespace, String) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getApplicationClasses(NamespaceId, String) - Method in class co.cask.cdap.client.ArtifactClient
Get information about all application classes in the specified namespace, of the specified class name.
getApplicationClasses(Id.Namespace, String, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
getApplicationClasses(NamespaceId, String, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Get information about all application classes in the specified namespace, of the specified class name.
getApplicationClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getApplicationManager(ApplicationId) - Method in class co.cask.cdap.test.IntegrationTestBase
 
getApplicationManager(ApplicationId) - Method in class co.cask.cdap.test.IntegrationTestManager
 
getApplicationManager(ApplicationId) - Method in interface co.cask.cdap.test.TestManager
Gets an Application Manager for an Application.
getApplicationManager(ApplicationId) - Method in class co.cask.cdap.test.UnitTestManager
 
getApplicationPreferences(Id.Application, boolean) - Method in class co.cask.cdap.client.PreferencesClient
getApplicationPreferences(ApplicationId, boolean) - Method in class co.cask.cdap.client.PreferencesClient
Returns the Preferences stored at the Application Level.
getApplicationSpecification() - Method in interface co.cask.cdap.api.RuntimeContext
 
getAppVersion() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getArguments() - Method in class co.cask.cdap.api.data.batch.Input.DatasetInput
 
getArguments() - Method in class co.cask.cdap.api.data.batch.Output.DatasetOutput
 
getArguments() - Method in class co.cask.cdap.api.macro.MacroFunction
return the list of arguments to the funcion
getArguments() - Method in interface co.cask.cdap.etl.api.action.ActionContext
Return the arguments which can be updated.
getArtifactId() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getArtifactId() - Method in class co.cask.cdap.api.plugin.Plugin
 
getArtifactInfo(Id.Artifact) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getArtifactInfo(ArtifactId) - Method in class co.cask.cdap.client.ArtifactClient
Gets information about a specific artifact version.
getArtifactInfo(Id.Artifact, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getArtifactInfo(ArtifactId, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Gets information about a specific artifact version.
getAsBoolean() - Method in class co.cask.cdap.api.workflow.Value
 
getAsDouble() - Method in class co.cask.cdap.api.workflow.Value
 
getAsInt() - Method in class co.cask.cdap.api.workflow.Value
 
getAsLong() - Method in class co.cask.cdap.api.workflow.Value
 
getAuthorizer() - Static method in class co.cask.cdap.test.TestBase
Returns an Authorizer for performing authorization operations.
getBaseLocation() - Method in interface co.cask.cdap.api.dataset.lib.FileSet
Allows to interact directly with the location of this dataset in the underlying file system.
getBasePath(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getBody() - Method in class co.cask.cdap.api.stream.GenericStreamEventData
 
getBodyFormatSpec() - Method in class co.cask.cdap.api.data.batch.Input.StreamInput
 
getBoolean(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getBoolean(byte[], boolean) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getBoolean(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getBoolean(String, boolean) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getBoolean(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
getBoolean(byte[], boolean) - Method in class co.cask.cdap.api.dataset.table.Result
 
getBoolean(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
getBoolean(String, boolean) - Method in class co.cask.cdap.api.dataset.table.Result
 
getBoolean(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getBoolean(byte[], boolean) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getBoolean(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getBoolean(String, boolean) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getBranches() - Method in class co.cask.cdap.api.workflow.WorkflowForkNode
 
getBytes(ByteBuffer) - Static method in class co.cask.cdap.api.common.Bytes
This method will get a sequence of bytes from pos -> limit, but will restore pos after.
getCacheConfig() - Method in class co.cask.cdap.etl.api.LookupTableConfig
 
getCause() - Method in class co.cask.cdap.api.flow.flowlet.FailureReason
Cause of the error if it is caused by exceptions.
getCDAPConfig() - Method in class co.cask.cdap.client.MetaClient
 
getClassName() - Method in interface co.cask.cdap.api.customaction.CustomActionSpecification
 
getClassName() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletSpecification
 
getClassName() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getClassName() - Method in class co.cask.cdap.api.plugin.PluginClass
Returns the fully qualified class name of the plugin.
getClassName() - Method in interface co.cask.cdap.api.ProgramSpecification
 
getClassName() - Method in class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
 
getClassName() - Method in class co.cask.cdap.api.service.ServiceSpecification
 
getClassName() - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getClassName() - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getClassName() - Method in interface co.cask.cdap.api.workflow.WorkflowActionSpecification
Deprecated.
 
getClassName() - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
 
getClientConfig() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getClientConfig(AccessToken) - Method in class co.cask.cdap.test.IntegrationTestBase
 
getClientResources() - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getClusterName() - Method in interface co.cask.cdap.api.RuntimeContext
 
getColumnFamily(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getColumnFamily(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getColumnFamilyBytes(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getColumnFamilyBytes(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getColumns() - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getColumns() - Method in class co.cask.cdap.api.dataset.table.Result
 
getColumns() - Method in interface co.cask.cdap.api.dataset.table.Row
 
getColumns() - Method in class co.cask.cdap.api.dataset.table.RowColumns
 
getComponentSchema() - Method in class co.cask.cdap.api.data.schema.Schema
 
getCondition(String) - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter
 
getConditions() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter
This should be used for inspection or debugging only.
getConfig() - Method in class co.cask.cdap.api.app.AbstractApplication
Get the configuration object.
getConfig() - Method in interface co.cask.cdap.api.app.ApplicationContext
Get the configuration object.
getConfig(Id.Stream) - Method in class co.cask.cdap.client.StreamClient
Deprecated.
since 4.0.0. Use StreamClient.getConfig(StreamId) instead.
getConfig(StreamId) - Method in class co.cask.cdap.client.StreamClient
Gets the configuration of a stream.
getConfigFieldName() - Method in class co.cask.cdap.api.plugin.PluginClass
Returns the name of the field that extends from PluginConfig in the plugin class.
getConfiguration() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getConfiguration() - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
 
getConfiguration() - Static method in class co.cask.cdap.test.TestBase
Returns the CConfiguration used in tests.
getConfiguredNamespace() - Static method in class co.cask.cdap.test.IntegrationTestBase
 
getConfigurer() - Method in class co.cask.cdap.api.app.AbstractApplication
 
getConfigurer() - Method in class co.cask.cdap.api.flow.AbstractFlow
Returns the FlowConfigurer used for configuration.
getConfigurer() - Method in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
Returns the FlowletConfigurer used for configuration.
getConfigurer() - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
Returns the MapReduceConfigurer, only available at configuration time.
getConfigurer() - Method in class co.cask.cdap.api.service.AbstractService
Returns the ServiceConfigurer, only available at configuration time.
getConfigurer() - Method in class co.cask.cdap.api.service.http.AbstractHttpServiceHandler
 
getConfigurer() - Method in class co.cask.cdap.api.spark.AbstractSpark
Returns the SparkConfigurer, only available at configuration time.
getConfigurer() - Method in class co.cask.cdap.api.worker.AbstractWorker
Returns the WorkerConfigurer used for configuration.
getConfigurer() - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Returns the WorkflowConfigurer, only available at configuration time.
getConflictDetection(DatasetProperties, ConflictDetection) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getConflictDetection(Map<String, String>, ConflictDetection) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getConnectionConfig() - Method in class co.cask.cdap.client.config.ClientConfig
 
getConnectionConfig() - Method in exception co.cask.cdap.client.exception.DisconnectedException
 
getConnections() - Method in interface co.cask.cdap.api.flow.FlowSpecification
 
getContent() - Method in interface co.cask.cdap.api.service.http.HttpServiceRequest
 
getContentLength() - Method in class co.cask.cdap.api.service.http.HttpContentProducer
Returns the length of the content or -1L if the length is unknown.
getContext() - Method in class co.cask.cdap.api.app.AbstractApplication
 
getContext() - Method in class co.cask.cdap.api.customaction.AbstractCustomAction
 
getContext() - Method in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
 
getContext() - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
Return an instance of the MapReduceContext.
getContext(Map<String, String>) - Method in interface co.cask.cdap.api.metrics.MetricsCollectionService
Returns the metric collector for the given context.
getContext() - Method in class co.cask.cdap.api.service.http.AbstractHttpServiceHandler
 
getContext() - Method in class co.cask.cdap.api.spark.AbstractSpark
Return an instance of the SparkClientContext.
getContext() - Method in class co.cask.cdap.api.worker.AbstractWorker
 
getContext() - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Return an instance of the WorkflowContext.
getContext() - Method in class co.cask.cdap.api.workflow.AbstractWorkflowAction
Deprecated.
 
getContext() - Method in class co.cask.cdap.etl.api.Transform
 
getCounter() - Method in class co.cask.cdap.api.dataset.lib.CounterTimeseriesTable.Counter
Returns the name of the counter.
getCreationTime() - Method in class co.cask.cdap.api.dataset.lib.PartitionMetadata
 
getCube() - Method in class co.cask.cdap.api.dataset.lib.cube.AbstractCubeHttpHandler
 
getCurrentKey() - Method in class co.cask.cdap.api.data.batch.SplitReader
Get the current key.
getCurrentKey() - Method in class co.cask.cdap.api.data.batch.SplitReaderAdapter
 
getCurrentKey() - Method in class co.cask.cdap.api.data.batch.SplitReaderBase
 
getCurrentKey() - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable.KeyValueScanner
 
getCurrentRecord() - Method in class co.cask.cdap.api.data.batch.RecordScanner
Get the current record.
getCurrentValue() - Method in class co.cask.cdap.api.data.batch.SplitReader
Get the current value.
getCurrentValue() - Method in class co.cask.cdap.api.data.batch.SplitReaderAdapter
 
getCurrentValue() - Method in class co.cask.cdap.api.data.batch.SplitReaderBase
 
getCurrentValue() - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable.KeyValueScanner
 
getCustomActionSpecification() - Method in class co.cask.cdap.api.workflow.WorkflowActionNode
 
getData(SecureKeyId) - Method in class co.cask.cdap.client.SecureStoreClient
Fetch the data associated with the given secure key
getDataset(String) - Method in interface co.cask.cdap.api.data.DatasetContext
Get an instance of the specified Dataset.
getDataset(String, String) - Method in interface co.cask.cdap.api.data.DatasetContext
Get an instance of the specified Dataset.
getDataset(String, Map<String, String>) - Method in interface co.cask.cdap.api.data.DatasetContext
Get an instance of the specified Dataset.
getDataset(String, String, Map<String, String>) - Method in interface co.cask.cdap.api.data.DatasetContext
Get an instance of the specified Dataset.
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in interface co.cask.cdap.api.dataset.DatasetDefinition
Provides dataset to be used to perform data operations on the dataset instance data defined by passed DatasetSpecification and the given arguments.
getDataset(DatasetContext, String, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetDefinition
Gets a Dataset instance from the delegates with the given instance name.
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.api.dataset.lib.CounterTimeseriesTableDefinition
 
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.api.dataset.lib.IndexedObjectStoreDefinition
 
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.api.dataset.lib.IndexedTableDefinition
 
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTableDefinition
 
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.api.dataset.lib.TimeseriesTableDefinition
 
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.client.app.FakeDatasetDefinition
 
getDataset(DatasetContext, DatasetSpecification, Map<String, String>, ClassLoader) - Method in class co.cask.cdap.client.app.StandaloneDatasetDefinition
 
getDataset(Id.Namespace, String) - Method in class co.cask.cdap.test.AbstractTestManager
 
getDataset(DatasetId) - Method in class co.cask.cdap.test.IntegrationTestManager
 
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(Id.Namespace, String) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
since 4.0.0. Use TestManager.getDataset(DatasetId) instead.
getDataset(DatasetId) - Method in interface co.cask.cdap.test.TestManager
Gets Dataset manager of Dataset instance of type <T>.
getDataset(DatasetId) - Method in class co.cask.cdap.test.UnitTestManager
 
getDatasetClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getDatasetManager() - Method in class co.cask.cdap.api.logging.AppenderContext
Returns a DatasetManager for interacting with the dataset system.
getDatasetModules() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getDatasetModules() - Method in class co.cask.cdap.api.flow.FlowletDefinition
Deprecated.
getDatasetProperties(String) - Method in interface co.cask.cdap.api.dataset.DatasetManager
Get the properties with which a dataset was created or updated.
getDatasetProperties() - Method in class co.cask.cdap.etl.api.LookupTableConfig
 
getDatasets() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getDatasets() - Method in interface co.cask.cdap.api.customaction.CustomActionSpecification
 
getDataSets() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletSpecification
 
getDatasets() - Method in class co.cask.cdap.api.flow.FlowletDefinition
 
getDataSets() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getDatasets() - Method in class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
 
getDatasets() - Method in class co.cask.cdap.api.spark.SparkSpecification
Returns the set of static datasets used by the Spark program.
getDatasets() - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getDatasets() - Method in interface co.cask.cdap.api.workflow.WorkflowActionSpecification
Deprecated.
 
getDatasetSpecs() - Method in class co.cask.cdap.api.flow.FlowletDefinition
Deprecated.
getDatasetType(String) - Method in interface co.cask.cdap.api.dataset.DatasetManager
Get the type of a dataset.
getDataTracer(String) - Method in interface co.cask.cdap.api.RuntimeContext
 
getDecoderType() - Method in class co.cask.cdap.api.data.batch.Input.StreamInput
 
getDefault() - Static method in class co.cask.cdap.client.config.ClientConfig
 
getDefaultConnectTimeout() - Method in class co.cask.cdap.client.config.ClientConfig
 
getDefaultReadTimeout() - Method in class co.cask.cdap.client.config.ClientConfig
 
getDefaultRequestConfig() - Method in class co.cask.cdap.client.config.ClientConfig
 
getDefaultSchema() - Method in class co.cask.cdap.api.data.format.RecordFormat
Get the default schema for the format.
getDelegate(String) - Method in class co.cask.cdap.api.dataset.lib.CompositeDatasetDefinition
 
getDescription() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getDescription() - Method in interface co.cask.cdap.api.customaction.CustomActionSpecification
 
getDescription() - Method in class co.cask.cdap.api.data.stream.StreamSpecification
Returns the description of the Stream.
getDescription() - Method in class co.cask.cdap.api.dataset.DatasetProperties
 
getDescription() - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Returns the description of dataset.
getDescription() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletSpecification
 
getDescription() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getDescription() - Method in class co.cask.cdap.api.plugin.PluginClass
Returns description of the plugin.
getDescription() - Method in class co.cask.cdap.api.plugin.PluginPropertyField
Returns description for the property.
getDescription() - Method in interface co.cask.cdap.api.ProgramSpecification
 
getDescription() - Method in class co.cask.cdap.api.schedule.Schedule
 
getDescription() - Method in class co.cask.cdap.api.security.store.SecureStoreMetadata
 
getDescription() - Method in class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
 
getDescription() - Method in class co.cask.cdap.api.service.ServiceSpecification
 
getDescription() - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getDescription() - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getDescription() - Method in interface co.cask.cdap.api.workflow.WorkflowActionSpecification
Deprecated.
 
getDescription() - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
 
getDimensionValues() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
 
getDimensionValues() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
 
getDimensionValues() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
 
getDimensionValues() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getDimensionValues() - Method in class co.cask.cdap.api.dataset.lib.cube.TimeSeries
 
getDirectMessagePublisher() - Method in interface co.cask.cdap.api.messaging.MessagingContext
Returns an instance of MessagePublisher for publishing messages without a transaction.
getDouble(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getDouble(byte[], double) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getDouble(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getDouble(String, double) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getDouble(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
getDouble(byte[], double) - Method in class co.cask.cdap.api.dataset.table.Result
 
getDouble(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
getDouble(String, double) - Method in class co.cask.cdap.api.dataset.table.Result
 
getDouble(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getDouble(byte[], double) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getDouble(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getDouble(String, double) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getDriverResources() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getDriverResources() - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getDynamicPartitioner(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
Return the DynamicPartitioner class that was previously assigned onto runtime arguments.
getElseBranch() - Method in class co.cask.cdap.api.workflow.WorkflowConditionNode
 
getEmbeddedFileSet() - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
 
getEndpoints() - Method in class co.cask.cdap.api.plugin.PluginClass
Returns the set of plugin endpoints available in the plugin.
getEndpoints() - Method in class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
 
getEndpoints(Id.Service) - Method in class co.cask.cdap.client.ServiceClient
Deprecated.
since 4.0.0. Please use ServiceClient.getEndpoints(ServiceId) instead
getEndpoints(ServiceId) - Method in class co.cask.cdap.client.ServiceClient
Gets a list of ServiceHttpEndpoint that a Service exposes.
getEndTime() - Method in class co.cask.cdap.api.data.batch.Input.StreamInput
 
getEndTs() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
 
getEndTs() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
 
getEndTs() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getEndTs() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getEndTs() - Method in class co.cask.cdap.api.metrics.MetricDeleteQuery
 
getEndTs() - Method in class co.cask.cdap.api.metrics.MetricSearchQuery
 
getEnumIndex(String) - Method in class co.cask.cdap.api.data.schema.Schema
 
getEnumValue(int) - Method in class co.cask.cdap.api.data.schema.Schema
 
getEnumValues() - Method in class co.cask.cdap.api.data.schema.Schema
 
getErrorCode() - Method in interface co.cask.cdap.etl.api.ErrorRecord
 
getErrorCode() - Method in class co.cask.cdap.etl.api.InvalidEntry
 
getErrorMessage() - Method in interface co.cask.cdap.etl.api.ErrorRecord
 
getErrorMsg() - Method in class co.cask.cdap.etl.api.InvalidEntry
 
getEvents(Id.Stream, String, String, int, T) - Method in class co.cask.cdap.client.StreamClient
getEvents(StreamId, String, String, int, T) - Method in class co.cask.cdap.client.StreamClient
Reads events from a stream
getEvents(Id.Stream, long, long, int, T) - Method in class co.cask.cdap.client.StreamClient
getEvents(StreamId, long, long, int, T) - Method in class co.cask.cdap.client.StreamClient
Reads events from a stream
getEvents(Id.Stream, long, long, int, Function<? super StreamEvent, Boolean>) - Method in class co.cask.cdap.client.StreamClient
getEvents(StreamId, long, long, int, Function<? super StreamEvent, Boolean>) - Method in class co.cask.cdap.client.StreamClient
Reads events from a stream
getEvents(Id.Stream, String, String, int, Function<? super StreamEvent, Boolean>) - Method in class co.cask.cdap.client.StreamClient
getEvents(StreamId, String, String, int, Function<? super StreamEvent, Boolean>) - Method in class co.cask.cdap.client.StreamClient
Reads events from a stream
getEvents(String, String, int) - Method in interface co.cask.cdap.test.StreamManager
Get events from the specified stream in the specified interval
getEvents(long, long, int) - Method in interface co.cask.cdap.test.StreamManager
Get events from the specified stream in the specified interval
getException() - Method in interface co.cask.cdap.api.metrics.RuntimeMetrics
 
getExecutorResources() - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getExpiryBorder() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConcurrentPartitionConsumer
 
getExpirySeconds() - Method in class co.cask.cdap.etl.api.CacheConfig
 
getExploreDatabaseName(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.ExploreProperties
 
getExploreDatabaseName(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.ExploreProperties
 
getExploreFormat(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getExploreFormatProperties(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getExploreInputFormat(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getExploreOutputFormat(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getExploreSchema(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getExploreTableName(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.ExploreProperties
 
getExploreTableName(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.ExploreProperties
 
getFailedPartitions() - Method in class co.cask.cdap.api.dataset.lib.partitioned.PartitionConsumerResult
 
getFailureCause() - Method in class co.cask.cdap.api.workflow.WorkflowNodeState
Return the detail message string for failure if node execution failed, otherwise null is returned.
getFailureInfo() - Method in class co.cask.cdap.api.ProgramState
Return any available information on the reason of failure of the program.
getFailurePolicy() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletSpecification
 
getField(String) - Method in class co.cask.cdap.api.data.schema.Schema
Returns the record Schema.Field of the given name.
getField(String) - Method in class co.cask.cdap.api.dataset.lib.PartitionKey
 
getFieldName() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Condition
 
getFields() - Method in class co.cask.cdap.api.data.schema.Schema
 
getFields() - Method in class co.cask.cdap.api.dataset.lib.Partitioning
This returns a map associating all the fields of this partitioning with their respective types.
getFields() - Method in class co.cask.cdap.api.dataset.lib.PartitionKey
 
getFieldType(String) - Method in class co.cask.cdap.api.dataset.lib.Partitioning
 
getFileGroup(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getFilePermissions(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getFilter() - Method in class co.cask.cdap.api.dataset.table.Scan
 
getFix() - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
getFloat(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getFloat(byte[], float) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getFloat(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getFloat(String, float) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getFloat(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
getFloat(byte[], float) - Method in class co.cask.cdap.api.dataset.table.Result
 
getFloat(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
getFloat(String, float) - Method in class co.cask.cdap.api.dataset.table.Result
 
getFloat(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getFloat(byte[], float) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getFloat(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getFloat(String, float) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getFlowletInstances(Id.Flow.Flowlet) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
getFlowletInstances(FlowletId) - Method in class co.cask.cdap.client.ProgramClient
Gets the number of instances that a flowlet is currently running on.
getFlowletInstances(String) - Method in interface co.cask.cdap.test.FlowManager
Gets the number of flowlet instances.
getFlowletMetrics(Id.Program, String) - Method in class co.cask.cdap.client.MetricsClient
Deprecated.
getFlowletMetrics(FlowletId) - Method in class co.cask.cdap.client.MetricsClient
 
getFlowletMetrics(String) - Method in interface co.cask.cdap.test.FlowManager
 
getFlowletMetrics(String, String, String, String) - Method in class co.cask.cdap.test.MetricsManager
returns flowlet related metrics
getFlowlets() - Method in interface co.cask.cdap.api.flow.FlowSpecification
 
getFlowletSpec() - Method in class co.cask.cdap.api.flow.FlowletDefinition
 
getFlowManager(String) - Method in interface co.cask.cdap.test.ApplicationManager
Returns a ProgramManager, without starting the program
getFlows() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getFunctionName() - Method in class co.cask.cdap.api.macro.MacroFunction
return the function name
getGroupByDimensions() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getGroupByTags() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getHadoopConfig() - Method in class co.cask.cdap.client.MetaClient
 
getHadoopContext() - Method in interface co.cask.cdap.api.mapreduce.MapReduceTaskContext
Returns the Hadoop context object for the task.
getHadoopJob() - Method in interface co.cask.cdap.api.mapreduce.MapReduceContext
Returns the actual Hadoop job.
getHadoopJob() - Method in interface co.cask.cdap.etl.api.batch.BatchContext
Deprecated.
this method will be removed.
getHadoopJob() - Method in interface co.cask.cdap.etl.api.batch.BatchRuntimeContext
Deprecated.
this method will be removed.
getHandlers() - Method in class co.cask.cdap.api.service.ServiceSpecification
Returns an immutable map from handler name to handler specification.
getHeader(String) - Method in interface co.cask.cdap.api.service.http.HttpServiceRequest
 
getHeaders(String) - Method in interface co.cask.cdap.api.service.http.HttpServiceRequest
Returns all of the values for a specified header
getHeaders() - Method in class co.cask.cdap.api.stream.GenericStreamEventData
 
getHistory(Id.Program, ProgramRunStatus) - Method in class co.cask.cdap.test.AbstractApplicationManager
 
getHistory() - Method in class co.cask.cdap.test.AbstractProgramManager
 
getHistory(ProgramRunStatus) - Method in class co.cask.cdap.test.AbstractProgramManager
 
getHistory(Id.Program, ProgramRunStatus) - Method in interface co.cask.cdap.test.ApplicationManager
Gets the history of the program
getHistory(ProgramId, ProgramRunStatus) - Method in interface co.cask.cdap.test.ApplicationManager
Gets the history of the program
getHistory() - Method in interface co.cask.cdap.test.ProgramManager
Gets the history of the program
getHistory(ProgramRunStatus) - Method in interface co.cask.cdap.test.ProgramManager
Gets the history of the program
getHostname() - Method in class co.cask.cdap.client.config.ConnectionConfig
 
getId() - Method in interface co.cask.cdap.api.messaging.Message
Returns the unique identifier of this message.
getIfBranch() - Method in class co.cask.cdap.api.workflow.WorkflowConditionNode
 
getInfo() - Method in interface co.cask.cdap.test.ApplicationManager
Returns the application's details.
getInput() - Method in interface co.cask.cdap.api.metrics.RuntimeMetrics
 
getInputContext() - Method in interface co.cask.cdap.api.mapreduce.MapReduceTaskContext
Returns an InputContext of the input configured for this task.
getInputDataSet() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getInputEndTime(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.TimePartitionedFileSetArguments
Get the end (exclusive) of the time range to be read as input.
getInputFormat(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getInputFormatClassName() - Method in interface co.cask.cdap.api.data.batch.InputFormatProvider
 
getInputFormatConfiguration() - Method in interface co.cask.cdap.api.data.batch.InputFormatProvider
 
getInputFormatConfiguration(Iterable<? extends Location>) - Method in interface co.cask.cdap.api.dataset.lib.FileSet
A variant of InputFormatProvider.getInputFormatConfiguration() that allows passing in the input locations (rather than using the input locations that were determined from runtime arguments).
getInputFormatProvider() - Method in class co.cask.cdap.api.data.batch.Input.InputFormatProviderInput
 
getInputLocations() - Method in interface co.cask.cdap.api.dataset.lib.FileSet
Allows direct access to files of this dataset in the underlying file system.
getInputName() - Method in interface co.cask.cdap.api.data.batch.InputContext
Returns the name of the input configured for this task.
getInputName() - Method in interface co.cask.cdap.api.mapreduce.MapReduceTaskContext
Deprecated.
getInputPartitionFilter(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
Get the partition filter for the input to be read.
getInputPartitionKey() - Method in interface co.cask.cdap.api.data.batch.PartitionedFileSetInputContext
Returns the PartitionKey of the input configured for this task.
getInputPartitionKeys(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
Get the partition keys to be read for the input.
getInputPaths(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetArguments
 
getInputProperties(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getInputRecord() - Method in class co.cask.cdap.etl.api.JoinElement
Returns input record which is part of join result
getInputs() - Method in class co.cask.cdap.api.flow.FlowletDefinition
 
getInputSchema() - Method in interface co.cask.cdap.etl.api.StageConfigurer
get the input schema for this stage, or null if its unknown
getInputSchema() - Method in interface co.cask.cdap.etl.api.StageContext
Return the input schema for the stage.
getInputSchemas() - Method in interface co.cask.cdap.etl.api.MultiInputStageConfigurer
get the map of input stageName to input schema for this stage, or return empty map if its unknown
getInputSchemas() - Method in interface co.cask.cdap.etl.api.StageContext
Return the input schemas for the stage.
getInputSplits(int, byte[], long, long, byte[]...) - Method in class co.cask.cdap.api.dataset.lib.TimeseriesTable
Defines input selection for batch jobs.
getInputStartTime(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.TimePartitionedFileSetArguments
Get the start (inclusive) of the time range to be read as input.
getInstanceCount() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletContext
 
getInstanceCount() - Method in class co.cask.cdap.api.logging.AppenderContext
Returns the total number of log framework instances running.
getInstanceCount() - Method in interface co.cask.cdap.api.service.http.HttpServiceContext
 
getInstanceCount() - Method in interface co.cask.cdap.api.worker.WorkerContext
 
getInstanceCount() - Method in interface co.cask.cdap.etl.api.realtime.RealtimeContext
Get Instance Count.
getInstanceId() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletContext
 
getInstanceId() - Method in class co.cask.cdap.api.logging.AppenderContext
Returns the current instance id of the log framework.
getInstanceId() - Method in interface co.cask.cdap.api.service.http.HttpServiceContext
 
getInstanceId() - Method in interface co.cask.cdap.api.worker.WorkerContext
 
getInstanceId() - Method in interface co.cask.cdap.etl.api.realtime.RealtimeContext
Get Instance Id.
getInstancePreferences() - Method in class co.cask.cdap.client.PreferencesClient
Returns the Preferences stored at the Instance Level.
getInstances() - Method in class co.cask.cdap.api.flow.FlowletDefinition
 
getInstances() - Method in class co.cask.cdap.api.service.ServiceSpecification
Returns the number of instances for the service handler.
getInstances() - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getInstances() - Method in interface co.cask.cdap.test.WorkerManager
Returns the number of instances.
getInstanceURI() - Method in class co.cask.cdap.test.IntegrationTestBase
Reads the CDAP instance URI from the system property "instanceUri".
getInt(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getInt(byte[], int) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getInt(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getInt(String, int) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getInt(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
getInt(byte[], int) - Method in class co.cask.cdap.api.dataset.table.Result
 
getInt(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
getInt(String, int) - Method in class co.cask.cdap.api.dataset.table.Result
 
getInt(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getInt(byte[], int) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getInt(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getInt(String, int) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getInterpolator() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getInterpolator() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getIntProperty(String, int) - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Lookup a custom property of the dataset.
getInvalidRecord() - Method in class co.cask.cdap.etl.api.InvalidEntry
 
getInvalidSize() - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
getJoinConfig() - Method in interface co.cask.cdap.etl.api.Joiner
Creates join configuration which holds information about required inputs which are needed to decide type of the join and produce join result.
getKey(VALUE) - Method in class co.cask.cdap.api.data.batch.IteratorBasedSplitReader
Gets the key belonging to the key/value record provided by the iterator.
getKey() - Method in class co.cask.cdap.api.dataset.lib.KeyValue
 
getKey(TimeseriesTable.Entry) - Method in class co.cask.cdap.api.dataset.lib.TimeseriesTable.TimeseriesTableRecordsReader
 
getKey() - Method in class co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult
 
getKeyMetadata(SecureKeyId) - Method in class co.cask.cdap.client.SecureStoreClient
Get the metadata associated with the given secure key
getLastModifiedTime() - Method in class co.cask.cdap.api.security.store.SecureStoreMetadata
 
getLength() - Method in class co.cask.cdap.api.data.batch.Split
By default assume that the size of each split is roughly the same.
getLimit() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
 
getLimit() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getLimit() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getLimit() - Method in class co.cask.cdap.api.metrics.MetricSearchQuery
 
getLineage(Id.DatasetInstance, long, long, Integer) - Method in class co.cask.cdap.client.LineageClient
Deprecated.
getLineage(DatasetId, long, long, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given dataset.
getLineage(Id.DatasetInstance, String, String, Integer) - Method in class co.cask.cdap.client.LineageClient
getLineage(DatasetId, String, String, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given dataset.
getLineage(Id.DatasetInstance, long, long, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
getLineage(DatasetId, long, long, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given dataset.
getLineage(Id.DatasetInstance, String, String, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
getLineage(DatasetId, String, String, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given dataset.
getLineage(Id.Stream, long, long, Integer) - Method in class co.cask.cdap.client.LineageClient
Deprecated.
getLineage(StreamId, long, long, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given stream.
getLineage(Id.Stream, long, long, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
getLineage(StreamId, long, long, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given stream.
getLineage(Id.Stream, String, String, Integer) - Method in class co.cask.cdap.client.LineageClient
getLineage(StreamId, String, String, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given stream.
getLineage(Id.Stream, String, String, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
getLineage(StreamId, String, String, Set<CollapseType>, Integer) - Method in class co.cask.cdap.client.LineageClient
Retrieves Lineage for a given stream.
getLiveInfo(Id.Program) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
since 4.0.0. Use ProgramClient.getLiveInfo(ProgramId) instead
getLiveInfo(ProgramId) - Method in class co.cask.cdap.client.ProgramClient
Gets the live information of a program.
getLocalDatasetSpecs() - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
Return the map of local dataset names and associated specifications required for dataset instance creation.
getLocalFile(String) - Method in interface co.cask.cdap.api.TaskLocalizationContext
Returns a File representing the path to a localized file localized with the given name.
getLocalizationContext() - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Returns a Serializable TaskLocalizationContext which can be used to retrieve files localized to task containers.
getLocation(String) - Method in interface co.cask.cdap.api.dataset.lib.FileSet
Allows direct access to files in this dataset, in the underlying file system.
getLocation() - Method in interface co.cask.cdap.api.dataset.lib.Partition
 
getLocationFactory() - Method in class co.cask.cdap.api.logging.AppenderContext
Returns a LocationFactory that the log framework is running on.
getLogicalStartTime() - Method in interface co.cask.cdap.api.customaction.CustomActionContext
Returns the logical start time of the batch job which triggers this instance of an action.
getLogicalStartTime() - Method in interface co.cask.cdap.api.mapreduce.MapReduceContext
Returns the logical start time of this MapReduce job.
getLogicalStartTime() - Method in interface co.cask.cdap.api.mapreduce.MapReduceTaskContext
Returns the logical start time of this MapReduce job.
getLogicalStartTime() - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Returns the logical start time of this Spark job.
getLogicalStartTime() - Method in interface co.cask.cdap.api.spark.SparkClientContext
Returns the logical start time of this Spark job.
getLogicalStartTime() - Method in interface co.cask.cdap.api.workflow.WorkflowContext
 
getLogicalStartTime() - Method in interface co.cask.cdap.etl.api.action.ActionContext
Returns the logical start time of the batch job which triggers this instance of an action.
getLogicalStartTime() - Method in interface co.cask.cdap.etl.api.batch.BatchContext
Returns the logical start time of the Batch Job.
getLogicalStartTime() - Method in interface co.cask.cdap.etl.api.batch.BatchRuntimeContext
Returns the logical start time of the Batch Job.
getLogicalStartTime() - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Returns the logical start time of the Batch Job.
getLong(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getLong(byte[], long) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getLong(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getLong(String, long) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getLong(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
getLong(byte[], long) - Method in class co.cask.cdap.api.dataset.table.Result
 
getLong(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
getLong(String, long) - Method in class co.cask.cdap.api.dataset.table.Result
 
getLong(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getLong(byte[], long) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getLong(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getLong(String, long) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getLongProperty(String, long) - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Lookup a custom property of the dataset.
getLookups() - Method in class co.cask.cdap.api.macro.Macros
 
getLower() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Condition
 
getMacroFunctions() - Method in class co.cask.cdap.api.macro.Macros
 
getMacros() - Method in class co.cask.cdap.api.plugin.PluginProperties
 
getMainClassName() - Method in class co.cask.cdap.api.spark.SparkSpecification
Returns the main class name for the Spark program.
getMajor() - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
getMapperResources() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getMapReduce() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getMapReduceManager(String) - Method in interface co.cask.cdap.test.ApplicationManager
Returns a ProgramManager, without starting the program
getMapSchema() - Method in class co.cask.cdap.api.data.schema.Schema
 
getMaxAllowedGap() - Method in interface co.cask.cdap.api.dataset.lib.cube.Interpolator
Data points that are more than this many seconds apart will not cause interpolation to occur and will instead return 0 for any point in between.
getMaxAllowedGap() - Method in class co.cask.cdap.api.dataset.lib.cube.Interpolators.BaseInterpolator
 
getMaxConcurrentRuns() - Method in class co.cask.cdap.api.schedule.RunConstraints
 
getMaxRetries() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerConfiguration
 
getMaxSize() - Method in class co.cask.cdap.etl.api.CacheConfig
 
getMaxWorkingSetSize() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerConfiguration
 
getMeasurements() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
 
getMeasurements() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getMeasureName() - Method in class co.cask.cdap.api.dataset.lib.cube.TimeSeries
 
getMeasureNames() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
 
getMemoryMB() - Method in class co.cask.cdap.api.Resources
Returns the memory size in MB.
getMessage() - Method in interface co.cask.cdap.api.common.HttpErrorStatusProvider
Gives the error message.
getMessage() - Method in class co.cask.cdap.api.flow.flowlet.FailureReason
Message associated with error.
getMessageFetcher() - Method in interface co.cask.cdap.api.messaging.MessagingContext
Returns an instance of MessageFetcher for fetching messages.
getMessagePublisher() - Method in interface co.cask.cdap.api.messaging.MessagingContext
Returns an instance of MessagePublisher for publishing messages.
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.api.spark.JavaSparkExecutionContext
Returns a MessagingContext which can be used to interact with the transactional messaging system.
getMessagingContext() - Method in class co.cask.cdap.test.TestBase
Returns a MessagingContext for interacting with the messaging system.
getMetaClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getMetadata() - Method in interface co.cask.cdap.api.dataset.lib.PartitionDetail
Gets the metadata for the partition
getMetadata() - Method in class co.cask.cdap.api.security.store.SecureStoreData
 
getMethod() - Method in interface co.cask.cdap.api.service.http.HttpServiceRequest
 
getMethod() - Method in class co.cask.cdap.api.service.http.ServiceHttpEndpoint
 
getMetricName() - Method in class co.cask.cdap.api.metrics.MetricTimeSeries
 
getMetricNames() - Method in class co.cask.cdap.api.metrics.MetricDeleteQuery
 
getMetrics() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getMetrics() - Method in class co.cask.cdap.api.metrics.MetricValues
 
getMetrics() - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Returns a Serializable Metrics which can be used to emit custom metrics from user's Spark program.
getMetrics() - Method in interface co.cask.cdap.api.spark.SparkClientContext
Returns a Metrics which can be used to emit custom metrics.
getMetrics() - Method in interface co.cask.cdap.etl.api.StageContext
Get an instance of StageMetrics, used to collect metrics for this stage.
getMetrics() - Method in interface co.cask.cdap.test.ServiceManager
 
getMetricsClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getMetricsContext() - Method in class co.cask.cdap.api.logging.AppenderContext
Returns a MetricsContext for emitting metrics.
getMetricsManager() - Method in class co.cask.cdap.test.TestBase
 
getMinor() - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
getMonitorClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getMultiInputStageConfigurer() - Method in interface co.cask.cdap.etl.api.MultiInputPipelineConfigurer
Get multi input stage configurer for the pipeline stage
getName() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getName() - Method in class co.cask.cdap.api.artifact.ArtifactId
 
getName() - Method in interface co.cask.cdap.api.customaction.CustomActionSpecification
 
getName() - Method in class co.cask.cdap.api.data.batch.Input
 
getName() - Method in class co.cask.cdap.api.data.batch.Output
 
getName() - Method in class co.cask.cdap.api.data.format.FormatSpecification
 
getName() - Method in class co.cask.cdap.api.data.schema.Schema.Field
 
getName() - Method in class co.cask.cdap.api.data.stream.StreamSpecification
Returns the name of the Stream.
getName() - Method in interface co.cask.cdap.api.dataset.DatasetDefinition
 
getName() - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Returns the name of the dataset.
getName() - Method in class co.cask.cdap.api.dataset.lib.AbstractDataset
 
getName() - Method in class co.cask.cdap.api.dataset.lib.AbstractDatasetDefinition
 
getName() - Method in class co.cask.cdap.api.dataset.lib.cube.DimensionValue
 
getName() - Method in class co.cask.cdap.api.dataset.lib.cube.Measurement
 
getName() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletContext
 
getName() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletSpecification
 
getName() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getName() - Method in class co.cask.cdap.api.metrics.MetricValue
 
getName() - Method in class co.cask.cdap.api.metrics.TagValue
 
getName() - Method in class co.cask.cdap.api.plugin.PluginClass
Returns name of the plugin.
getName() - Method in class co.cask.cdap.api.plugin.PluginPropertyField
Returns name of the property.
getName() - Method in interface co.cask.cdap.api.preview.DataTracer
Return the name of the tracer instance.
getName() - Method in interface co.cask.cdap.api.ProgramSpecification
 
getName() - Method in class co.cask.cdap.api.schedule.Schedule
 
getName() - Method in class co.cask.cdap.api.security.store.SecureStoreMetadata
 
getName() - Method in class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
 
getName() - Method in class co.cask.cdap.api.service.ServiceSpecification
 
getName() - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getName() - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getName() - Method in interface co.cask.cdap.api.workflow.WorkflowActionSpecification
Deprecated.
 
getName() - Method in interface co.cask.cdap.api.workflow.WorkflowInfo
 
getName() - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
 
getNamespace() - Method in class co.cask.cdap.api.data.batch.Input
 
getNamespace() - Method in class co.cask.cdap.api.data.batch.Output
 
getNamespace() - Method in exception co.cask.cdap.api.messaging.MessagingException
 
getNamespace() - Method in interface co.cask.cdap.api.RuntimeContext
 
getNamespace() - Method in interface co.cask.cdap.etl.api.action.ActionContext
 
getNamespaceAdmin() - Static method in class co.cask.cdap.test.TestBase
Returns a NamespaceAdmin to interact with namespaces.
getNamespaceClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getNamespaceId() - Method in class co.cask.cdap.api.dataset.DatasetContext
Returns the namespace for a dataset
getNamespacePreferences(Id.Namespace, boolean) - Method in class co.cask.cdap.client.PreferencesClient
getNamespacePreferences(NamespaceId, boolean) - Method in class co.cask.cdap.client.PreferencesClient
Returns the Preferences stored at the Namespace Level.
getNodeId() - Method in interface co.cask.cdap.api.workflow.WorkflowInfo
 
getNodeId() - Method in class co.cask.cdap.api.workflow.WorkflowNode
 
getNodeId() - Method in class co.cask.cdap.api.workflow.WorkflowNodeState
Return the id of the node for which the state is maintained.
getNodeIdMap() - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
Return the map of the node id to the WorkflowNode.
getNodeName() - Method in class co.cask.cdap.api.workflow.NodeValue
 
getNodes() - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
Return the list of nodes in the Workflow.
getNodeStates() - Method in interface co.cask.cdap.api.workflow.WorkflowContext
Return an immutable Map of node ids to WorkflowNodeState.
getNodeStates() - Method in interface co.cask.cdap.etl.api.batch.BatchActionContext
Return an immutable Map of node ids to WorkflowNodeState.
getNodeStatus() - Method in class co.cask.cdap.api.workflow.WorkflowNodeState
Return the status of the node for which the state is maintained.
getNonNullable() - Method in class co.cask.cdap.api.data.schema.Schema
Assuming this is a union of a null and one non-null type, return the non-null schema.
getNumFailures() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.ConsumablePartition
 
getNumFailures() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
getObjectSchema(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.ObjectMappedTableProperties
 
getObjectTypeRepresentation(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.ObjectMappedTableProperties
 
getOrigin() - Method in interface co.cask.cdap.api.flow.flowlet.InputContext
 
getOriginalProperties() - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Return the original properties with which the dataset was created/reconfigured.
getOutputDataSet() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getOutputFormat(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getOutputFormatClassName() - Method in interface co.cask.cdap.api.data.batch.OutputFormatProvider
 
getOutputFormatConfiguration() - Method in interface co.cask.cdap.api.data.batch.OutputFormatProvider
 
getOutputFormatProvider() - Method in class co.cask.cdap.api.data.batch.Output.OutputFormatProviderOutput
 
getOutputLocation() - Method in interface co.cask.cdap.api.dataset.lib.FileSet
Allows direct access to files in the output location, in the underlying file system.
getOutputPartitionKey(Map<String, String>, Partitioning) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
 
getOutputPartitionMetadata(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
 
getOutputPartitionTime(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.TimePartitionedFileSetArguments
 
getOutputPath(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetArguments
 
getOutputPathFormat(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.TimePartitionedFileSetArguments
This is the file extension for each partition when using TimePartitionedFileSet as an OutputFormatProvider.
getOutputPathTimeZone(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.TimePartitionedFileSetArguments
This is the time zone used to format the date for the output partition.
getOutputProperties(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getOutputs() - Method in class co.cask.cdap.api.flow.FlowletDefinition
 
getOutputSchema() - Method in interface co.cask.cdap.etl.api.StageContext
Return the output schema of the stage, as set by this stage when the pipeline was deployed.
getPartition(PartitionKey) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Return the partition for a specific partition key, or null if key is not found.
getPartitionByTime(long) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Return the partition associated with the given time, rounded to the minute; or null if no such partition exists.
getPartitionConsumerState() - Method in class co.cask.cdap.api.dataset.lib.PartitionConsumerResult
 
getPartitionedFileSet() - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
 
getPartitionedFileSetName() - Method in exception co.cask.cdap.api.dataset.PartitionNotFoundException
 
getPartitioning() - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Get the partitioning declared for the file set.
getPartitioning(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetProperties
Read the partitioning for a PartitionedFileSet from its properties.
getPartitionKey(K, V) - Method in class co.cask.cdap.api.dataset.lib.DynamicPartitioner
Determine the PartitionKey for the key-value pair to be written to.
getPartitionKey() - Method in interface co.cask.cdap.api.dataset.lib.Partition
 
getPartitionKey() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.ConsumablePartition
 
getPartitionKey() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
getPartitionKey() - Method in exception co.cask.cdap.api.dataset.PartitionNotFoundException
 
getPartitionOutput(PartitionKey) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Return a partition output for a specific partition key, in preparation for creating a new partition.
getPartitionOutput(long) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Return a partition output for a specific time, rounded to the minute, in preparation for creating a new partition.
getPartitionPredicate() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerConfiguration
 
getPartitions() - Method in class co.cask.cdap.api.dataset.lib.PartitionConsumerResult
 
getPartitions() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerWorkingSet
 
getPartitions() - Method in class co.cask.cdap.api.dataset.lib.partitioned.PartitionConsumerResult
 
getPartitions(PartitionFilter) - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Return all partitions matching the partition filter.
getPartitionsByTime(long, long) - Method in interface co.cask.cdap.api.dataset.lib.TimePartitionedFileSet
Return all partitions within the time range given by startTime (inclusive) and endTime (exclusive), both rounded to the full minute.
getPath() - Method in class co.cask.cdap.api.service.http.ServiceHttpEndpoint
 
getPayload() - Method in interface co.cask.cdap.api.messaging.Message
Returns the message payload.
getPayloadAsString(Charset) - Method in interface co.cask.cdap.api.messaging.Message
Returns the message payload as a string decoded with the given Charset.
getPayloadAsString() - Method in interface co.cask.cdap.api.messaging.Message
Returns the message payload as a UTF-8 string.
getPluginClass() - Method in class co.cask.cdap.api.plugin.Plugin
 
getPluginContext() - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Returns a Serializable PluginContext which can be used to request for plugins instances.
getPluginContext() - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Returns a Serializable PluginContext which can be used to request for plugins instances.
getPluginInfo(Id.Artifact, String, String) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getPluginInfo(ArtifactId, String, String) - Method in class co.cask.cdap.client.ArtifactClient
Gets all the plugins of the given type and name available to the given artifact.
getPluginInfo(Id.Artifact, String, String, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
getPluginInfo(ArtifactId, String, String, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Gets all the plugins of the given type and name available to the given artifact.
getPluginProperties(String) - Method in interface co.cask.cdap.api.plugin.PluginContext
Gets the PluginProperties associated with the given plugin id.
getPluginProperties() - Method in interface co.cask.cdap.etl.api.StageContext
Gets the PluginProperties associated with the stage.
getPluginProperties(String) - Method in interface co.cask.cdap.etl.api.StageContext
Gets the PluginProperties associated with the given plugin id.
getPlugins() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getPlugins(ApplicationId) - Method in class co.cask.cdap.client.ApplicationClient
Get plugins in the specified application.
getPlugins() - Method in interface co.cask.cdap.test.ApplicationManager
Returns the list of plugins used in the application.
getPluginSummaries(Id.Artifact, String) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getPluginSummaries(ArtifactId, String) - Method in class co.cask.cdap.client.ArtifactClient
Gets all the plugins of the given type available to the given artifact.
getPluginSummaries(Id.Artifact, String, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
getPluginSummaries(ArtifactId, String, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Gets all the plugins of the given type available to the given artifact.
getPluginTypes(Id.Artifact) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getPluginTypes(ArtifactId) - Method in class co.cask.cdap.client.ArtifactClient
Gets all the plugin types available to a specific artifact.
getPluginTypes(Id.Artifact, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Deprecated.
getPluginTypes(ArtifactId, ArtifactScope) - Method in class co.cask.cdap.client.ArtifactClient
Gets all the plugin types available to a specific artifact.
getPort() - Method in class co.cask.cdap.client.config.ConnectionConfig
 
getPredicateClassName() - Method in class co.cask.cdap.api.workflow.WorkflowConditionNode
 
getPreviewManager() - Static method in class co.cask.cdap.test.TestBase
Returns a PreviewManager to interact with preview.
getProcessed() - Method in interface co.cask.cdap.api.metrics.RuntimeMetrics
 
getProcessState() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.ConsumablePartition
 
getProcessState() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
getProgram() - Method in class co.cask.cdap.api.schedule.ScheduleSpecification
 
getProgram() - Method in class co.cask.cdap.api.workflow.WorkflowActionNode
 
getProgramClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getProgramLogs(Id.Program, long, long) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
getProgramLogs(ProgramId, long, long) - Method in class co.cask.cdap.client.ProgramClient
Gets the logs of a program.
getProgramName() - Method in class co.cask.cdap.api.workflow.ScheduleProgramInfo
 
getProgramPreferences(Id.Program, boolean) - Method in class co.cask.cdap.client.PreferencesClient
getProgramPreferences(ProgramId, boolean) - Method in class co.cask.cdap.client.PreferencesClient
Returns the Preferences stored at the Program Level.
getProgramRuns(Id.Program, String, long, long, int) - Method in class co.cask.cdap.client.ProgramClient
getProgramRuns(ProgramId, String, long, long, int) - Method in class co.cask.cdap.client.ProgramClient
Gets the run records of a program.
getProgramType() - Method in class co.cask.cdap.api.workflow.ScheduleProgramInfo
 
getProgress() - Method in class co.cask.cdap.api.data.batch.RecordScanner
The current progress of the record reader through its data.
getProgress() - Method in class co.cask.cdap.api.data.batch.SplitReader
The current progress of the record reader through its data.
getProperties() - Method in interface co.cask.cdap.api.common.PropertyProvider
Returns an immutable Map of all properties.
getProperties() - Method in class co.cask.cdap.api.dataset.DatasetProperties
 
getProperties() - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Return map of all properties set in this specification.
getProperties() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getProperties() - Method in class co.cask.cdap.api.plugin.Plugin
Returns the set of properties available when the plugin was created.
getProperties() - Method in class co.cask.cdap.api.plugin.PluginClass
Returns a map from config property name to PluginPropertyField that are supported by the plugin class.
getProperties() - Method in class co.cask.cdap.api.plugin.PluginConfig
Returns the PluginProperties.
getProperties() - Method in class co.cask.cdap.api.plugin.PluginProperties
 
getProperties() - Method in class co.cask.cdap.api.schedule.ScheduleSpecification
 
getProperties() - Method in class co.cask.cdap.api.security.store.SecureStoreMetadata
 
getProperties() - Method in class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
 
getProperties() - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getProperties() - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getProperties() - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
 
getProperties(Id.DatasetInstance) - Method in class co.cask.cdap.client.DatasetClient
Deprecated.
since 4.0.0. Use DatasetClient.getProperties(DatasetId) instead.
getProperties(DatasetId) - Method in class co.cask.cdap.client.DatasetClient
Retrieve the properties with which a dataset was created or updated.
getProperty(String) - Method in interface co.cask.cdap.api.common.PropertyProvider
Return the property value of a given key.
getProperty(String) - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Lookup a custom property of the dataset.
getProperty(String, String) - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Lookup a custom property of the dataset.
getProperty(String) - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getProperty(String) - Method in class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
 
getProperty(String) - Method in class co.cask.cdap.api.spark.SparkSpecification
 
getProperty(String) - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getProperty(String) - Method in class co.cask.cdap.api.workflow.WorkflowSpecification
 
getProvisionedInstances() - Method in interface co.cask.cdap.test.ServiceManager
Returns the number of provisioned instances.
getQueryClient(Id.Namespace) - Method in class co.cask.cdap.test.AbstractTestManager
 
getQueryClient(NamespaceId) - Method in class co.cask.cdap.test.IntegrationTestManager
 
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(Id.Namespace) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
since 4.0.0. Use TestManager.getQueryClient(NamespaceId) instead.
getQueryClient(NamespaceId) - Method in interface co.cask.cdap.test.TestManager
 
getQueryClient(NamespaceId) - Method in class co.cask.cdap.test.UnitTestManager
 
getReadlessIncrementSupport(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getReadlessIncrementSupport(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getRecord() - Method in interface co.cask.cdap.etl.api.ErrorRecord
 
getRecordName() - Method in class co.cask.cdap.api.data.schema.Schema
 
getRecordType() - Method in interface co.cask.cdap.api.data.batch.RecordScannable
The type of records that the dataset exposes as a schema.
getRecordType() - Method in interface co.cask.cdap.api.data.batch.RecordWritable
The type of records that the dataset exposes as a schema.
getRecordType() - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
getRecordType() - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
 
getRecordType() - Method in class co.cask.cdap.client.app.FakeDataset
 
getRecordType() - Method in class co.cask.cdap.client.app.StandaloneDataset
 
getReducerResources() - Method in class co.cask.cdap.api.mapreduce.MapReduceSpecification
 
getRelativePath() - Method in interface co.cask.cdap.api.dataset.lib.Partition
 
getRequestedInstances() - Method in interface co.cask.cdap.test.ServiceManager
Returns the number of requested instances.
getRequestURI() - Method in interface co.cask.cdap.api.service.http.HttpServiceRequest
 
getRequiredInputs() - Method in class co.cask.cdap.etl.api.JoinConfig
Returns required inputs to be joined.
getResolution() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
 
getResolution() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
 
getResolution() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getResolution() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getResolution() - Method in class co.cask.cdap.api.metrics.MetricSearchQuery
 
getResources() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletSpecification
 
getResources() - Method in class co.cask.cdap.api.service.ServiceSpecification
Returns the resources requirements for the service handler.
getResources() - Method in class co.cask.cdap.api.worker.WorkerSpecification
 
getRestClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getRetryCount() - Method in interface co.cask.cdap.api.flow.flowlet.InputContext
 
getRouteConfig(ServiceId) - Method in class co.cask.cdap.client.ServiceClient
Gets RouteConfig of a service with different application versions.
getRow() - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getRow() - Method in class co.cask.cdap.api.dataset.table.Increment
 
getRow() - Method in class co.cask.cdap.api.dataset.table.Put
 
getRow() - Method in class co.cask.cdap.api.dataset.table.Result
 
getRow() - Method in interface co.cask.cdap.api.dataset.table.Row
 
getRow() - Method in class co.cask.cdap.api.dataset.table.RowColumns
 
getRowFieldName(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getRowFieldName(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getRowKeyExploreName(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.ObjectMappedTableProperties
 
getRowKeyExploreType(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.ObjectMappedTableProperties
 
getRunConstraints() - Method in class co.cask.cdap.api.schedule.Schedule
 
getRunId() - Method in interface co.cask.cdap.api.RuntimeContext
 
getRunId() - Method in interface co.cask.cdap.api.workflow.WorkflowInfo
 
getRunId() - Method in class co.cask.cdap.api.workflow.WorkflowNodeState
Return the run id if node represents programs, such as MapReduce or Spark.
getRuntimeArgs(Id.Program) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
since 4.0.0. Please use ProgramClient.getRuntimeArgs(ProgramId) instead
getRuntimeArgs(ProgramId) - Method in class co.cask.cdap.client.ProgramClient
Gets the runtime args of a program.
getRuntimeArgs() - Method in class co.cask.cdap.test.AbstractProgramManager
 
getRuntimeArgs(ProgramId) - Method in interface co.cask.cdap.test.ApplicationManager
Gets runtime arguments of the specified program.
getRuntimeArgs() - Method in interface co.cask.cdap.test.ProgramManager
Get runtime arguments of this program
getRuntimeArguments() - Method in interface co.cask.cdap.api.dataset.lib.FileSet
Allow direct access to the runtime arguments of this file set.
getRuntimeArguments() - Method in interface co.cask.cdap.api.dataset.lib.PartitionedFileSet
Allow direct access to the runtime arguments of this partitioned file set.
getRuntimeArguments() - Method in interface co.cask.cdap.api.RuntimeContext
 
getRuntimeArguments() - Method in interface co.cask.cdap.etl.api.batch.BatchContext
Returns runtime arguments of the Batch Job.
getRuntimeArguments() - Method in interface co.cask.cdap.etl.api.batch.BatchRuntimeContext
Returns runtime arguments of the Batch Job.
getRuntimeArguments() - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Returns runtime arguments of the Batch Job.
getSchedule() - Method in class co.cask.cdap.api.schedule.ScheduleSpecification
 
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.api.app.ApplicationSpecification
 
getSchedules() - Method in interface co.cask.cdap.api.schedule.SchedulableProgramSpecification
 
getSchedules() - Method in interface co.cask.cdap.test.WorkflowManager
Get the list of schedules of the workflow
getSchema() - Method in class co.cask.cdap.api.data.format.FormatSpecification
 
getSchema() - Method in class co.cask.cdap.api.data.format.RecordFormat
Get the schema of the format.
getSchema() - Method in class co.cask.cdap.api.data.format.StructuredRecord
Get the schema of the record.
getSchema() - Method in class co.cask.cdap.api.data.schema.Schema.Field
 
getSchema(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getSchema(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getSchemaHash() - Method in class co.cask.cdap.api.data.schema.Schema
 
getScope() - Method in class co.cask.cdap.api.artifact.ArtifactId
 
getSecureData(String, String) - Method in interface co.cask.cdap.api.security.store.SecureStore
Returns the data stored in the secure store.
getSecureStore() - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Returns a Serializable SecureStore which can be used to request for plugins instances.
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.
getSerDe(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getServiceDiscoverer() - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
Returns a Serializable ServiceDiscoverer for Service Discovery in Spark Program which can be passed in Spark program's closures.
getServiceHandlerMetrics(String, String, String, String) - Method in class co.cask.cdap.test.MetricsManager
returns service handler related metrics
getServiceInstances(Id.Service) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
getServiceInstances(ServiceId) - Method in class co.cask.cdap.client.ProgramClient
Gets the number of instances of a service.
getServiceManager(String) - Method in interface co.cask.cdap.test.ApplicationManager
Returns a ProgramManager, without starting the program
getServiceMetrics(Id.Program) - Method in class co.cask.cdap.client.MetricsClient
Deprecated.
getServiceMetrics(ServiceId) - Method in class co.cask.cdap.client.MetricsClient
 
getServiceMetrics(String, String, String) - Method in class co.cask.cdap.test.MetricsManager
returns service related metrics
getServices() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getServiceURL(String, String) - Method in interface co.cask.cdap.api.ServiceDiscoverer
Discover the base URL for a Service, relative to which Service endpoints can be accessed
getServiceURL(String) - Method in interface co.cask.cdap.api.ServiceDiscoverer
Discover the base URL for a Service in the same application, relative to which Service endpoints can be accessed
getServiceURL(Id.Service) - Method in class co.cask.cdap.client.ServiceClient
getServiceURL(ServiceId) - Method in class co.cask.cdap.client.ServiceClient
Gets a URL to call methods for the endpoint of a Service with no application version.
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.
getSettings() - Method in class co.cask.cdap.api.data.format.FormatSpecification
 
getShort(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getShort(byte[], short) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getShort(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getShort(String, short) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getShort(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
getShort(byte[], short) - Method in class co.cask.cdap.api.dataset.table.Result
 
getShort(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
getShort(String, short) - Method in class co.cask.cdap.api.dataset.table.Result
 
getShort(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getShort(byte[], short) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getShort(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getShort(String, short) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getSliceByTags() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getSliceByTags() - Method in class co.cask.cdap.api.metrics.MetricDeleteQuery
 
getSlideInterval() - Method in class co.cask.cdap.etl.api.streaming.Windower
 
getSnapshotInputStream() - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
getSourceName() - Method in class co.cask.cdap.api.flow.FlowletConnection
 
getSourceNamespace() - Method in class co.cask.cdap.api.flow.FlowletConnection
 
getSourceType() - Method in class co.cask.cdap.api.flow.FlowletConnection
 
getSpark() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getSparkContext() - Method in interface co.cask.cdap.etl.api.batch.SparkExecutionPluginContext
Returns the JavaSparkContext used during the execution.
getSparkExecutionContext() - Method in interface co.cask.cdap.etl.api.streaming.StreamingContext
 
getSparkManager(String) - Method in interface co.cask.cdap.test.ApplicationManager
Returns a ProgramManager, without starting the program
getSparkStreamingContext() - Method in interface co.cask.cdap.etl.api.streaming.StreamingContext
 
getSpecification() - Method in interface co.cask.cdap.api.customaction.CustomActionContext
Return the specification of the custom action.
getSpecification(String) - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Get the specification for an embedded dataset.
getSpecification() - Method in interface co.cask.cdap.api.flow.flowlet.FlowletContext
 
getSpecification() - Method in interface co.cask.cdap.api.mapreduce.MapReduceContext
 
getSpecification() - Method in interface co.cask.cdap.api.mapreduce.MapReduceTaskContext
 
getSpecification() - Method in interface co.cask.cdap.api.service.http.HttpServiceContext
 
getSpecification() - Method in class co.cask.cdap.api.spark.JavaSparkExecutionContext
 
getSpecification() - Method in interface co.cask.cdap.api.spark.SparkClientContext
 
getSpecification() - Method in interface co.cask.cdap.api.worker.WorkerContext
Returns the specification used to configure Worker bounded to this context.
getSpecification() - Method in interface co.cask.cdap.api.workflow.WorkflowContext
 
getSpecifications() - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Get the map of embedded dataset name to DatasetSpecification
getSplits() - Method in interface co.cask.cdap.api.data.batch.BatchReadable
Returns all splits of the dataset.
getSplits() - Method in class co.cask.cdap.api.data.batch.Input.DatasetInput
 
getSplits() - Method in interface co.cask.cdap.api.data.batch.RecordScannable
Returns all splits of the dataset.
getSplits(int, byte[], byte[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
getSplits() - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
 
getSplits() - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
 
getSplits(int, byte[], byte[]) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
Returns splits for a range of keys in the table.
getSplits(int, byte[], byte[]) - Method in interface co.cask.cdap.api.dataset.lib.ObjectMappedTable
Returns splits for a range of keys in the table.
getSplits(int, byte[], byte[]) - Method in interface co.cask.cdap.api.dataset.lib.ObjectStore
Returns splits for a range of keys in the table.
getSplits() - Method in class co.cask.cdap.api.dataset.lib.TimeseriesTable
 
getSplits(int, byte[], byte[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Returns splits for a range of keys in the table.
getSplits() - Method in class co.cask.cdap.client.app.FakeDataset
 
getSplits() - Method in class co.cask.cdap.client.app.StandaloneDataset
 
getStageConfigurer() - Method in interface co.cask.cdap.etl.api.PipelineConfigurer
Get stage configurer for the pipeline stage
getStageName() - Method in interface co.cask.cdap.etl.api.ErrorRecord
 
getStageName() - Method in class co.cask.cdap.etl.api.JoinElement
Returns stage name to which input record belongs to
getStageName() - Method in interface co.cask.cdap.etl.api.StageContext
Gets the unique stage name of the transform, useful for setting the context of logging in transforms.
getStart() - Method in class co.cask.cdap.api.dataset.table.TableSplit
 
getStartRow() - Method in class co.cask.cdap.api.dataset.table.Scan
 
getStartTime() - Method in class co.cask.cdap.api.data.batch.Input.StreamInput
 
getStartTs() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery
 
getStartTs() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
 
getStartTs() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
getStartTs() - Method in class co.cask.cdap.api.metrics.MetricDataQuery
 
getStartTs() - Method in class co.cask.cdap.api.metrics.MetricDeleteQuery
 
getStartTs() - Method in class co.cask.cdap.api.metrics.MetricSearchQuery
 
getStartVersion() - Method in class co.cask.cdap.api.dataset.lib.PartitionConsumerState
 
getState() - Method in interface co.cask.cdap.api.customaction.CustomActionContext
Return the state of the custom action.
getState() - Method in interface co.cask.cdap.api.mapreduce.MapReduceContext
Return the state of the MapReduce program.
getState() - Method in interface co.cask.cdap.api.spark.SparkClientContext
Return the state of the Spark program.
getState() - Method in interface co.cask.cdap.api.workflow.WorkflowContext
Return the state of the workflow.
getState(String) - Method in class co.cask.cdap.etl.api.realtime.SourceState
Get the byte[] associated with a key.
getState() - Method in class co.cask.cdap.etl.api.realtime.SourceState
Get the full state of the Source.
getStatePersistor() - Method in class co.cask.cdap.api.dataset.lib.partitioned.AbstractPartitionConsumer
 
getStatus() - Method in class co.cask.cdap.api.ProgramState
Return the ProgramStatus of the program.
getStatus(Id.Program) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
since 4.0.0. Please use ProgramClient.getStatus(ProgramId) instead
getStatus(ProgramId) - Method in class co.cask.cdap.client.ProgramClient
Gets the status of a program
getStatus(Id.Namespace, List<BatchProgram>) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
getStatus(NamespaceId, List<BatchProgram>) - Method in class co.cask.cdap.client.ProgramClient
Gets the status of multiple programs.
getStatus(ScheduleId) - Method in class co.cask.cdap.client.ScheduleClient
 
getStatusCode() - Method in interface co.cask.cdap.api.common.HttpErrorStatusProvider
Gives the HTTP status code for this error.
getStop() - Method in class co.cask.cdap.api.dataset.table.TableSplit
 
getStopRow() - Method in class co.cask.cdap.api.dataset.table.Scan
 
getStream(StreamingContext) - Method in class co.cask.cdap.etl.api.streaming.StreamingSource
Get the stream to read from.
getStreamClient() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getStreamManager(Id.Stream) - Method in class co.cask.cdap.test.AbstractTestManager
 
getStreamManager(StreamId) - Method in class co.cask.cdap.test.IntegrationTestManager
 
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(Id.Stream) - Method in interface co.cask.cdap.test.TestManager
Deprecated.
since 4.0.0. Use TestManager.getStreamManager(StreamId) instead.
getStreamManager(StreamId) - Method in interface co.cask.cdap.test.TestManager
Returns a StreamManager for the specified Id.Stream.
getStreamManager(StreamId) - Method in class co.cask.cdap.test.UnitTestManager
 
getStreamName() - Method in class co.cask.cdap.client.app.ConfigTestApp.ConfigClass
 
getStreams() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getStreams() - Method in class co.cask.cdap.api.flow.FlowletDefinition
Deprecated.
getString(byte[]) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getString(String) - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
getString(byte[]) - Method in class co.cask.cdap.api.dataset.table.Result
 
getString(String) - Method in class co.cask.cdap.api.dataset.table.Result
 
getString(byte[]) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getString(String) - Method in interface co.cask.cdap.api.dataset.table.Row
 
getSuffix() - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
getSystemServiceInstances(String) - Method in class co.cask.cdap.client.MonitorClient
Gets the number of instances the system service is running on.
getSystemServiceLiveInfo(String) - Method in class co.cask.cdap.client.MonitorClient
Gets the live info of a system service.
getSystemServiceStatus(String) - Method in class co.cask.cdap.client.MonitorClient
Gets the status of a system service.
getTable(String) - Method in class co.cask.cdap.etl.api.LookupConfig
 
getTableName() - Method in class co.cask.cdap.client.app.ConfigTestApp.ConfigClass
 
getTablePermissions(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getTableProperties(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
getTags() - Method in class co.cask.cdap.api.dataset.lib.CounterTimeseriesTable.Counter
Returns the tags associated with the counter.
getTags() - Method in interface co.cask.cdap.api.metrics.MetricsContext
 
getTags() - Method in class co.cask.cdap.api.metrics.MetricValues
 
getTags() - Method in class co.cask.cdap.api.metrics.NoopMetricsContext
 
getTagValues() - Method in class co.cask.cdap.api.metrics.MetricSearchQuery
 
getTagValues() - Method in class co.cask.cdap.api.metrics.MetricTimeSeries
 
getTargetName() - Method in class co.cask.cdap.api.flow.FlowletConnection
 
getTestManager() - Method in class co.cask.cdap.test.IntegrationTestBase
 
getTestManager(ClientConfig, RESTClient) - Method in class co.cask.cdap.test.IntegrationTestBase
 
getTime() - Method in interface co.cask.cdap.api.dataset.lib.TimePartition
 
getTimeout() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerConfiguration
Defines an expiration timeout, in seconds, of IN_PROGRESS partitions
getTimestamp() - Method in class co.cask.cdap.api.dataset.lib.CounterTimeseriesTable.Counter
Returns the timestamp of the counter.
getTimestamp() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeFact
 
getTimestamp() - Method in class co.cask.cdap.api.dataset.lib.cube.TimeValue
 
getTimestamp() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.ConsumablePartition
 
getTimestamp() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
getTimestamp() - Method in class co.cask.cdap.api.flow.flowlet.StreamEvent
 
getTimestamp() - Method in class co.cask.cdap.api.metrics.MetricValues
 
getTimeValues() - Method in class co.cask.cdap.api.dataset.lib.cube.TimeSeries
 
getTimeValues() - Method in class co.cask.cdap.api.metrics.MetricTimeSeries
 
getToken() - Method in interface co.cask.cdap.api.workflow.WorkflowContext
 
getToken() - Method in interface co.cask.cdap.etl.api.batch.BatchActionContext
 
getToken(String, WorkflowToken.Scope, String) - Method in interface co.cask.cdap.test.WorkflowManager
Get the WorkflowTokenDetail for the specified workflow run.
getTokenAtNode(String, String, WorkflowToken.Scope, String) - Method in interface co.cask.cdap.test.WorkflowManager
Returns the WorkflowTokenNodeDetail for the specified workflow run at the specified node.
getTopic() - Method in exception co.cask.cdap.api.messaging.MessagingException
 
getTopicProperties(String) - Method in interface co.cask.cdap.api.messaging.MessagingAdmin
Returns the properties of a topic.
getTotalMetric(Map<String, String>, String) - Method in class co.cask.cdap.test.MetricsManager
get metrics total count value for a given context and metric.
getTransactionAwareName() - Method in class co.cask.cdap.api.dataset.lib.AbstractDataset
 
getTTL(DatasetProperties) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getTTL(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
getTxChanges() - Method in class co.cask.cdap.api.dataset.lib.AbstractDataset
 
getTxService() - Method in class co.cask.cdap.test.TestBase
 
getType() - Method in class co.cask.cdap.api.data.schema.Schema
 
getType() - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Returns the type of the dataset.
getType() - Method in class co.cask.cdap.api.dataset.lib.cube.Measurement
 
getType() - Method in class co.cask.cdap.api.flow.flowlet.FailureReason
Returns the type of failure.
getType() - Method in class co.cask.cdap.api.metrics.MetricValue
 
getType() - Method in class co.cask.cdap.api.plugin.PluginClass
Returns the type name of the plugin.
getType() - Method in class co.cask.cdap.api.plugin.PluginPropertyField
Returns the type of the property.
getType() - Method in class co.cask.cdap.api.workflow.WorkflowNode
 
getType() - Method in class co.cask.cdap.etl.api.LookupTableConfig
 
getUnavailableRetryLimit() - Method in class co.cask.cdap.client.config.ClientConfig
 
getUnionSchema(int) - Method in class co.cask.cdap.api.data.schema.Schema
 
getUnionSchemas() - Method in class co.cask.cdap.api.data.schema.Schema
 
getUploadConnectTimeout() - Method in class co.cask.cdap.client.config.ClientConfig
 
getUploadReadTimeout() - Method in class co.cask.cdap.client.config.ClientConfig
 
getUploadRequestConfig() - Method in class co.cask.cdap.client.config.ClientConfig
 
getUpper() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Condition
 
getURI() - Method in class co.cask.cdap.client.config.ConnectionConfig
 
getValidator() - Method in interface co.cask.cdap.etl.api.Validator
Gets the Validator Object, on which the validator function's can be invoked from user-code.
getValidatorName() - Method in interface co.cask.cdap.etl.api.Validator
Name used as variable name for the Object returned by Validator.getValidator().
getValue() - Method in class co.cask.cdap.api.dataset.lib.CounterTimeseriesTable.Counter
Returns the count value of the counter.
getValue() - Method in class co.cask.cdap.api.dataset.lib.cube.DimensionValue
 
getValue() - Method in class co.cask.cdap.api.dataset.lib.cube.Measurement
 
getValue() - Method in class co.cask.cdap.api.dataset.lib.cube.TimeValue
 
getValue() - Method in class co.cask.cdap.api.dataset.lib.KeyValue
 
getValue() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Condition
 
getValue() - Method in class co.cask.cdap.api.metrics.MetricValue
 
getValue() - Method in class co.cask.cdap.api.metrics.TagValue
 
getValue() - Method in class co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult
 
getValue() - Method in class co.cask.cdap.api.workflow.NodeValue
 
getValues() - Method in class co.cask.cdap.api.dataset.table.Increment
 
getValues() - Method in class co.cask.cdap.api.dataset.table.Put
 
getVersion() - Method in class co.cask.cdap.api.artifact.ArtifactId
 
getVersion() - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
getVersion() - Method in class co.cask.cdap.client.MetaClient
 
getVersionedServiceURL(ServiceId) - Method in class co.cask.cdap.client.ServiceClient
Gets a URL to call methods for a specific version of a Service.
getVersionsToCheck() - Method in class co.cask.cdap.api.dataset.lib.PartitionConsumerState
 
getVirtualCores() - Method in class co.cask.cdap.api.Resources
Returns the number of virtual cores.
getWidth() - Method in class co.cask.cdap.etl.api.streaming.Windower
 
getWorkerInstances(Id.Worker) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
getWorkerInstances(ProgramId) - Method in class co.cask.cdap.client.ProgramClient
Gets the number of instances that a worker is currently running on.
getWorkerManager(String) - Method in interface co.cask.cdap.test.ApplicationManager
Returns a ProgramManager, without starting the program
getWorkers() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getWorkflowCurrent(Id.Application, String, String) - Method in class co.cask.cdap.client.ProgramClient
Deprecated.
getWorkflowCurrent(WorkflowId, String) - Method in class co.cask.cdap.client.ProgramClient
Get the current run information for the Workflow based on the runid
getWorkflowInfo() - Method in interface co.cask.cdap.api.mapreduce.MapReduceTaskContext
 
getWorkflowInfo() - Method in interface co.cask.cdap.api.workflow.WorkflowInfoProvider
 
getWorkflowLocalDatasets(ProgramRunId) - Method in class co.cask.cdap.client.WorkflowClient
Get the local datasets associated with the Workflow run.
getWorkflowManager(String) - Method in interface co.cask.cdap.test.ApplicationManager
Returns a ProgramManager, without starting the program
getWorkflowNodeStates(ProgramRunId) - Method in class co.cask.cdap.client.WorkflowClient
Get node states associated with the Workflow run.
getWorkflowNodeStates(String) - Method in interface co.cask.cdap.test.WorkflowManager
Get node stated for the specified Workflow run.
getWorkflows() - Method in interface co.cask.cdap.api.app.ApplicationSpecification
 
getWorkflowSpecification() - Method in interface co.cask.cdap.api.workflow.WorkflowContext
 
getWorkflowToken() - Method in interface co.cask.cdap.api.mapreduce.MapReduceTaskContext
 
getWorkflowToken() - Method in interface co.cask.cdap.api.workflow.WorkflowInfoProvider
 
getWorkflowToken(Id.Run) - Method in class co.cask.cdap.client.WorkflowClient
Deprecated.
getWorkflowToken(ProgramRunId) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve the entire WorkflowToken for the specified workflow run.
getWorkflowToken(Id.Run, WorkflowToken.Scope) - Method in class co.cask.cdap.client.WorkflowClient
getWorkflowToken(ProgramRunId, WorkflowToken.Scope) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve all the keys in the WorkflowToken with the specified scope for the specified workflow run.
getWorkflowToken(Id.Run, String) - Method in class co.cask.cdap.client.WorkflowClient
getWorkflowToken(ProgramRunId, String) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve the specified key from the WorkflowToken for the specified workflow run.
getWorkflowToken(Id.Run, WorkflowToken.Scope, String) - Method in class co.cask.cdap.client.WorkflowClient
getWorkflowToken(ProgramRunId, WorkflowToken.Scope, String) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve the WorkflowToken for the specified workflow run filtered by the specified WorkflowToken.Scope and key.
getWorkflowTokenAtNode(Id.Run, String) - Method in class co.cask.cdap.client.WorkflowClient
getWorkflowTokenAtNode(ProgramRunId, String) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve all the key-value pairs in a workflow run's WorkflowToken that were set by the specified node.
getWorkflowTokenAtNode(Id.Run, String, WorkflowToken.Scope) - Method in class co.cask.cdap.client.WorkflowClient
getWorkflowTokenAtNode(ProgramRunId, String, WorkflowToken.Scope) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve all the key-value pairs in a workflow run's WorkflowToken that were set by the specified node in the specified WorkflowToken.Scope.
getWorkflowTokenAtNode(Id.Run, String, String) - Method in class co.cask.cdap.client.WorkflowClient
getWorkflowTokenAtNode(ProgramRunId, String, String) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve the specified key set by the specified node in a specified workflow run's WorkflowToken.
getWorkflowTokenAtNode(Id.Run, String, WorkflowToken.Scope, String) - Method in class co.cask.cdap.client.WorkflowClient
getWorkflowTokenAtNode(ProgramRunId, String, WorkflowToken.Scope, String) - Method in class co.cask.cdap.client.WorkflowClient
Retrieve the keys set by the specified node in the WorkflowToken for the specified workflow run filtered by the specified WorkflowToken.Scope and key.
grant(EntityId, Principal, Set<Action>) - Method in class co.cask.cdap.client.AuthorizationClient
 
GROK - Static variable in class co.cask.cdap.api.data.format.Formats
 
groupBy() - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.GroupBy
 
groupBy(GROUP_VALUE, Emitter<GROUP_KEY>) - Method in interface co.cask.cdap.etl.api.Aggregator
Emit the group key(s) for a given input value.

H

handler(HttpServiceRequest, HttpServiceResponder) - Method in class co.cask.cdap.client.app.AppReturnsArgs.ArgService
 
has(String) - Method in interface co.cask.cdap.etl.api.action.SettableArguments
Returns true if specified argument is provided, otherwise false is returned.
hashBytes(byte[], int, int) - Static method in class co.cask.cdap.api.common.Bytes
Compute hash for binary data.
hashBytes(byte[], int) - Static method in class co.cask.cdap.api.common.Bytes
Compute hash for binary data.
hashCode() - Method in class co.cask.cdap.api.artifact.ArtifactId
 
hashCode() - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
hashCode(byte[]) - Static method in class co.cask.cdap.api.common.Bytes
Compute hash for binary data.
hashCode(byte[], int) - Static method in class co.cask.cdap.api.common.Bytes
Compute hash for binary data.
hashCode(byte[], int, int) - Static method in class co.cask.cdap.api.common.Bytes
 
hashCode() - Method in class co.cask.cdap.api.data.format.FormatSpecification
 
hashCode() - Method in class co.cask.cdap.api.data.format.StructuredRecord
 
hashCode() - Method in class co.cask.cdap.api.data.schema.Schema
 
hashCode() - Method in class co.cask.cdap.api.data.schema.SchemaHash
 
hashCode() - Method in class co.cask.cdap.api.data.stream.StreamSpecification
 
hashCode() - Method in class co.cask.cdap.api.dataset.DatasetSpecification
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.cube.DimensionValue
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.cube.TimeSeries
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.cube.TimeValue
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.PartitionConsumerState
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.partitioned.ConsumerWorkingSet
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Condition
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.PartitionKey
 
hashCode() - Method in class co.cask.cdap.api.dataset.lib.PartitionMetadata
 
hashCode() - Method in class co.cask.cdap.api.metrics.MetricTimeSeries
 
hashCode() - Method in class co.cask.cdap.api.metrics.TagValue
 
hashCode() - Method in class co.cask.cdap.api.plugin.Plugin
 
hashCode() - Method in class co.cask.cdap.api.plugin.PluginClass
 
hashCode() - Method in class co.cask.cdap.api.plugin.PluginPropertyField
 
hashCode() - Method in class co.cask.cdap.api.Resources
 
hashCode() - Method in class co.cask.cdap.api.schedule.RunConstraints
 
hashCode() - Method in class co.cask.cdap.api.schedule.Schedule
 
hashCode() - Method in class co.cask.cdap.api.schedule.ScheduleSpecification
 
hashCode() - Method in class co.cask.cdap.api.security.store.SecureStoreMetadata
 
hashCode() - Method in class co.cask.cdap.api.service.http.ServiceHttpEndpoint
 
hashCode() - Method in class co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult
 
hashCode() - Method in class co.cask.cdap.api.workflow.NodeValue
 
hashCode() - Method in class co.cask.cdap.api.workflow.ScheduleProgramInfo
 
hashCode() - Method in class co.cask.cdap.api.workflow.Value
 
hashCode() - Method in class co.cask.cdap.client.config.ConnectionConfig
 
hashCode() - Method in class co.cask.cdap.etl.api.realtime.SourceState
 
HashPartition - Annotation Type in co.cask.cdap.api.annotation
Defines the strategy used when reading data from a Flowlet's input as hash partitioning.
hasNext() - Method in class co.cask.cdap.api.dataset.lib.AbstractCloseableIterator
 
hasType(String) - Method in interface co.cask.cdap.api.dataset.module.DatasetDefinitionRegistry
 
head(byte[], int) - Static method in class co.cask.cdap.api.common.Bytes
Returns first length bytes from byte array.
HttpContentConsumer - Class in co.cask.cdap.api.service.http
An instance of this class is for consuming an HTTP request body incrementally.
HttpContentConsumer() - Constructor for class co.cask.cdap.api.service.http.HttpContentConsumer
 
HttpContentProducer - Class in co.cask.cdap.api.service.http
Instance of this class is for producing an HTTP response body in small chunks to avoid running out of memory when responding with a large body.
HttpContentProducer() - Constructor for class co.cask.cdap.api.service.http.HttpContentProducer
 
HttpErrorStatusProvider - Interface in co.cask.cdap.api.common
Interface to be used by all error related classes which needs to provide a status code.
HttpServiceConfigurer - Interface in co.cask.cdap.api.service.http
Interface which should be implemented to configure a HttpServiceHandler
HttpServiceContext - Interface in co.cask.cdap.api.service.http
The context for a HttpServiceHandler.
HttpServiceHandler - Interface in co.cask.cdap.api.service.http
Interface to be implemented to handle HTTP requests.
HttpServiceHandlerSpecification - Class in co.cask.cdap.api.service.http
Specification for a HttpServiceHandler.
HttpServiceHandlerSpecification(String, String, String, Map<String, String>, Set<String>, List<ServiceHttpEndpoint>) - Constructor for class co.cask.cdap.api.service.http.HttpServiceHandlerSpecification
Create an instance of HttpServiceHandlerSpecification.
HttpServiceRequest - Interface in co.cask.cdap.api.service.http
Interface with methods for processing HTTP requests.
HttpServiceResponder - Interface in co.cask.cdap.api.service.http
Interface with methods for sending HTTP responses.

I

IncompatibleUpdateException - Exception in co.cask.cdap.api.dataset
Exception thrown when a dataset instance is reconfigured in an incompatible way.
IncompatibleUpdateException(String) - Constructor for exception co.cask.cdap.api.dataset.IncompatibleUpdateException
 
increment(byte[], long, long, byte[]...) - Method in class co.cask.cdap.api.dataset.lib.CounterTimeseriesTable
Increments the value for a counter for a row and timestamp.
increment(byte[], byte[], long) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Increments (atomically) the specified row and column by the specified amount, without returning the new value.
increment(byte[], byte[][], long[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Increments (atomically) the specified row and columns by the specified amounts, without returning the new values.
increment(Increment) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Increments (atomically) the specified row and columns by the specified amounts, without returning the new values.
increment(byte[], long) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
Increment the value of a key by amount; the key must either not exist yet, or the current value at the key must be 8 bytes long to be interpretable as a long.
Increment - Class in co.cask.cdap.api.dataset.table
An Increment interprets the values of columns as 8-byte integers and increments them by the specified value.
Increment(byte[]) - Constructor for class co.cask.cdap.api.dataset.table.Increment
Changes the values of columns in a row.
Increment(byte[], byte[], long) - Constructor for class co.cask.cdap.api.dataset.table.Increment
Changes the value of at least one column in a row.
Increment(String) - Constructor for class co.cask.cdap.api.dataset.table.Increment
Changes the values of all of the columns in a row.
Increment(String, String, long) - Constructor for class co.cask.cdap.api.dataset.table.Increment
Changes the value of at least one column in a row.
increment(byte[], byte[], long) - Method in interface co.cask.cdap.api.dataset.table.Table
Increments (atomically) the specified row and columns by the specified amounts, without returning the new value.
increment(byte[], byte[][], long[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Increments (atomically) the specified row and columns by the specified amounts, without returning the new values.
increment(Increment) - Method in interface co.cask.cdap.api.dataset.table.Table
Increments (atomically) the specified row and columns by the specified amounts, without returning the new values.
increment(String, long) - Method in interface co.cask.cdap.api.metrics.MetricsCollector
Increment a metric value at the current time.
increment(String, long) - Method in class co.cask.cdap.api.metrics.NoopMetricsContext
 
incrementAndGet(byte[], byte[], long) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Increments (atomically) the specified row and column by the specified amount, and returns the new value.
incrementAndGet(byte[], byte[][], long[]) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Increments (atomically) the specified row and columns by the specified amounts, and returns the new values.
incrementAndGet(Increment) - Method in class co.cask.cdap.api.dataset.lib.IndexedTable
Increments (atomically) the specified row and columns by the specified amounts, and returns the new values.
incrementAndGet(byte[], long) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable
Increment the value for a given key and return the resulting value.
incrementAndGet(byte[], byte[], long) - Method in interface co.cask.cdap.api.dataset.table.Table
Increments the specified column of the row by the specified amount and returns the new value.
incrementAndGet(byte[], byte[][], long[]) - Method in interface co.cask.cdap.api.dataset.table.Table
Increments the specified columns of the row by the specified amounts and returns the new values.
incrementAndGet(Increment) - Method in interface co.cask.cdap.api.dataset.table.Table
Increments the specified columns of a row by the specified amounts defined by the Increment parameter and returns the new values
incrementBytes(byte[], long) - Static method in class co.cask.cdap.api.common.Bytes
Bytewise binary increment/deincrement of long contained in byte array on given amount.
incrementNumFailures() - Method in interface co.cask.cdap.api.dataset.lib.partitioned.ConsumablePartition
 
incrementNumFailures() - Method in class co.cask.cdap.api.dataset.lib.partitioned.DefaultConsumablePartition
 
INDEX_COLUMNS_CONF_KEY - Static variable in class co.cask.cdap.api.dataset.lib.IndexedTable
Configuration key for defining column names to index in the DatasetSpecification properties.
INDEX_COLUMNS_CONF_KEY - Static variable in class co.cask.cdap.api.dataset.lib.IndexedTableDefinition
Deprecated.
IndexedObjectStore<T> - Class in co.cask.cdap.api.dataset.lib
An ObjectStore Dataset extension that supports access to objects via indices; lookups by the index will return all the objects stored in the object store that have the index value.
IndexedObjectStore(String, ObjectStore<T>, Table) - Constructor for class co.cask.cdap.api.dataset.lib.IndexedObjectStore
Constructs the IndexedObjectStore with name and type.
IndexedObjectStoreDefinition - Class in co.cask.cdap.api.dataset.lib
DatasetDefinition for IndexedObjectStore.
IndexedObjectStoreDefinition(String, DatasetDefinition<? extends Table, ?>, DatasetDefinition<? extends ObjectStore, ?>) - Constructor for class co.cask.cdap.api.dataset.lib.IndexedObjectStoreDefinition
 
IndexedTable - Class in co.cask.cdap.api.dataset.lib
Implements a table that creates and maintains indexes on values stored within a configured set of column names.
IndexedTable(String, Table, Table, SortedSet<byte[]>) - Constructor for class co.cask.cdap.api.dataset.lib.IndexedTable
Configuration time constructor.
IndexedTableDefinition - Class in co.cask.cdap.api.dataset.lib
DatasetDefinition for IndexedTable.
IndexedTableDefinition(String, DatasetDefinition<? extends Table, ?>) - Constructor for class co.cask.cdap.api.dataset.lib.IndexedTableDefinition
 
info(String, Object) - Method in interface co.cask.cdap.api.preview.DataTracer
Traces the data.
initialize(CustomActionContext) - Method in class co.cask.cdap.api.customaction.AbstractCustomAction
 
initialize() - Method in class co.cask.cdap.api.customaction.AbstractCustomAction
Classes derived from AbstractCustomAction can override this method to initialize the CustomAction.
initialize(Split) - Method in class co.cask.cdap.api.data.batch.IteratorBasedSplitReader
 
initialize(Split) - Method in class co.cask.cdap.api.data.batch.RecordScanner
Called once at initialization.
initialize(Split) - Method in class co.cask.cdap.api.data.batch.SplitReader
Called once at initialization.
initialize(Split) - Method in class co.cask.cdap.api.data.batch.SplitReaderAdapter
 
initialize(FormatSpecification) - Method in class co.cask.cdap.api.data.format.RecordFormat
Initialize the format with the given desired schema and properties.
initialize(MapReduceTaskContext<K, V>) - Method in class co.cask.cdap.api.dataset.lib.DynamicPartitioner
Initializes a DynamicPartitioner.
initialize(Split) - Method in class co.cask.cdap.api.dataset.lib.KeyValueTable.KeyValueScanner
 
initialize(FlowletContext) - Method in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
 
initialize(FlowletContext) - Method in interface co.cask.cdap.api.flow.flowlet.Flowlet
Initializes a Flowlet.
initialize(MapReduceContext) - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
 
initialize() - Method in class co.cask.cdap.api.mapreduce.AbstractMapReduce
Classes derived from AbstractMapReduce can override this method to initialize the MapReduce.
initialize(T) - Method in interface co.cask.cdap.api.ProgramLifecycle
Initializes a Program.
initialize(HttpServiceContext) - Method in class co.cask.cdap.api.service.http.AbstractHttpServiceHandler
initialize(HttpServiceContext) - Method in interface co.cask.cdap.api.service.http.HttpServiceHandler
Invoked whenever a new instance of this HttpServiceHandler is created.
initialize(SparkClientContext) - Method in class co.cask.cdap.api.spark.AbstractSpark
 
initialize() - Method in class co.cask.cdap.api.spark.AbstractSpark
Classes derived from AbstractSpark can override this method to initialize the Spark.
initialize(WorkerContext) - Method in class co.cask.cdap.api.worker.AbstractWorker
 
initialize(WorkerContext) - Method in interface co.cask.cdap.api.worker.Worker
Initialize the Worker.
initialize(WorkflowContext) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
 
initialize(WorkflowContext) - Method in class co.cask.cdap.api.workflow.AbstractWorkflowAction
Deprecated.
 
initialize(WorkflowContext) - Method in interface co.cask.cdap.api.workflow.WorkflowAction
Deprecated.
Initializes a WorkflowAction.
initialize() - Method in class co.cask.cdap.client.app.FakeWorkflow.FakeAction
 
initialize(HttpServiceContext) - Method in class co.cask.cdap.client.app.PrefixedEchoHandler
 
initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.api.batch.BatchAggregator
Initialize the Batch Aggregator.
initialize(BatchJoinerRuntimeContext) - Method in class co.cask.cdap.etl.api.batch.BatchJoiner
Initialize the Batch Joiner.
initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.api.batch.BatchSink
Initialize the Batch Sink stage.
initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.api.batch.BatchSource
Initialize the Batch Source stage.
initialize(SparkExecutionPluginContext) - Method in class co.cask.cdap.etl.api.batch.SparkCompute
Initialize the plugin.
initialize(RealtimeContext) - Method in class co.cask.cdap.etl.api.realtime.RealtimeSink
Initialize the Sink.
initialize(RealtimeContext) - Method in class co.cask.cdap.etl.api.realtime.RealtimeSource
Initialize the Source.
initialize(T) - Method in interface co.cask.cdap.etl.api.StageLifecycle
Initialize the Stage.
initialize(TransformContext) - Method in class co.cask.cdap.etl.api.Transform
Initialize the Transform Stage.
initialize() - Static method in class co.cask.cdap.test.TestBase
 
Input - Class in co.cask.cdap.api.data.batch
Defines input to a program, such as MapReduce.
Input.DatasetInput - Class in co.cask.cdap.api.data.batch
An implementation of Input, which defines a Dataset as an input.
Input.InputFormatProviderInput - Class in co.cask.cdap.api.data.batch
An implementation of Input, which defines an InputFormatProvider as an input.
Input.StreamInput - Class in co.cask.cdap.api.data.batch
An implementation of Input, which defines a Stream as an input.
INPUT_END_TIME - Static variable in class co.cask.cdap.api.dataset.lib.TimePartitionedFileSetArguments
 
INPUT_FORMAT - Static variable in class co.cask.cdap.api.dataset.lib.FileSetProperties
The name of the input format class.
INPUT_PARTITION_FILTER - Static variable in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
 
INPUT_PARTITION_LIST - Static variable in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
 
INPUT_PATHS - Static variable in class co.cask.cdap.api.dataset.lib.FileSetArguments
The paths of the files to be read.
INPUT_PROPERTIES_PREFIX - Static variable in class co.cask.cdap.api.dataset.lib.FileSetProperties
Prefix for additional properties for the input format.
INPUT_START_TIME - Static variable in class co.cask.cdap.api.dataset.lib.TimePartitionedFileSetArguments
 
InputContext - Interface in co.cask.cdap.api.data.batch
Exposes information about the input configured for this task.
InputContext - Interface in co.cask.cdap.api.flow.flowlet
Represents the context of the input data that is passed to Flowlet for processing.
InputFormatProvider - Interface in co.cask.cdap.api.data.batch
Interface to be implemented by datasets used as input to a MapReduce.
InstanceConflictException - Exception in co.cask.cdap.api.dataset
Thrown when operation conflicts with existing dataset instances available in the system.
InstanceConflictException(String) - Constructor for exception co.cask.cdap.api.dataset.InstanceConflictException
 
InstanceConflictException(String, Throwable) - Constructor for exception co.cask.cdap.api.dataset.InstanceConflictException
 
InstanceNotFoundException - Exception in co.cask.cdap.api.dataset
Thrown for an operation on a non-existing dataset instance.
InstanceNotFoundException(String) - Constructor for exception co.cask.cdap.api.dataset.InstanceNotFoundException
 
InstanceNotFoundException(String, Throwable) - Constructor for exception co.cask.cdap.api.dataset.InstanceNotFoundException
 
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
TestManager for integration tests.
IntegrationTestManager(ClientConfig, RESTClient, File) - Constructor for class co.cask.cdap.test.IntegrationTestManager
 
interpolate(TimeValue, TimeValue, long) - Method in interface co.cask.cdap.api.dataset.lib.cube.Interpolator
Given start and end TimeValues, and a time in-between the two, return a TimeValue for the in-between time.
interpolate(TimeValue, TimeValue, long) - Method in class co.cask.cdap.api.dataset.lib.cube.Interpolators.BaseInterpolator
 
interpolator(Interpolator) - Method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder.Limit
Sets Interpolator to use for CubeQuery.
Interpolator - Interface in co.cask.cdap.api.dataset.lib.cube
Defines how to interpolate a value between two other time values.
Interpolators - Class in co.cask.cdap.api.dataset.lib.cube
Returns interpolators of different types.
Interpolators() - Constructor for class co.cask.cdap.api.dataset.lib.cube.Interpolators
 
Interpolators.BaseInterpolator - Class in co.cask.cdap.api.dataset.lib.cube
Return 0 if the time between data points is above a give limit, or if the point to interpolate is too far before the first point, or too far after the last point.
Interpolators.Linear - Class in co.cask.cdap.api.dataset.lib.cube
timestamps between 2 data points will increase or decrease "linearly".
Interpolators.Linear() - Constructor for class co.cask.cdap.api.dataset.lib.cube.Interpolators.Linear
 
Interpolators.Linear(long) - Constructor for class co.cask.cdap.api.dataset.lib.cube.Interpolators.Linear
 
Interpolators.Step - Class in co.cask.cdap.api.dataset.lib.cube
Timestamps between 2 data points will take on the value of the previous point.
Interpolators.Step() - Constructor for class co.cask.cdap.api.dataset.lib.cube.Interpolators.Step
 
Interpolators.Step(long) - Constructor for class co.cask.cdap.api.dataset.lib.cube.Interpolators.Step
 
invalidate(long) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
InvalidEntry<T> - Class in co.cask.cdap.etl.api
Represents a record that fails validation, with provided errorCode and errorMessage
InvalidEntry(int, String, T) - Constructor for class co.cask.cdap.etl.api.InvalidEntry
 
InvalidMacroException - Exception in co.cask.cdap.api.macro
Indicates that there is an invalid macro.
InvalidMacroException(String) - Constructor for exception co.cask.cdap.api.macro.InvalidMacroException
 
InvalidMacroException(String, Throwable) - Constructor for exception co.cask.cdap.api.macro.InvalidMacroException
 
isBaseOutputPath(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetArguments
 
isCacheEnabled() - Method in class co.cask.cdap.etl.api.LookupTableConfig
 
isCompatible(Schema) - Method in class co.cask.cdap.api.data.schema.Schema
Checks if the given target schema is compatible with this schema, meaning datum being written with this schema could be projected correctly into the given target schema.
isDataExternal(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
isDynamicPartitionerConcurrencyAllowed(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.PartitionedFileSetArguments
Determines whether concurrent writers are allowed in the case of DynamicPartitioner.
isEmpty() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Builder
 
isEmpty() - Method in class co.cask.cdap.api.dataset.table.EmptyRow
 
isEmpty() - Method in class co.cask.cdap.api.dataset.table.Result
 
isEmpty() - Method in interface co.cask.cdap.api.dataset.table.Row
 
isEnabled() - Method in interface co.cask.cdap.api.preview.DataTracer
Returns true if application is running in preview mode otherwise false is returned.
isExploreEnabled(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
isMacroSupported() - Method in class co.cask.cdap.api.plugin.PluginPropertyField
Returns true if the property supports macro, false otherwise.
isNullable() - Method in class co.cask.cdap.api.data.schema.Schema
Check if this is a nullable type, which is a union of a null and one other non-null type.
isNullableSimple() - Method in class co.cask.cdap.api.data.schema.Schema
Check if this is a nullable simple type, which is a union of a null and one other non-null simple type, where a simple type is a boolean, int, long, float, double, bytes, or string type.
isParent(String) - Method in class co.cask.cdap.api.dataset.DatasetSpecification
Returns true if the datasetName is the name of a non-composite dataset represented by this spec.
isPossessExisting(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
isPreviewEnabled() - Method in interface co.cask.cdap.etl.api.batch.BatchSinkContext
Indicates whether the pipeline is running in preview.
isPreviewEnabled() - Method in interface co.cask.cdap.etl.api.batch.BatchSourceContext
Indicates whether the pipeline is running in preview.
isRequired() - Method in class co.cask.cdap.api.plugin.PluginPropertyField
Returns true if the property is required by the plugin, false otherwise.
isRunning(Id.Program) - Method in class co.cask.cdap.test.AbstractApplicationManager
 
isRunning() - Method in class co.cask.cdap.test.AbstractProgramManager
 
isRunning(Id.Program) - Method in interface co.cask.cdap.test.ApplicationManager
Checks whether a particular program is running or not.
isRunning(ProgramId) - Method in interface co.cask.cdap.test.ApplicationManager
Checks whether a particular program is running or not.
isRunning() - Method in class co.cask.cdap.test.DefaultMapReduceManager
 
isRunning() - Method in class co.cask.cdap.test.DefaultSparkManager
 
isRunning() - Method in interface co.cask.cdap.test.ProgramManager
Checks if program is running
isSimpleOrNullableSimple() - Method in class co.cask.cdap.api.data.schema.Schema
Check if this is a simple type or a nullable simple type, which is a union of a null and one other non-null simple type, where a simple type is a boolean, int, long, float, double, bytes, or string type.
isSimpleType() - Method in enum co.cask.cdap.api.data.schema.Schema.Type
 
isSingleValue() - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Condition
 
isSnapshot() - Method in class co.cask.cdap.api.artifact.ArtifactVersion
 
isSSLEnabled() - Method in class co.cask.cdap.client.config.ConnectionConfig
 
isSuccessful() - Method in interface co.cask.cdap.etl.api.batch.BatchActionContext
Return true if the execution was successful, false otherwise.
isUseExisting(Map<String, String>) - Static method in class co.cask.cdap.api.dataset.lib.FileSetProperties
 
isVerifySSLCert() - Method in class co.cask.cdap.client.config.ClientConfig
 
iterateOnSplits(byte[], byte[], int) - Static method in class co.cask.cdap.api.common.Bytes
Iterate over keys within the passed range, splitting at an [a,b) boundary.
iterateOnSplits(byte[], byte[], boolean, int) - Static method in class co.cask.cdap.api.common.Bytes
Iterate over keys within the passed range.
iterator() - Method in class co.cask.cdap.api.dataset.lib.PartitionMetadata
 
IteratorBasedSplitReader<KEY,VALUE> - Class in co.cask.cdap.api.data.batch
Handy implementation of SplitReader backed by Iterator.
IteratorBasedSplitReader() - Constructor for class co.cask.cdap.api.data.batch.IteratorBasedSplitReader
 

J

JavaSparkExecutionContext - Class in co.cask.cdap.api.spark
Spark program execution context.
JavaSparkExecutionContext() - Constructor for class co.cask.cdap.api.spark.JavaSparkExecutionContext
 
JavaSparkMain - Interface in co.cask.cdap.api.spark
A Java interface for Spark program to implement.
join() - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Joins the current fork
JoinConfig - Class in co.cask.cdap.etl.api
Join configuration to hold information about join to be performed
JoinConfig(Iterable<String>) - Constructor for class co.cask.cdap.etl.api.JoinConfig
Creates new instance of JoinConfig
JoinElement<INPUT_RECORD> - Class in co.cask.cdap.etl.api
Join element to hold join record per stage
JoinElement(String, INPUT_RECORD) - Constructor for class co.cask.cdap.etl.api.JoinElement
 
Joiner<JOIN_KEY,INPUT_RECORD,OUT> - Interface in co.cask.cdap.etl.api
Provides join keys on which join needs to be performed and merges the join results.
joinOn(String, INPUT_RECORD) - Method in interface co.cask.cdap.etl.api.Joiner
Return value for the join key on which join will be performed

K

KeyValue<KEY_TYPE,VALUE_TYPE> - Class in co.cask.cdap.api.dataset.lib
Represents key value pair
KeyValue(KEY_TYPE, VALUE_TYPE) - Constructor for class co.cask.cdap.api.dataset.lib.KeyValue
 
KeyValueTable - Class in co.cask.cdap.api.dataset.lib
A key/value map implementation on top of Table supporting read, write and delete operations.
KeyValueTable(String, Table) - Constructor for class co.cask.cdap.api.dataset.lib.KeyValueTable
 
KeyValueTable.KeyValueRecordMaker - Class in co.cask.cdap.api.dataset.lib
KeyValueTable.KeyValueRecordMaker() - Constructor for class co.cask.cdap.api.dataset.lib.KeyValueTable.KeyValueRecordMaker
 
KeyValueTable.KeyValueScanner - Class in co.cask.cdap.api.dataset.lib
The split reader for KeyValueTable.
KeyValueTable.KeyValueScanner(SplitReader<byte[], Row>) - Constructor for class co.cask.cdap.api.dataset.lib.KeyValueTable.KeyValueScanner
 
KeyValueTableDefinition - Class in