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

A

A - Static variable in class co.cask.cdap.cli.english.Article
 
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() - Method in class co.cask.cdap.data2.transaction.AbstractTransactionContext
 
abort(TransactionFailureException) - Method in class co.cask.cdap.data2.transaction.AbstractTransactionContext
 
abort(Transaction) - Method in class co.cask.cdap.data2.transaction.DelegatingTransactionSystemClientService
 
abort(Transaction) - Method in class co.cask.cdap.data2.transaction.DistributedTransactionSystemClientService
 
abort(Transaction) - Method in class co.cask.cdap.data2.transaction.RetryingLongTransactionSystemClient
 
abort(Transaction) - Method in class co.cask.cdap.data2.transaction.RetryingTransactionSystemClient
 
abort(Transaction) - Method in class co.cask.cdap.data2.transaction.TransactionSystemClientAdapter
 
abort(String, Throwable) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices
 
abort(Executor) - Method in class co.cask.cdap.explore.jdbc.ExploreConnection
 
abort(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
aborted() - Method in class co.cask.cdap.common.twill.TwillAppLifecycleEventHandler
 
abortIfNotMet() - Method in interface co.cask.cdap.api.schedule.ConstraintProgramScheduleBuilder
Specifies that the scheduler will abort the schedule execution if the configured constraint is not met.
abortIfNotMet() - Method in class co.cask.cdap.internal.app.runtime.schedule.DefaultScheduleBuilder
 
abortJob(JobContext, JobStatus.State) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.output.MultipleOutputsCommitter
 
abortJob(JobContext, JobStatus.State) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.partitioned.DynamicPartitioningOutputCommitter
 
abortJob(JobContext, JobStatus.State) - Method in class co.cask.cdap.internal.app.runtime.batch.MainOutputCommitter
 
AbortOnTimeoutEventHandler - Class in co.cask.cdap.common.twill
A Twill EventHandler that abort the application if for some runnable it cannot provision container for too long.
AbortOnTimeoutEventHandler(long) - Constructor for class co.cask.cdap.common.twill.AbortOnTimeoutEventHandler
Constructs an instance of AbortOnTimeoutEventHandler that abort the application if some runnable has no containers, same as calling AbortOnTimeoutEventHandler.AbortOnTimeoutEventHandler(long, boolean) with second parameter as false.
AbortOnTimeoutEventHandler(long, boolean) - Constructor for class co.cask.cdap.common.twill.AbortOnTimeoutEventHandler
Constructs an instance of AbortOnTimeoutEventHandler that abort the application if some runnable has not enough containers.
abortTask(TaskAttemptContext) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.output.MultipleOutputsCommitter
 
AbstractAppenderContext - Class in co.cask.cdap.logging.framework
The base implementation of AppenderContext that provides integration with CDAP system.
AbstractAppenderContext(DatasetFramework, TransactionSystemClient, LocationFactory, MetricsCollectionService) - Constructor for class co.cask.cdap.logging.framework.AbstractAppenderContext
 
AbstractAppFabricHttpHandler - Class in co.cask.cdap.gateway.handlers.util
Abstract Class that contains commonly used methods for parsing Http Requests.
AbstractAppFabricHttpHandler() - Constructor for class co.cask.cdap.gateway.handlers.util.AbstractAppFabricHttpHandler
 
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
 
AbstractArtifactManager - Class in co.cask.cdap.internal.app.runtime.artifact
An abstract base for ArtifactManager implementation.
AbstractArtifactManager(CConfiguration) - Constructor for class co.cask.cdap.internal.app.runtime.artifact.AbstractArtifactManager
 
AbstractAuthCommand - Class in co.cask.cdap.cli.util
Abstract command for updating AccessToken.
AbstractAuthCommand(CLIConfig) - Constructor for class co.cask.cdap.cli.util.AbstractAuthCommand
 
AbstractAuthenticationHandler - Class in co.cask.cdap.security.server
An abstract authentication handler that provides basic functionality including setting of constraints and setting of different required services.
AbstractAuthenticationHandler() - Constructor for class co.cask.cdap.security.server.AbstractAuthenticationHandler
 
AbstractAuthorizationEnforcer - Class in co.cask.cdap.security.authorization
Abstract Class that implements common methods for the AuthorizationEnforcer interface.
AbstractAuthorizer - Class in co.cask.cdap.security.spi.authorization
Abstract class that implements Authorizer and provides default no-op implementations of Authorizer.initialize(AuthorizationContext) and Authorizer.destroy() so classes extending it do not have to implement these methods unless necessary.
AbstractAuthorizer() - Constructor for class co.cask.cdap.security.spi.authorization.AbstractAuthorizer
 
AbstractBatchContext - Class in co.cask.cdap.etl.batch
Base Batch Context.
AbstractBatchContext(PipelineRuntime, StageSpec, DatasetContext, Admin) - Constructor for class co.cask.cdap.etl.batch.AbstractBatchContext
 
AbstractBatchReadableInputFormat<KEY,VALUE> - Class in co.cask.cdap.internal.app.runtime.batch.dataset
An abstract InputFormat implementation that reads from BatchReadable.
AbstractBatchReadableInputFormat() - Constructor for class co.cask.cdap.internal.app.runtime.batch.dataset.AbstractBatchReadableInputFormat
 
AbstractBatchWritableOutputFormat<KEY,VALUE> - Class in co.cask.cdap.internal.app.runtime.batch.dataset
An abstract base implementation of OutputFormat for writing to BatchWritable from batch job.
AbstractBatchWritableOutputFormat() - Constructor for class co.cask.cdap.internal.app.runtime.batch.dataset.AbstractBatchWritableOutputFormat
 
AbstractBodyConsumer - Class in co.cask.cdap.common.http
An abstract implementation of BodyConsumer that preserves data to a File.
AbstractBodyConsumer(File) - Constructor for class co.cask.cdap.common.http.AbstractBodyConsumer
 
AbstractBuilder() - Constructor for class co.cask.cdap.api.dataset.ExploreProperties.AbstractBuilder
 
AbstractBuilder() - Constructor for class co.cask.cdap.api.dataset.table.TableProperties.AbstractBuilder
 
AbstractCachedUGIProvider - Class in co.cask.cdap.security.impersonation
An abstract base class for UGIProvider that provides caching of UGIWithPrincipal containing the UserGroupInformation.
AbstractCachedUGIProvider(CConfiguration, OwnerAdmin) - Constructor for class co.cask.cdap.security.impersonation.AbstractCachedUGIProvider
 
AbstractCDAPStats - Class in co.cask.cdap.operations.cdap
Base class for CDAP OperationalStats.
AbstractCDAPStats() - Constructor for class co.cask.cdap.operations.cdap.AbstractCDAPStats
 
AbstractChunkedCallback - Class in co.cask.cdap.logging.gateway.handlers
LogReader Callback class that uses ChunkResponder to send logs back in chunks.
AbstractChunkedLogProducer - Class in co.cask.cdap.logging.gateway.handlers
LogReader BodyProducer class that delegates to subclasses for how to encode log events.
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.
AbstractCommand - Class in co.cask.cdap.cli.util
 
AbstractCommand(CLIConfig) - Constructor for class co.cask.cdap.cli.util.AbstractCommand
 
AbstractCompositeTrigger(Trigger.Type, List<T>) - Constructor for class co.cask.cdap.proto.ProtoTrigger.AbstractCompositeTrigger
 
AbstractCompositeTriggerBuilder - Class in co.cask.cdap.internal.app.runtime.schedule.trigger
A Trigger builder that builds a AbstractSatisfiableCompositeTrigger
AbstractCompositeTriggerBuilder(Trigger.Type, Trigger...) - Constructor for class co.cask.cdap.internal.app.runtime.schedule.trigger.AbstractCompositeTriggerBuilder
 
AbstractCondition - Class in co.cask.cdap.api.workflow
The abstract class provides default implementation of the Condition methods for an easy extension
AbstractCondition() - Constructor for class co.cask.cdap.api.workflow.AbstractCondition
 
AbstractCondition(String) - Constructor for class co.cask.cdap.api.workflow.AbstractCondition
 
AbstractConfigurer - Class in co.cask.cdap.internal.app
Abstract base implementation for application and program configurer.
AbstractConfigurer(Id.Namespace, Id.Artifact, ArtifactRepository, PluginInstantiator) - Constructor for class co.cask.cdap.internal.app.AbstractConfigurer
 
AbstractContext - Class in co.cask.cdap.internal.app.runtime
Base class for program runtime context
AbstractContext(Program, ProgramOptions, CConfiguration, Set<String>, DatasetFramework, TransactionSystemClient, DiscoveryServiceClient, boolean, MetricsCollectionService, Map<String, String>, SecureStore, SecureStoreManager, MessagingService, PluginInstantiator, MetadataReader, MetadataPublisher) - Constructor for class co.cask.cdap.internal.app.runtime.AbstractContext
Constructs a context.
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.
AbstractDelegatorContext<T> - Class in co.cask.cdap.internal.app.runtime.service.http
An abstract base implementation of DelegatorContext to provide context per thread implementation, together with the context capturing capability that is suitable for HttpContentProducer and HttpContentConsumer use cases.
AbstractDelegatorContext(TypeToken<T>, InstantiatorFactory, MetricsContext, MetricsContext) - Constructor for class co.cask.cdap.internal.app.runtime.service.http.AbstractDelegatorContext
 
AbstractDelegatorContext.HandlerTaskExecutor - Class in co.cask.cdap.internal.app.runtime.service.http
Helper class for performing user service handler lifecycle calls as well as task execution.
AbstractDistributedMasterServiceManager - Class in co.cask.cdap.common.twill
Abstract class that can be extended by individual CDAP Services to implement their management methods.
AbstractDistributedMasterServiceManager(CConfiguration, String, TwillRunnerService, DiscoveryServiceClient) - Constructor for class co.cask.cdap.common.twill.AbstractDistributedMasterServiceManager
 
AbstractEndpointStrategy - Class in co.cask.cdap.common.discovery
An abstract EndpointStrategy that helps implementation of any strategy.
AbstractEndpointStrategy(ServiceDiscovered) - Constructor for class co.cask.cdap.common.discovery.AbstractEndpointStrategy
Constructs an instance with the given ServiceDiscovered.
AbstractExploreClient - Class in co.cask.cdap.explore.client
A base for an Explore Client that talks to a server implementing Explore over HTTP/HTTPS.
AbstractExploreClient() - Constructor for class co.cask.cdap.explore.client.AbstractExploreClient
 
AbstractExploreMetadataHttpHandler - Class in co.cask.cdap.explore.executor
An abstract class that provides common functionality for namespaced and non-namespaced ExploreMetadata handlers.
AbstractExploreMetadataHttpHandler() - Constructor for class co.cask.cdap.explore.executor.AbstractExploreMetadataHttpHandler
 
AbstractExploreMetadataHttpHandler.EndpointCoreExecution<R extends io.netty.handler.codec.http.HttpRequest,T> - Interface in co.cask.cdap.explore.executor
Represents the core execution of an endpoint.
AbstractExploreQueryExecutorHttpHandler - Class in co.cask.cdap.explore.executor
An abstract class that provides common functionality for namespaced and non-namespaced ExploreQuery handlers.
AbstractExploreQueryExecutorHttpHandler() - Constructor for class co.cask.cdap.explore.executor.AbstractExploreQueryExecutorHttpHandler
 
AbstractExtendedSpark - Class in co.cask.cdap.api.spark
This abstract class provides extra features at configure time to Spark program through the ExtendedSparkConfigurer provided by the AbstractExtendedSpark.getConfigurer() method.
AbstractExtendedSpark() - Constructor for class co.cask.cdap.api.spark.AbstractExtendedSpark
 
AbstractExtensionLoader<EXTENSION_TYPE,EXTENSION> - Class in co.cask.cdap.extension
A class to load extensions for supported extension types from a configured extensions directory.
AbstractExtensionLoader(String) - Constructor for class co.cask.cdap.extension.AbstractExtensionLoader
 
AbstractFieldAccessor - Class in co.cask.cdap.internal.io
A base implementation of FieldAccessor that throws UnsupportedOperationException for all getter/setter methods, which are meant to be overridden by children class.
AbstractFieldAccessor(Type) - Constructor for class co.cask.cdap.internal.io.AbstractFieldAccessor
 
AbstractFlow - Class in co.cask.cdap.api.flow
Deprecated.
As of release 5.0.0, replaced by @ProgramType.SPARK for realtime processing.
AbstractFlow() - Constructor for class co.cask.cdap.api.flow.AbstractFlow
Deprecated.
 
AbstractFlowlet - Class in co.cask.cdap.api.flow.flowlet
Deprecated.
As of release 5.0.0, replaced by @ProgramType.SPARK for realtime processing.
AbstractFlowlet() - Constructor for class co.cask.cdap.api.flow.flowlet.AbstractFlowlet
Deprecated.
 
AbstractGetPreferencesCommand - Class in co.cask.cdap.cli.command
Abstract Class for getting preferences for instance, namespace, application, program.
AbstractGetPreferencesCommand(ElementType, PreferencesClient, CLIConfig, boolean) - Constructor for class co.cask.cdap.cli.command.AbstractGetPreferencesCommand
 
AbstractHBaseDataSetAdmin - Class in co.cask.cdap.data2.dataset2.lib.hbase
Base class for writing HBase EntityAdmin.
AbstractHBaseDataSetAdmin(TableId, Configuration, CConfiguration, HBaseTableUtil, LocationFactory) - Constructor for class co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin
 
AbstractHBaseDataSetAdmin.CoprocessorJar - Class in co.cask.cdap.data2.dataset2.lib.hbase
Holder for coprocessor information.
AbstractHttpHandlerDelegator<T> - Class in co.cask.cdap.internal.app.runtime.service.http
An abstract base class for all HttpHandler generated through the HttpHandlerGenerator.
AbstractHttpHandlerDelegator(DelegatorContext<T>, MetricsContext) - Constructor for class co.cask.cdap.internal.app.runtime.service.http.AbstractHttpHandlerDelegator
 
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
 
AbstractHttpServiceResponder - Class in co.cask.cdap.internal.app.runtime.service.http
An abstract implementation of HttpServiceResponder to simplify concrete implementation of HttpServiceResponder.
AbstractHttpServiceResponder() - Constructor for class co.cask.cdap.internal.app.runtime.service.http.AbstractHttpServiceResponder
 
AbstractInMemoryMasterServiceManager - Class in co.cask.cdap.common.twill
InMemory CDAP Service Management class.
AbstractInMemoryMasterServiceManager() - Constructor for class co.cask.cdap.common.twill.AbstractInMemoryMasterServiceManager
 
AbstractInMemoryProgramRunner - Class in co.cask.cdap.internal.app
ProgramRunner that can be used to manage multiple in-memory instances of a Program.
AbstractInMemoryProgramRunner(CConfiguration) - Constructor for class co.cask.cdap.internal.app.AbstractInMemoryProgramRunner
 
AbstractJSONCallback - Class in co.cask.cdap.logging.gateway.handlers
LogReader callback that sends JSON objects.
AbstractJSONLogProducer - Class in co.cask.cdap.logging.gateway.handlers
LogReader BodyProducer that serves log events as JSON objects.
AbstractKeyManager - Class in co.cask.cdap.security.auth
AbstractKeyManager that provides the basic functionality that all key managers share.
AbstractKeyManager(CConfiguration) - Constructor for class co.cask.cdap.security.auth.AbstractKeyManager
An AbstractKeyManager that has common functionality of all keymanagers.
AbstractKeyManager(String, int) - Constructor for class co.cask.cdap.security.auth.AbstractKeyManager
 
AbstractListener - Class in co.cask.cdap.internal.app.runtime
Base implementation of ProgramController.Listener that does nothing on any its method invocation.
AbstractListener() - Constructor for class co.cask.cdap.internal.app.runtime.AbstractListener
 
AbstractLoggingContext - Class in co.cask.cdap.common.logging
Provides handy base abstract implementation of the logging context that can be used by subclasses to simplify their implementations.
AbstractLoggingContext() - Constructor for class co.cask.cdap.common.logging.AbstractLoggingContext
 
AbstractLogHandler - Class in co.cask.cdap.logging.gateway.handlers
Abstract Class that contains commonly used methods for log Http Requests.
AbstractLogHandler(LogReader, CConfiguration) - Constructor for class co.cask.cdap.logging.gateway.handlers.AbstractLogHandler
 
AbstractLogPublisher<MESSAGE> - Class in co.cask.cdap.logging.appender
A class that continuously serializes logs from a queue and publishes them.
AbstractLogPublisher(int, RetryStrategy) - Constructor for class co.cask.cdap.logging.appender.AbstractLogPublisher
 
AbstractLookupProvider - Class in co.cask.cdap.etl.common
Lookup that provides common functionality.
AbstractLookupProvider() - Constructor for class co.cask.cdap.etl.common.AbstractLookupProvider
 
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
 
AbstractMasterCheck - Class in co.cask.cdap.master.startup
Base for master startup checks.
AbstractMasterCheck(CConfiguration) - Constructor for class co.cask.cdap.master.startup.AbstractMasterCheck
 
AbstractMasterTwillRunnable - Class in co.cask.cdap.common.twill
Abstract TwillRunnable class for Master system service.
AbstractMasterTwillRunnable(String, String, String) - Constructor for class co.cask.cdap.common.twill.AbstractMasterTwillRunnable
 
AbstractMessagePublisher - Class in co.cask.cdap.messaging.context
An abstract implementation of MessagePublisher that implement most of the publish methods by delegating to the AbstractMessagePublisher.publish(String, String, Iterator).
AbstractMessagePublisher() - Constructor for class co.cask.cdap.messaging.context.AbstractMessagePublisher
 
AbstractMessageTable - Class in co.cask.cdap.messaging.store
Contains common logic for implementation of MessageTable.
AbstractMessageTable() - Constructor for class co.cask.cdap.messaging.store.AbstractMessageTable
 
AbstractMessagingSubscriberService<T> - Class in co.cask.cdap.messaging.subscriber
An abstract base class for implementing message consumption from TMS.
AbstractMessagingSubscriberService(TopicId, boolean, int, int, int, long, RetryStrategy, MetricsContext) - Constructor for class co.cask.cdap.messaging.subscriber.AbstractMessagingSubscriberService
Constructor.
AbstractMetadataClient - Class in co.cask.cdap.common.metadata
Common implementation of methods to interact with metadata service over HTTP.
AbstractMetadataClient() - Constructor for class co.cask.cdap.common.metadata.AbstractMetadataClient
 
AbstractNamespaceClient - Class in co.cask.cdap.common.namespace
Common implementation of methods to interact with namespaces over HTTP.
AbstractNamespaceClient() - Constructor for class co.cask.cdap.common.namespace.AbstractNamespaceClient
 
AbstractNamespaceQueryClient - Class in co.cask.cdap.common.namespace
Implementation of NamespaceQueryAdmin that fetchs NamespaceMeta through REST API.
AbstractNamespaceQueryClient() - Constructor for class co.cask.cdap.common.namespace.AbstractNamespaceQueryClient
 
AbstractNamespaceResourceDeleter - Class in co.cask.cdap.internal.app.namespace
Abstract class for deleting namespace components
AbstractNotificationService - Class in co.cask.cdap.notifications.service
Common implementation of the the NotificationService that handles the subscriptions to all the notification feeds for the current process and that has the ability to push notifications to subscribers.
AbstractNotificationService(DatasetFramework, TransactionSystemClientService, NotificationFeedManager) - Constructor for class co.cask.cdap.notifications.service.AbstractNotificationService
 
AbstractNotificationSubscriberService - Class in co.cask.cdap.internal.app.services
Abstract class that fetches notifications from TMS
AbstractNotificationSubscriberService(String, CConfiguration, String, boolean, int, long, MessagingService, DatasetFramework, TransactionSystemClient, MetricsCollectionService) - Constructor for class co.cask.cdap.internal.app.services.AbstractNotificationSubscriberService
 
AbstractOperationalStats - Class in co.cask.cdap.operations
A base class to provide default implementations for OperationalStats extensions
AbstractOperationalStats() - Constructor for class co.cask.cdap.operations.AbstractOperationalStats
 
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.
AbstractPayloadTable - Class in co.cask.cdap.messaging.store
Contains common logic for implementation of PayloadTable.
AbstractPayloadTable() - Constructor for class co.cask.cdap.messaging.store.AbstractPayloadTable
 
AbstractPipeline<T> - Class in co.cask.cdap.internal.pipeline
Abstract implementation of Pipeline.
AbstractPipeline() - Constructor for class co.cask.cdap.internal.pipeline.AbstractPipeline
 
AbstractPluginConfigurable<T extends PluginConfigurer & DatasetConfigurer> - Class in co.cask.cdap.internal.api
Helper methods to add plugins to Programs.
AbstractPluginConfigurable() - Constructor for class co.cask.cdap.internal.api.AbstractPluginConfigurable
 
AbstractProgramController - Class in co.cask.cdap.internal.app.runtime
Abstract base implementation of ProgramController that governs state transitions as well as Listener invocation mechanism.
AbstractProgramController(ProgramRunId) - Constructor for class co.cask.cdap.internal.app.runtime.AbstractProgramController
 
AbstractProgramController(ProgramRunId, String) - Constructor for class co.cask.cdap.internal.app.runtime.AbstractProgramController
 
AbstractProgramDatasetConfigurable<T extends DatasetConfigurer> - Class in co.cask.cdap.internal.api
Helper methods to help add stream/dataset to Programs.
AbstractProgramDatasetConfigurable() - Constructor for class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable
 
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
 
AbstractProgramRunnerWithPlugin - Class in co.cask.cdap.internal.app.runtime
Provides method to create PluginInstantiator for Program Runners
AbstractProgramRunnerWithPlugin(CConfiguration) - Constructor for class co.cask.cdap.internal.app.runtime.AbstractProgramRunnerWithPlugin
 
AbstractProgramRuntimeService - Class in co.cask.cdap.app.runtime
A ProgramRuntimeService that keeps an in memory map for all running programs.
AbstractProgramRuntimeService(CConfiguration, ProgramRunnerFactory, ArtifactRepository) - Constructor for class co.cask.cdap.app.runtime.AbstractProgramRuntimeService
 
AbstractProgramSpecification - Class in co.cask.cdap.api
Base abstract class for ProgramSpecification which contains common information for various program specifications.
AbstractProgramSpecification(String, String, String, Map<String, Plugin>) - Constructor for class co.cask.cdap.api.AbstractProgramSpecification
 
AbstractProgramTwillRunnable<T extends ProgramRunner> - Class in co.cask.cdap.internal.app.runtime.distributed
A TwillRunnable for running a program through a ProgramRunner.
AbstractProgramTwillRunnable(String) - Constructor for class co.cask.cdap.internal.app.runtime.distributed.AbstractProgramTwillRunnable
Constructor.
AbstractPropertyChangeListener<T> - Class in co.cask.cdap.common.conf
Implementation of a PropertyChangeListener that only log for callbacks.
AbstractPropertyChangeListener() - Constructor for class co.cask.cdap.common.conf.AbstractPropertyChangeListener
 
AbstractPropertyStore<T> - Class in co.cask.cdap.common.conf
Base implementation of PropertyStore.
AbstractPropertyStore() - Constructor for class co.cask.cdap.common.conf.AbstractPropertyStore
 
AbstractQueueAdmin - Class in co.cask.cdap.data2.transaction.queue
Common implementation of table-based QueueAdmin
AbstractQueueAdmin(QueueConstants.QueueType) - Constructor for class co.cask.cdap.data2.transaction.queue.AbstractQueueAdmin
 
AbstractQueueConsumer - Class in co.cask.cdap.data2.transaction.queue
Common queue consumer for persisting engines such as HBase and LevelDB.
AbstractQueueConsumer(CConfiguration, ConsumerConfig, QueueName) - Constructor for class co.cask.cdap.data2.transaction.queue.AbstractQueueConsumer
 
AbstractQueueConsumer(CConfiguration, ConsumerConfig, QueueName, byte[]) - Constructor for class co.cask.cdap.data2.transaction.queue.AbstractQueueConsumer
 
AbstractQueueProducer - Class in co.cask.cdap.data2.transaction.queue
Abstract base class for QueueProducer that emits enqueue metrics post commit.
AbstractQueueProducer(QueueMetrics, QueueName) - Constructor for class co.cask.cdap.data2.transaction.queue.AbstractQueueProducer
 
AbstractQueueSpecificationGenerator - Class in co.cask.cdap.internal.app.queue
AbstractQueueSpecification builder for extracting commanality across different implementation.
AbstractQueueSpecificationGenerator() - Constructor for class co.cask.cdap.internal.app.queue.AbstractQueueSpecificationGenerator
 
AbstractResourceReporter - Class in co.cask.cdap.internal.app.runtime
Abstract implementation of a ProgramResourceReporter writes out resource metrics at a fixed rate that defaults to 60 seconds, but can be specified in the constructor.
AbstractResourceReporter(MetricsContext) - Constructor for class co.cask.cdap.internal.app.runtime.AbstractResourceReporter
 
AbstractResourceReporter(MetricsContext, int) - Constructor for class co.cask.cdap.internal.app.runtime.AbstractResourceReporter
 
AbstractRetryableScheduledService - Class in co.cask.cdap.common.service
A AbstractScheduledService that runs task periodically and with retry logic upon task failure.
AbstractRetryableScheduledService(RetryStrategy) - Constructor for class co.cask.cdap.common.service.AbstractRetryableScheduledService
Constructor.
AbstractRowKeyDistributor - Class in co.cask.cdap.hbase.wd
Defines the way row keys are distributed.
AbstractRowKeyDistributor() - Constructor for class co.cask.cdap.hbase.wd.AbstractRowKeyDistributor
 
AbstractSatisfiableCompositeTrigger - Class in co.cask.cdap.internal.app.runtime.schedule.trigger
Abstract base class for composite trigger.
AbstractSatisfiableCompositeTrigger(Trigger.Type, List<SatisfiableTrigger>) - Constructor for class co.cask.cdap.internal.app.runtime.schedule.trigger.AbstractSatisfiableCompositeTrigger
 
AbstractSchemaGenerator - Class in co.cask.cdap.internal.io
An abstract base class for generating schema.
AbstractSchemaGenerator() - Constructor for class co.cask.cdap.internal.io.AbstractSchemaGenerator
 
AbstractService - Class in co.cask.cdap.api.service
An abstract implementation of Service.
AbstractService() - Constructor for class co.cask.cdap.api.service.AbstractService
 
AbstractServiceDiscoverer - Class in co.cask.cdap.app.services
An abstract implementation of ServiceDiscoverer.
AbstractServiceDiscoverer(ProgramId) - Constructor for class co.cask.cdap.app.services.AbstractServiceDiscoverer
 
AbstractServiceHttpServer<T> - Class in co.cask.cdap.internal.app.runtime.service.http
An abstract base class for running netty-http service that host user service handler.
AbstractServiceHttpServer(String, Program, ProgramOptions, int, ServiceAnnouncer, TransactionControl) - Constructor for class co.cask.cdap.internal.app.runtime.service.http.AbstractServiceHttpServer
 
AbstractSetPreferencesCommand - Class in co.cask.cdap.cli.command
Abstract Set Preferences Class.
AbstractSetPreferencesCommand(ElementType, PreferencesClient, CLIConfig) - Constructor for class co.cask.cdap.cli.command.AbstractSetPreferencesCommand
 
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
 
AbstractSparkHttpServiceHandler - Class in co.cask.cdap.api.spark.service
An abstract implementation of SparkHttpServiceHandler.
AbstractSparkHttpServiceHandler() - Constructor for class co.cask.cdap.api.spark.service.AbstractSparkHttpServiceHandler
 
AbstractSparkPythonUtil - Class in co.cask.cdap.app.runtime.spark.python
Abstract base utility class for PySpark.
AbstractSparkPythonUtil() - Constructor for class co.cask.cdap.app.runtime.spark.python.AbstractSparkPythonUtil
 
AbstractSparkSubmitter - Class in co.cask.cdap.app.runtime.spark.submit
Provides common implementation for different SparkSubmitter.
AbstractSparkSubmitter() - Constructor for class co.cask.cdap.app.runtime.spark.submit.AbstractSparkSubmitter
 
AbstractSpecificationCodec<T> - Class in co.cask.cdap.proto.codec
Abstract base class to provides common methods for all Codec.
AbstractSpecificationCodec() - Constructor for class co.cask.cdap.proto.codec.AbstractSpecificationCodec
 
AbstractStage<T> - Class in co.cask.cdap.pipeline
Abstract implementation of Stage allowing ability to determine type to invoke the actual processing of event.
AbstractStage(TypeToken<T>) - Constructor for class co.cask.cdap.pipeline.AbstractStage
Constructor that allows determining the type Stage is looking to process.
AbstractStageContext - Class in co.cask.cdap.etl.common
Base implementation of StageContext for common functionality.
AbstractStageContext(PipelineRuntime, StageSpec) - Constructor for class co.cask.cdap.etl.common.AbstractStageContext
 
AbstractStreamCoordinatorClient - Class in co.cask.cdap.data.stream
Base implementation for StreamCoordinatorClient.
AbstractStreamCoordinatorClient() - Constructor for class co.cask.cdap.data.stream.AbstractStreamCoordinatorClient
 
AbstractStreamEventRecordFormat<T> - Class in co.cask.cdap.spi.stream
Format for a record contained in a StreamEvent.
AbstractStreamEventRecordFormat() - Constructor for class co.cask.cdap.spi.stream.AbstractStreamEventRecordFormat
 
AbstractStreamFileConsumer - Class in co.cask.cdap.data2.transaction.stream
A StreamConsumer that read events from stream file and uses a table to store consumer states.
AbstractStreamFileConsumer(CConfiguration, StreamConfig, ConsumerConfig, FileReader<StreamEventOffset, Iterable<StreamFileOffset>>, StreamConsumerStateStore, StreamConsumerState, ReadFilter) - Constructor for class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumer
 
AbstractStreamFileConsumer.StateScanner - Interface in co.cask.cdap.data2.transaction.stream
Scanner for scanning state table.
AbstractStreamFileConsumerFactory - Class in co.cask.cdap.data2.transaction.stream
Abstract base class for implementing StreamConsumerFactory using MultiLiveStreamFileReader.
AbstractStreamFileConsumerFactory(CConfiguration, StreamAdmin, StreamConsumerStateStoreFactory) - Constructor for class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumerFactory
 
AbstractStreamInputFormat<K,V> - Class in co.cask.cdap.data.stream
Stream mapreduce input format.
AbstractStreamInputFormat() - Constructor for class co.cask.cdap.data.stream.AbstractStreamInputFormat
 
AbstractStreamService - Class in co.cask.cdap.data.stream.service
Stream service meant to run in an HTTP service.
AbstractStreamService(StreamCoordinatorClient, StreamFileJanitorService, StreamWriterSizeCollector, MetricStore) - Constructor for class co.cask.cdap.data.stream.service.AbstractStreamService
 
AbstractSystemMetadataWriter - Class in co.cask.cdap.data2.metadata.system
A class to write MetadataScope.SYSTEM metadata for an entity.
AbstractTable - Class in co.cask.cdap.data2.dataset2.lib.table
Implements some of the methods in a generic way (not necessarily in most efficient way).
AbstractTable(Map<String, String>) - Constructor for class co.cask.cdap.data2.dataset2.lib.table.AbstractTable
 
AbstractTable.TableScanner - Class in co.cask.cdap.data2.dataset2.lib.table
Implements a split reader for a key range of a table, based on the Scanner implementation of the underlying table implementation.
AbstractTableDefinition<D extends Dataset,A extends DatasetAdmin> - Class in co.cask.cdap.data2.dataset2.lib.table
Common configuration and reconfiguration for all Table implementations.
AbstractTableDefinition(String) - Constructor for class co.cask.cdap.data2.dataset2.lib.table.AbstractTableDefinition
 
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
 
AbstractTimeSchedulerService - Class in co.cask.cdap.internal.app.runtime.schedule
Abstract scheduler service common scheduling functionality.
AbstractTimeSchedulerService(TimeScheduler) - Constructor for class co.cask.cdap.internal.app.runtime.schedule.AbstractTimeSchedulerService
 
AbstractTransactionContext - Class in co.cask.cdap.data2.transaction
An abstract implementation of TransactionContext for governing general transaction lifecycle.
AbstractTransactionContext(TransactionSystemClient) - Constructor for class co.cask.cdap.data2.transaction.AbstractTransactionContext
 
AbstractTransformContext - Class in co.cask.cdap.etl.common
Base implementation of TransformContext for common functionality.
AbstractTransformContext(PipelineRuntime, StageSpec, LookupProvider) - Constructor for class co.cask.cdap.etl.common.AbstractTransformContext
 
AbstractTriggerInfo - Class in co.cask.cdap.internal.app.runtime.schedule.trigger
Base class for the trigger information to be passed to the triggered program.
AbstractTriggerInfo(TriggerInfo.Type) - Constructor for class co.cask.cdap.internal.app.runtime.schedule.trigger.AbstractTriggerInfo
 
AbstractTwillProgramController - Class in co.cask.cdap.internal.app.runtime.distributed
A ProgramController that control program through twill.
AbstractTwillProgramController(ProgramId, TwillController, RunId) - Constructor for class co.cask.cdap.internal.app.runtime.distributed.AbstractTwillProgramController
 
AbstractUpgrader - Class in co.cask.cdap.data.tools
Abstract class for Upgrade
AbstractUpgrader(LocationFactory, NamespacedLocationFactory) - Constructor for class co.cask.cdap.data.tools.AbstractUpgrader
 
AbstractVerifier<T> - Class in co.cask.cdap.app.verification
 
AbstractVerifier() - Constructor for class co.cask.cdap.app.verification.AbstractVerifier
 
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
 
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
 
accept(String, int) - Method in class co.cask.cdap.common.logging.CountBasedLogSampler
 
accept(String, int, long) - Method in class co.cask.cdap.common.logging.CountBasedLogSampler
Returns the decision whether to accept the log message.
accept(String, int) - Method in interface co.cask.cdap.common.logging.LogSampler
Returns the decision of whether to accept the log message of the given log level.
accept(String, int) - Method in class co.cask.cdap.common.logging.TimeBasedLogSampler
 
accept(String, URL, URL) - Method in class co.cask.cdap.common.twill.HadoopClassExcluder
 
accept(CubeFact) - Method in interface co.cask.cdap.data2.dataset2.lib.cube.Aggregation
Filters out CubeFacts which should not be added into this aggregation.
accept(CubeFact) - Method in class co.cask.cdap.data2.dataset2.lib.cube.DefaultAggregation
 
acceptOffset(long) - Method in class co.cask.cdap.data.file.filter.AndReadFilter
 
acceptOffset(long) - Method in class co.cask.cdap.data.file.ReadFilter
Accept or reject based on file offset.
acceptPackage(String) - Method in interface co.cask.cdap.common.lang.FilterClassLoader.Filter
Returns the result of whether the given package is accepted or not.
acceptResource(String) - Method in interface co.cask.cdap.common.lang.FilterClassLoader.Filter
Returns the result of whether the given resource is accepted or not.
acceptsURL(String) - Method in class co.cask.cdap.explore.jdbc.ExploreDriver
 
acceptTimestamp(long) - Method in class co.cask.cdap.data.file.filter.AndReadFilter
 
acceptTimestamp(long) - Method in class co.cask.cdap.data.file.filter.TTLReadFilter
 
acceptTimestamp(long) - Method in class co.cask.cdap.data.file.ReadFilter
Accept or reject based on event timestamp.
acceptTimestamp(long) - Method in class co.cask.cdap.data.stream.TimeRangeReadFilter
 
ACCESS_REGISTRY_TABLE - Static variable in class co.cask.cdap.data2.metadata.lineage.LineageDatasetDefinition
 
ACCESS_TOKEN - Static variable in class co.cask.cdap.security.server.ExternalAuthenticationServer.ResponseFields
 
accessibleFrom(String) - Method in class co.cask.cdap.etl.planner.Dag
Return all stages accessible from a starting stage.
accessibleFrom(String, Set<String>) - Method in class co.cask.cdap.etl.planner.Dag
Return all stages accessible from a starting stage, without going past any node in stopNodes.
accessibleFrom(Set<String>, Set<String>) - Method in class co.cask.cdap.etl.planner.Dag
Return all stages accessible from the starting stages, without going past any node in stopNodes.
AccessPayload - Class in co.cask.cdap.proto.audit.payload.access
Represents the access that happened on a data entity.
AccessPayload(AccessType, EntityId) - Constructor for class co.cask.cdap.proto.audit.payload.access.AccessPayload
 
AccessToken - Class in co.cask.cdap.security.auth
Represents a verified identity used for client authentication.
AccessToken(AccessTokenIdentifier, int, byte[]) - Constructor for class co.cask.cdap.security.auth.AccessToken
 
AccessTokenCodec - Class in co.cask.cdap.security.auth
Utility to encode and decode AccessToken and AccessTokenIdentifier instances to and from byte array representations.
AccessTokenCodec(DatumReaderFactory, DatumWriterFactory) - Constructor for class co.cask.cdap.security.auth.AccessTokenCodec
 
AccessTokenIdentifier - Class in co.cask.cdap.security.auth
Represents a verified user identity.
AccessTokenIdentifier(String, Collection<String>, long, long) - Constructor for class co.cask.cdap.security.auth.AccessTokenIdentifier
 
AccessTokenIdentifierCodec - Class in co.cask.cdap.security.auth
Utility to handle serialization and deserialization of AccessTokenIdentifier objects.
AccessTokenIdentifierCodec(DatumReaderFactory, DatumWriterFactory) - Constructor for class co.cask.cdap.security.auth.AccessTokenIdentifierCodec
 
AccessTokenIdentifierPair(String, AccessTokenIdentifier) - Constructor for class co.cask.cdap.security.auth.AccessTokenTransformer.AccessTokenIdentifierPair
 
AccessTokenTransformer - Class in co.cask.cdap.security.auth
It takes the access token and transforms it to Access Token Identifier.
AccessTokenTransformer(Codec<AccessToken>, Codec<AccessTokenIdentifier>) - Constructor for class co.cask.cdap.security.auth.AccessTokenTransformer
 
AccessTokenTransformer.AccessTokenIdentifierPair - Class in co.cask.cdap.security.auth
Access token identifier pair that has marshalled and unmarshalled access token object
AccessTokenValidator - Class in co.cask.cdap.security.auth
This class validates the accessToken and returns the different states of accessToken validation.
AccessTokenValidator(TokenManager, Codec<AccessToken>) - Constructor for class co.cask.cdap.security.auth.AccessTokenValidator
 
AccessType - Enum in co.cask.cdap.data2.metadata.lineage
Represents the type of Dataset access by a Program.
AccessType - Enum in co.cask.cdap.proto.audit.payload.access
Type of access on a data entity.
ACCOUNT_ID - Static variable in class co.cask.cdap.app.program.ManifestFields
 
ack(List<InMemoryQueue.Key>, ConsumerConfig) - Method in class co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueue
 
ACL - Static variable in class co.cask.cdap.common.conf.Constants.Service
 
act(T) - Method in interface co.cask.cdap.etl.common.submit.SubmitterPlugin.PrepareAction
 
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
 
Action - Enum in co.cask.cdap.proto.security
Types of actions that users can perform on entities.
ActionContext - Interface in co.cask.cdap.etl.api.action
Represents the context available to the action plugin during runtime.
ACTIONS_STRING_TO_SET - Static variable in class co.cask.cdap.cli.util.AbstractAuthCommand
 
ActionSpec - Class in co.cask.cdap.etl.batch
Specification for a batch action.
ActionSpec(String, PluginSpec) - Constructor for class co.cask.cdap.etl.batch.ActionSpec
 
ACTIVE_OPERATION_TIMEOUT_SECS - Static variable in class co.cask.cdap.common.conf.Constants.Explore
 
activeFileLocation - Variable in class co.cask.cdap.logging.plugins.LocationRollingPolicyBase
 
ActiveOperationRemovalHandler - Class in co.cask.cdap.explore.service.hive
Takes care of closing operations after they are removed from the cache.
ActiveOperationRemovalHandler(BaseHiveExploreService, ExecutorService) - Constructor for class co.cask.cdap.explore.service.hive.ActiveOperationRemovalHandler
 
ActivityFlow - Class in co.cask.cdap.examples.profiles
Reads click events from a stream, counts clicks per URL, and records user's last activity in their profiles.
ActivityFlow() - Constructor for class co.cask.cdap.examples.profiles.ActivityFlow
 
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(List<String>) - Method in class co.cask.cdap.cli.util.table.Table.Builder.Rows
 
add(String...) - Method in class co.cask.cdap.cli.util.table.Table.Builder.Rows
 
add(ArtifactId, Set<ArtifactRange>, ContentProvider<? extends InputStream>) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(NamespaceId, String, ContentProvider<? extends InputStream>, String) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(NamespaceId, String, ContentProvider<? extends InputStream>, String, Set<ArtifactRange>) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(NamespaceId, String, ContentProvider<? extends InputStream>, String, Set<ArtifactRange>, Set<PluginClass>) - Method in class co.cask.cdap.client.ArtifactClient
Add an artifact.
add(DatasetModuleId, String, File) - Method in class co.cask.cdap.client.DatasetModuleClient
Adds a new dataset module.
add(ScheduleId, ScheduleDetail) - Method in class co.cask.cdap.client.ScheduleClient
Add a new schedule for an existing application.
add(String, String) - Method in class co.cask.cdap.common.discovery.ServicePayload
Adds a key and value as service payload.
add(HBaseQueueDebugger.QueueStatistics) - Method in class co.cask.cdap.data.tools.HBaseQueueDebugger.QueueStatistics
 
add(NamespaceId, DatasetSpecification) - Method in class co.cask.cdap.data2.datafabric.dataset.instance.DatasetInstanceManager
Adds dataset instance metadata
add(DatasetDefinition) - Method in class co.cask.cdap.data2.dataset2.DefaultDatasetDefinitionRegistry
 
add(DatasetDefinition) - Method in class co.cask.cdap.data2.dataset2.InMemoryDatasetDefinitionRegistry
 
add(CubeFact) - Method in class co.cask.cdap.data2.dataset2.lib.cube.CubeDataset
 
add(Collection<? extends CubeFact>) - Method in class co.cask.cdap.data2.dataset2.lib.cube.CubeDataset
 
add(CubeFact) - Method in class co.cask.cdap.data2.dataset2.lib.cube.DefaultCube
 
add(Collection<? extends CubeFact>) - Method in class co.cask.cdap.data2.dataset2.lib.cube.DefaultCube
 
add(byte[]) - Method in class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
add(String) - Method in class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
add(String...) - Method in class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
add(long) - Method in class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
add(int) - Method in class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
add(List<Fact>) - Method in class co.cask.cdap.data2.dataset2.lib.timeseries.FactTable
 
add(byte[], byte[], long) - Method in interface co.cask.cdap.data2.util.hbase.IncrementBuilder
 
add(byte[], byte[], long, long) - Method in interface co.cask.cdap.data2.util.hbase.IncrementBuilder
 
add(byte[], byte[], byte[]) - Method in interface co.cask.cdap.data2.util.hbase.PutBuilder
 
add(byte[], byte[], long, byte[]) - Method in interface co.cask.cdap.data2.util.hbase.PutBuilder
 
add(byte[], ByteBuffer, long, ByteBuffer) - Method in interface co.cask.cdap.data2.util.hbase.PutBuilder
 
add(Purchase) - Method in class co.cask.cdap.examples.purchase.PurchaseHistory
Add a purchase to a customer's history.
add(Multibinder<HttpHandler>) - Static method in class co.cask.cdap.gateway.handlers.CommonHandlers
 
add(Event, long, int, int, Offset) - Method in class co.cask.cdap.logging.pipeline.TimeEventQueue
 
add(MetricValues) - Method in class co.cask.cdap.metrics.store.DefaultMetricStore
 
add(Collection<? extends MetricValues>) - Method in class co.cask.cdap.metrics.store.DefaultMetricStore
 
add(ProgramSchedule) - Method in class co.cask.cdap.scheduler.ProgramScheduleService
Add the given schedule
add(Permission) - Method in class co.cask.cdap.security.ApplicationSecurity.Builder
Adds a Permission object to the ApplicationPermissionCollection.
add(NamespacedEntityId, KerberosPrincipalId) - Method in class co.cask.cdap.security.impersonation.DefaultOwnerAdmin
 
add(NamespacedEntityId, KerberosPrincipalId) - Method in class co.cask.cdap.security.impersonation.InMemoryOwnerStore
 
add(NamespacedEntityId, KerberosPrincipalId) - Method in class co.cask.cdap.security.impersonation.NoOpOwnerAdmin
 
add(NamespacedEntityId, KerberosPrincipalId) - Method in interface co.cask.cdap.security.impersonation.OwnerAdmin
Store the owner's kerberosPrincipalId for the given EntityId
add(NamespacedEntityId, KerberosPrincipalId) - Method in class co.cask.cdap.security.impersonation.OwnerStore
Store the owner's kerberosPrincipalId for the given EntityId
add(NamespacedEntityId, KerberosPrincipalId) - Method in class co.cask.cdap.store.DefaultOwnerStore
 
addAccess(ProgramRunId, StreamId, AccessType) - Method in class co.cask.cdap.data.stream.preview.PreviewStreamAdmin
 
addAccess(ProgramRunId, DatasetId, AccessType, long) - Method in class co.cask.cdap.data2.metadata.lineage.LineageDataset
Add a program-dataset access.
addAccess(ProgramRunId, DatasetId, AccessType, long, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.lineage.LineageDataset
Add a program-dataset access.
addAccess(ProgramRunId, StreamId, AccessType, long) - Method in class co.cask.cdap.data2.metadata.lineage.LineageDataset
Add a program-stream access.
addAccess(ProgramRunId, StreamId, AccessType, long, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.lineage.LineageDataset
Add a program-stream access.
addAccess(ProgramRunId, DatasetId, AccessType, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.writer.BasicLineageWriter
 
addAccess(ProgramRunId, StreamId, AccessType, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.writer.BasicLineageWriter
 
addAccess(ProgramRunId, DatasetId, AccessType) - Method in interface co.cask.cdap.data2.metadata.writer.LineageWriter
Add a program-dataset access.
addAccess(ProgramRunId, DatasetId, AccessType, NamespacedEntityId) - Method in interface co.cask.cdap.data2.metadata.writer.LineageWriter
Add a program-dataset access.
addAccess(ProgramRunId, StreamId, AccessType) - Method in interface co.cask.cdap.data2.metadata.writer.LineageWriter
Add a program-stream access.
addAccess(ProgramRunId, StreamId, AccessType, NamespacedEntityId) - Method in interface co.cask.cdap.data2.metadata.writer.LineageWriter
Add a program-stream access.
addAccess(ProgramRunId, DatasetId, AccessType, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.writer.MessagingLineageWriter
 
addAccess(ProgramRunId, StreamId, AccessType, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.writer.MessagingLineageWriter
 
addAccess(ProgramRunId, DatasetId, AccessType) - Method in class co.cask.cdap.data2.metadata.writer.NoOpLineageWriter
 
addAccess(ProgramRunId, DatasetId, AccessType, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.writer.NoOpLineageWriter
 
addAccess(ProgramRunId, StreamId, AccessType) - Method in class co.cask.cdap.data2.metadata.writer.NoOpLineageWriter
 
addAccess(ProgramRunId, StreamId, AccessType, NamespacedEntityId) - Method in class co.cask.cdap.data2.metadata.writer.NoOpLineageWriter
 
addAccess(ProgramRunId, StreamId, AccessType) - Method in class co.cask.cdap.data2.transaction.queue.inmemory.InMemoryStreamAdmin
 
addAccess(ProgramRunId, StreamId, AccessType) - Method in class co.cask.cdap.data2.transaction.stream.AuthorizationStreamAdmin
 
addAccess(ProgramRunId, StreamId, AccessType) - Method in class co.cask.cdap.data2.transaction.stream.FileStreamAdmin
 
addAccess(ProgramRunId, StreamId, AccessType) - Method in interface co.cask.cdap.data2.transaction.stream.StreamAdmin
Record access of stream by a program run for lineage computation.
addAction(CustomAction) - Method in class co.cask.cdap.api.workflow.AbstractWorkflow
Adds a custom action to the Workflow.
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(CustomAction) - Method in interface co.cask.cdap.api.workflow.WorkflowConfigurer
Adds a custom action as a next sequential step in the Workflow
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
addAction(CustomAction) - Method in class co.cask.cdap.datapipeline.ConditionToConditionAdder
 
addAction(CustomAction) - Method in class co.cask.cdap.datapipeline.ConditionToForkAdder
 
addAction(CustomAction) - Method in class co.cask.cdap.datapipeline.ConditionToTrunkAdder
 
addAction(CustomAction) - Method in class co.cask.cdap.datapipeline.ForkToConditionAdder
 
addAction(CustomAction) - Method in class co.cask.cdap.datapipeline.ForkToForkAdder
 
addAction(CustomAction) - Method in class co.cask.cdap.datapipeline.ForkToTrunkAdder
 
addAction(CustomAction) - Method in class co.cask.cdap.datapipeline.TrunkProgramAdder
 
addAction(CustomAction) - Method in interface co.cask.cdap.datapipeline.WorkflowProgramAdder
 
addAction(ActionSpec) - Method in class co.cask.cdap.etl.batch.BatchPipelineSpec.Builder
 
addAction(ETLStage) - Method in class co.cask.cdap.etl.proto.v1.ETLBatchConfig.Builder
 
addAction(CustomAction) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConditionConfigurer
 
addAction(CustomAction) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConfigurer
 
addAction(CustomAction) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowForkConfigurer
 
addActions(Collection<ETLStage>) - Method in class co.cask.cdap.etl.proto.v1.ETLBatchConfig.Builder
 
addAdditionalSecurityHeaders() - Method in class co.cask.cdap.explore.client.DiscoveryExploreClient
 
addAdditionalSecurityHeaders() - Method in class co.cask.cdap.explore.client.ProgramDiscoveryExploreClient
 
addAdditions(MetadataRecordV2) - Method in class co.cask.cdap.data2.audit.payload.builder.MetadataPayloadBuilder
Add the additions to the previous value of metadata to get the current value of metadata.
addAlertConsumer(PipeStage<RecordInfo<Alert>>) - Method in class co.cask.cdap.etl.batch.PipeEmitter.Builder
 
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.
addAll(Iterator<T>) - Method in class co.cask.cdap.messaging.cache.MessageCache
Adds a list of entries to the cache.
addApp(ApplicationClass) - Method in class co.cask.cdap.api.artifact.ArtifactClasses.Builder
 
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(ArtifactId, Class<?>, Manifest, File...) - Method in class co.cask.cdap.test.IntegrationTestManager
 
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(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(ArtifactId, Class<?>, Manifest) - Static method in class co.cask.cdap.test.TestBase
Build an application artifact from the specified class and then add it.
addAppArtifact(ArtifactId, Class<?>) - Method in interface co.cask.cdap.test.TestManager
Builds an application artifact from the specified class and then adds it.
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(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<?>, Manifest, File...) - 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
 
addAppArtifact(ArtifactId, Class<?>, Manifest, File...) - Method in class co.cask.cdap.test.UnitTestManager
 
addApplication(ApplicationId, ApplicationSpecification) - Method in interface co.cask.cdap.app.store.Store
Creates new application if it doesn't exist.
addApplication(ApplicationId, ApplicationSpecification) - Method in class co.cask.cdap.internal.app.store.DefaultStore
 
addApps(ApplicationClass...) - Method in class co.cask.cdap.api.artifact.ArtifactClasses.Builder
 
addApps(Iterable<ApplicationClass>) - Method in class co.cask.cdap.api.artifact.ArtifactClasses.Builder
 
addArtifact(HttpRequest, HttpResponder, String, String, String, String, String) - Method in class co.cask.cdap.gateway.handlers.ArtifactHttpHandler
 
addArtifact(Id.Artifact, File) - Method in interface co.cask.cdap.internal.app.runtime.artifact.ArtifactRepository
Inspects and builds plugin and application information for the given artifact.
addArtifact(Id.Artifact, File, Set<ArtifactRange>, Set<PluginClass>) - Method in interface co.cask.cdap.internal.app.runtime.artifact.ArtifactRepository
Inspects and builds plugin and application information for the given artifact, adding an additional set of plugin classes to the plugins found through inspection.
addArtifact(Id.Artifact, File, Set<ArtifactRange>, Set<PluginClass>, Map<String, String>) - Method in interface co.cask.cdap.internal.app.runtime.artifact.ArtifactRepository
Inspects and builds plugin and application information for the given artifact, adding an additional set of plugin classes to the plugins found through inspection.
addArtifact(Id.Artifact, File) - Method in class co.cask.cdap.internal.app.runtime.artifact.AuthorizationArtifactRepository
 
addArtifact(Id.Artifact, File, Set<ArtifactRange>, Set<PluginClass>) - Method in class co.cask.cdap.internal.app.runtime.artifact.AuthorizationArtifactRepository
 
addArtifact(Id.Artifact, File, Set<ArtifactRange>, Set<PluginClass>, Map<String, String>) - Method in class co.cask.cdap.internal.app.runtime.artifact.AuthorizationArtifactRepository
 
addArtifact(Id.Artifact, File) - Method in class co.cask.cdap.internal.app.runtime.artifact.DefaultArtifactRepository
 
addArtifact(Id.Artifact, File, Set<ArtifactRange>, Set<PluginClass>) - Method in class co.cask.cdap.internal.app.runtime.artifact.DefaultArtifactRepository
 
addArtifact(Id.Artifact, File, Set<ArtifactRange>, Set<PluginClass>, Map<String, String>) - Method in class co.cask.cdap.internal.app.runtime.artifact.DefaultArtifactRepository
 
addArtifact(Location, ArtifactId) - Method in class co.cask.cdap.internal.app.runtime.plugin.PluginInstantiator
Adds a artifact Jar present at the given Location to allow Plugin Instantiator to load the class
addArtifact(ArtifactId, File) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addArtifact(ArtifactId, File) - Static method in class co.cask.cdap.test.TestBase
Add the specified artifact.
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
 
addAttribute(ConsumerConfig, Map<String, byte[]>) - Static method in class co.cask.cdap.data2.transaction.queue.hbase.DequeueScanAttributes
 
addAttribute(Transaction, Map<String, byte[]>) - Static method in class co.cask.cdap.data2.transaction.queue.hbase.DequeueScanAttributes
 
addBatch() - Method in class co.cask.cdap.explore.jdbc.ExplorePreparedStatement
 
addBatch(String) - Method in class co.cask.cdap.explore.jdbc.ExploreStatement
 
addChangeListener(String, PropertyChangeListener<T>) - Method in class co.cask.cdap.common.conf.AbstractPropertyStore
 
addChangeListener(String, PropertyChangeListener<T>) - Method in interface co.cask.cdap.common.conf.PropertyStore
Adds a listener for listening changes on a given property.
addChannelPipelineModifier(ChannelPipelineModifier) - Method in class co.cask.cdap.common.http.CommonNettyHttpServiceBuilder
 
addChecksInPackage(String) - Method in class co.cask.cdap.common.startup.CheckRunner.Builder
Recursively search the specified package for any Checks and add them.
addClass(String) - Method in class co.cask.cdap.common.startup.CheckRunner.Builder
Adds the Check given its class name.
addClass(ClassDefinition) - Method in class co.cask.cdap.internal.asm.ByteCodeClassLoader
Adds a class definition for this ClassLoader.
addColumn(byte[], byte[]) - Method in class co.cask.cdap.data2.util.hbase.DefaultScanBuilder
 
addColumn(byte[], byte[]) - Method in interface co.cask.cdap.data2.util.hbase.GetBuilder
 
addColumn(byte[], byte[]) - Method in interface co.cask.cdap.data2.util.hbase.ScanBuilder
 
addColumnFamily(ColumnFamilyDescriptor) - Method in class co.cask.cdap.data2.util.hbase.TableDescriptorBuilder
 
addCommandHandler(String, String, CommandPortService.CommandHandler) - Method in class co.cask.cdap.common.service.CommandPortService.Builder
Adds a CommandPortService.CommandHandler for a given command.
addCompiler(SparkCompiler, Closeable) - Method in class co.cask.cdap.app.runtime.spark.dynamic.SparkCompilerCleanupManager
Adds a SparkCompiler.
addConfig(String, String) - Method in class co.cask.cdap.common.ssh.SSHConfig.Builder
 
addConfigs(Map<String, String>) - Method in class co.cask.cdap.common.ssh.SSHConfig.Builder
 
addConnection(String, String) - Method in class co.cask.cdap.etl.common.PipelinePhase.Builder
 
addConnection(String, String) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addConnection(String, String) - Method in class co.cask.cdap.etl.planner.Dag
Add the specified connection.
addConnection(String, String) - Method in class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
addConnection(Connection) - Method in class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
addConnection(String, String) - Method in class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
addConnection(String, String, String) - Method in class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
addConnection(String, String, Boolean) - Method in class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
addConnection(Connection) - Method in class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
addConnection(String, String) - Method in class co.cask.cdap.etl.spec.PipelineSpec.Builder
 
addConnections(String, Collection<String>) - Method in class co.cask.cdap.etl.common.PipelinePhase.Builder
 
addConnections(Collection<Connection>) - Method in class co.cask.cdap.etl.common.PipelinePhase.Builder
 
addConnections(Collection<Connection>) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addConnections(Collection<Connection>) - Method in class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
addConnections(Collection<Connection>) - Method in class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
addConnections(Collection<Connection>) - Method in class co.cask.cdap.etl.spec.PipelineSpec.Builder
 
addConnectors(String...) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addContainer(Containers.ContainerInfo) - Method in interface co.cask.cdap.proto.Containers
addContainer(Containers.ContainerInfo) - Method in class co.cask.cdap.proto.DistributedProgramLiveInfo
 
addContainer(Containers.ContainerInfo) - Method in class co.cask.cdap.proto.SystemServiceLiveInfo.Builder
 
addCoprocessor(HTableDescriptorBuilder, Class<? extends Coprocessor>, Integer) - Method in class co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin
 
addCoprocessor(String) - Method in class co.cask.cdap.data2.util.hbase.HBase10HTableDescriptorBuilder
 
addCoprocessor(String, Path, int, Map<String, String>) - Method in class co.cask.cdap.data2.util.hbase.HBase10HTableDescriptorBuilder
 
addCoprocessor(String) - Method in class co.cask.cdap.data2.util.hbase.HBase11HTableDescriptorBuilder
 
addCoprocessor(String, Path, int, Map<String, String>) - Method in class co.cask.cdap.data2.util.hbase.HBase11HTableDescriptorBuilder
 
addCoprocessor(String) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570HTableDescriptorBuilder
 
addCoprocessor(String, Path, int, Map<String, String>) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570HTableDescriptorBuilder
 
addCoprocessor(String) - Method in class co.cask.cdap.data2.util.hbase.HTableDescriptorBuilder
 
addCoprocessor(String, Path, int, Map<String, String>) - Method in class co.cask.cdap.data2.util.hbase.HTableDescriptorBuilder
 
addCoprocessor(CoprocessorDescriptor) - Method in class co.cask.cdap.data2.util.hbase.TableDescriptorBuilder
 
addDag(Dag) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addDatasetInstance(String, DatasetId) - Method in class co.cask.cdap.test.AbstractTestManager
 
addDatasetInstance(String, DatasetId, DatasetProperties) - Method in class co.cask.cdap.test.IntegrationTestManager
 
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(DatasetId, String) - Method in class co.cask.cdap.test.TestBase
Adds an instance of dataset.
addDatasetInstance(String, String) - Method in class co.cask.cdap.test.TestBase
Adds an instance of dataset.
addDatasetInstance(String, DatasetId, DatasetProperties) - Method in interface co.cask.cdap.test.TestManager
Adds an instance of a dataset.
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.
addDatasetModule(String, Class<? extends DatasetModule>) - Method in class co.cask.cdap.etl.common.DefaultPipelineConfigurer
 
addDatasetModule(String, Class<? extends DatasetModule>) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer
 
addDatasetModule(String, Class<? extends DatasetModule>) - Method in class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable
 
addDatasetModule(String, Class<? extends DatasetModule>) - Method in class co.cask.cdap.internal.api.DefaultDatasetConfigurer
 
addDatasetModules(Map<String, String>) - Method in class co.cask.cdap.internal.api.DefaultDatasetConfigurer
 
addDatasetSpecs(Map<String, DatasetCreationSpec>) - Method in class co.cask.cdap.internal.api.DefaultDatasetConfigurer
 
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.
addDatasetType(Class<? extends Dataset>) - Method in class co.cask.cdap.etl.common.DefaultPipelineConfigurer
 
addDatasetType(Class<? extends Dataset>) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer
 
addDatasetType(Class<? extends Dataset>) - Method in class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable
 
addDatasetType(Class<? extends Dataset>) - Method in class co.cask.cdap.internal.api.DefaultDatasetConfigurer
 
addDelegationTokens(String, Credentials) - Method in interface co.cask.cdap.common.security.DelegationTokensUpdater
 
addDelegationTokens(String, Credentials) - Method in class co.cask.cdap.security.store.KMSSecureStore
Uses the KeyProviderDelegationTokenExtension to get the delegation token for KMS.
addDeletions(MetadataRecordV2) - Method in class co.cask.cdap.data2.audit.payload.builder.MetadataPayloadBuilder
Add the deletions to the previous value of metadata to get the current value of metadata.
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.
addElement(Element) - Method in class co.cask.cdap.common.collect.AllCollector
 
addElement(Map.Entry<KEY, VALUE>) - Method in class co.cask.cdap.common.collect.AllPairCollector
 
addElement(Element) - Method in interface co.cask.cdap.common.collect.Collector
collect one element.
addElement(Element) - Method in class co.cask.cdap.common.collect.FirstNCollector
 
addElement(Element) - Method in class co.cask.cdap.common.collect.LastNCollector
 
addError(String) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
addError(String, Throwable) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
addErrorConsumer(PipeStage<RecordInfo<ErrorRecord<Object>>>) - Method in class co.cask.cdap.etl.batch.PipeEmitter.Builder
 
addExtraClasspath(Iterable<String>) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addExtraDependencies(Class<?>...) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addExtraDependencies(Iterable<? extends Class<?>>) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addExtraEnv(Map<String, String>) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addExtraResources(Map<String, LocalizeResource>) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addExtraSystemArgument(String, String) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addExtraSystemArguments(Map<String, String>) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
Adds extra system arguments that will be available through the ProgramOptions.getArguments() in the program container.
addExtraTransactionAware(TransactionAware) - Method in class co.cask.cdap.data2.dataset2.DynamicDatasetCache
Add an extra transaction aware to the static datasets.
addExtraTransactionAware(TransactionAware) - Method in class co.cask.cdap.data2.dataset2.MultiThreadDatasetCache
 
addExtraTransactionAware(TransactionAware) - Method in class co.cask.cdap.data2.dataset2.SingleThreadDatasetCache
 
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).
addFamily(byte[]) - Method in class co.cask.cdap.data2.util.hbase.DefaultScanBuilder
 
addFamily(byte[]) - Method in interface co.cask.cdap.data2.util.hbase.GetBuilder
 
addFamily(HColumnDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase10HTableDescriptorBuilder
 
addFamily(HColumnDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase11HTableDescriptorBuilder
 
addFamily(HColumnDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570HTableDescriptorBuilder
 
addFamily(HColumnDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HTableDescriptorBuilder
 
addFamily(byte[]) - Method in interface co.cask.cdap.data2.util.hbase.ScanBuilder
 
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.
addFieldLineageInfo(ProgramRunId, FieldLineageInfo) - Method in class co.cask.cdap.data2.metadata.lineage.field.FieldLineageDataset
Store the field lineage information.
addFilter(Filter<E>) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
addFlow(Flow) - Method in class co.cask.cdap.api.app.AbstractApplication
Deprecated.
As of release 5.0.0, replaced by @ProgramType.SPARK for realtime processing.
addFlow(Flow) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Deprecated.
As of release 5.0.0, replaced by @ProgramType.SPARK for realtime processing.
addFlow(Flow) - Method in class co.cask.cdap.app.DefaultAppConfigurer
 
addFlowlet(Flowlet) - Method in class co.cask.cdap.api.flow.AbstractFlow
Deprecated.
Adds a Flowlet to the Flow.
addFlowlet(Flowlet, int) - Method in class co.cask.cdap.api.flow.AbstractFlow
Deprecated.
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
Deprecated.
Add a flowlet to flow with the specified name.
addFlowlet(String, Flowlet, int) - Method in class co.cask.cdap.api.flow.AbstractFlow
Deprecated.
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
Deprecated.
Add a Flowlet to the Flow.
addFlowlet(Flowlet, int) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Deprecated.
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
Deprecated.
Add a flowlet to flow with the specified name.
addFlowlet(String, Flowlet, int) - Method in interface co.cask.cdap.api.flow.FlowConfigurer
Deprecated.
Add a flowlet to the flow with the minimum number of instances of the flowlet to start with.
addFlowlet(Flowlet) - Method in class co.cask.cdap.internal.app.runtime.flow.DefaultFlowConfigurer
 
addFlowlet(Flowlet, int) - Method in class co.cask.cdap.internal.app.runtime.flow.DefaultFlowConfigurer
 
addFlowlet(String, Flowlet) - Method in class co.cask.cdap.internal.app.runtime.flow.DefaultFlowConfigurer
 
addFlowlet(String, Flowlet, int) - Method in class co.cask.cdap.internal.app.runtime.flow.DefaultFlowConfigurer
 
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.
addHandlers(SparkHttpServiceHandler...) - Method in class co.cask.cdap.api.spark.AbstractExtendedSpark
Adds a list of SparkHttpServiceHandlers to runs in the Spark driver.
addHandlers(Iterable<? extends SparkHttpServiceHandler>) - Method in class co.cask.cdap.api.spark.AbstractExtendedSpark
Adds a list of SparkHttpServiceHandlers to runs in the Spark driver.
addHandlers(SparkHttpServiceHandler...) - Method in interface co.cask.cdap.api.spark.ExtendedSparkConfigurer
Adds a list of SparkHttpServiceHandlers to runs in the Spark driver.
addHandlers(Iterable<? extends SparkHttpServiceHandler>) - Method in interface co.cask.cdap.api.spark.ExtendedSparkConfigurer
Adds a list of SparkHttpServiceHandlers to runs in the Spark driver.
addHandlers(Iterable<? extends HttpServiceHandler>) - Method in class co.cask.cdap.internal.app.services.DefaultServiceConfigurer
 
addHostnameChangeListener(CLIConfig.ConnectionChangeListener) - Method in class co.cask.cdap.cli.CLIConfig
 
addImmutable(byte[], byte[], byte[]) - Method in interface co.cask.cdap.data2.util.hbase.PutBuilder
 
addImmutable(byte[], byte[], long, byte[]) - Method in interface co.cask.cdap.data2.util.hbase.PutBuilder
 
addImmutable(byte[], ByteBuffer, long, ByteBuffer) - Method in interface co.cask.cdap.data2.util.hbase.PutBuilder
 
addInfo(Configuration) - Method in class co.cask.cdap.hbase.wd.AbstractRowKeyDistributor
 
addInfo(String) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
addInfo(String, Throwable) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
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.
addInput(Job, String, String, Map<String, String>, Class<? extends Mapper>) - Static method in class co.cask.cdap.internal.app.runtime.batch.dataset.input.MultipleInputs
Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.
addInput(Input) - Method in class co.cask.cdap.internal.app.runtime.batch.MapReduceLifecycleContext
 
addInput(Input, Class<?>) - Method in class co.cask.cdap.internal.app.runtime.batch.MapReduceLifecycleContext
 
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.
addInputSchema(String, Schema) - Method in class co.cask.cdap.etl.common.DefaultStageConfigurer
 
addInputSchema(String, Schema) - Method in class co.cask.cdap.etl.spec.StageSpec.Builder
 
addInputSchemas(Map<String, Schema>) - Method in class co.cask.cdap.etl.spec.StageSpec.Builder
 
addInstance(String, String, DatasetProperties) - Method in class co.cask.cdap.data2.datafabric.dataset.DatasetServiceClient
 
addInstance(String, String, DatasetProperties, KerberosPrincipalId) - Method in class co.cask.cdap.data2.datafabric.dataset.DatasetServiceClient
 
addInstance(String, DatasetId, DatasetProperties, KerberosPrincipalId) - Method in class co.cask.cdap.data2.datafabric.dataset.RemoteDatasetFramework
 
addInstance(String, DatasetId, DatasetProperties) - Method in interface co.cask.cdap.data2.dataset2.DatasetFramework
Adds information about dataset instance to the system.
addInstance(String, DatasetId, DatasetProperties, KerberosPrincipalId) - Method in interface co.cask.cdap.data2.dataset2.DatasetFramework
Adds information about dataset instance to the system.
addInstance(String, DatasetId, DatasetProperties, KerberosPrincipalId) - Method in class co.cask.cdap.data2.dataset2.ForwardingDatasetFramework
 
addInstance(String, DatasetId, DatasetProperties, KerberosPrincipalId) - Method in class co.cask.cdap.data2.dataset2.InMemoryDatasetFramework
 
addInstance(String, DatasetId, DatasetProperties, KerberosPrincipalId) - Method in class co.cask.cdap.data2.dataset2.preview.PreviewDatasetFramework
 
addInstance(String, DatasetId, DatasetProperties, KerberosPrincipalId) - Method in class co.cask.cdap.internal.app.runtime.workflow.NameMappedDatasetFramework
 
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.
addIsolationNodes(String...) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addIsolationNodes(Collection<String>) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addJoinKey(StageSpec, String, SparkCollection<Object>, StageStatisticsCollector) - Method in class co.cask.cdap.datastreams.SparkStreamingPipelineRunner
 
addJoinKey(StageSpec, String, SparkCollection<Object>, StageStatisticsCollector) - Method in class co.cask.cdap.etl.spark.batch.BatchSparkPipelineDriver
 
addJoinKey(StageSpec, String, SparkCollection<Object>, StageStatisticsCollector) - Method in class co.cask.cdap.etl.spark.SparkPipelineRunner
 
addJVMOptions(String) - Method in class co.cask.cdap.internal.app.runtime.distributed.ForwardingTwillPreparer
 
addKey(KeyIdentifier) - Method in class co.cask.cdap.security.auth.AbstractKeyManager
Adds a given key instance.
addKey(KeyIdentifier) - Method in class co.cask.cdap.security.auth.DistributedKeyManager
 
addKey(KeyIdentifier) - Method in class co.cask.cdap.security.auth.MapBackedKeyManager
 
addLabeledData(HttpServiceRequest, HttpServiceResponder) - Method in class co.cask.cdap.examples.dtree.ModelDataService.ModelHandler
 
addLast(Stage) - Method in class co.cask.cdap.internal.pipeline.AbstractPipeline
Adds a Stage to the Pipeline.
addLast(Stage) - Method in interface co.cask.cdap.pipeline.Pipeline
Adds a Stage to the end of this pipeline.
addListener(ProgramController.Listener, Executor) - Method in interface co.cask.cdap.app.runtime.ProgramController
Adds a listener to watch for state changes.
addListener(RESTClient.Listener) - Method in class co.cask.cdap.client.util.RESTClient
 
addListener(StreamId, StreamPropertyListener) - Method in class co.cask.cdap.data.stream.AbstractStreamCoordinatorClient
 
addListener(StreamId, StreamPropertyListener) - Method in interface co.cask.cdap.data.stream.StreamCoordinatorClient
Receives event for changes in stream properties.
addListener(ProgramController.Listener, Executor) - Method in class co.cask.cdap.internal.app.runtime.AbstractProgramController
 
addListener(ResourceListener<T>) - Method in class co.cask.cdap.security.zookeeper.SharedResourceCache
Adds a ResourceListener to be notified of cache updates.
addLogHandler(LogHandler) - Method in class co.cask.cdap.internal.app.runtime.distributed.ForwardingTwillPreparer
 
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
addMapReduce(MapReduce) - Method in class co.cask.cdap.app.DefaultAppConfigurer
 
addMapReduce(String) - Method in class co.cask.cdap.datapipeline.ConditionToConditionAdder
 
addMapReduce(String) - Method in class co.cask.cdap.datapipeline.ConditionToForkAdder
 
addMapReduce(String) - Method in class co.cask.cdap.datapipeline.ConditionToTrunkAdder
 
addMapReduce(String) - Method in class co.cask.cdap.datapipeline.ForkToConditionAdder
 
addMapReduce(String) - Method in class co.cask.cdap.datapipeline.ForkToForkAdder
 
addMapReduce(String) - Method in class co.cask.cdap.datapipeline.ForkToTrunkAdder
 
addMapReduce(String) - Method in class co.cask.cdap.datapipeline.TrunkProgramAdder
 
addMapReduce(String) - Method in interface co.cask.cdap.datapipeline.WorkflowProgramAdder
 
addMapReduce(String) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConditionConfigurer
 
addMapReduce(String) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConfigurer
 
addMapReduce(String) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowForkConfigurer
 
addMapReduceClassPath(Configuration, T) - Static method in class co.cask.cdap.internal.app.runtime.batch.distributed.MapReduceContainerHelper
Adds the classpath to be used in MapReduce job execution based on the given Configuration.
addMaster(Map<String, String>, ImmutableList.Builder<String>) - Method in class co.cask.cdap.app.runtime.spark.submit.AbstractSparkSubmitter
Add the --master argument for the Spark submission.
addMaster(Map<String, String>, ImmutableList.Builder<String>) - Method in class co.cask.cdap.app.runtime.spark.submit.DistributedSparkSubmitter
 
addMaster(Map<String, String>, ImmutableList.Builder<String>) - Method in class co.cask.cdap.app.runtime.spark.submit.LocalSparkSubmitter
 
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
addMessage(LogMessage) - Method in class co.cask.cdap.logging.appender.AbstractLogPublisher
Adds a log message for publishing.
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.
addMetadata(PartitionKey, String, String) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset
 
addMetadata(PartitionKey, Map<String, String>) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset
 
addMetadata(long, String, String) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.TimePartitionedFileSetDataset
 
addMetadata(long, Map<String, String>) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.TimePartitionedFileSetDataset
 
AddMetadataPropertiesCommand - Class in co.cask.cdap.cli.command.metadata
Adds metadata properties for an entity.
AddMetadataPropertiesCommand(CLIConfig, MetadataClient) - Constructor for class co.cask.cdap.cli.command.metadata.AddMetadataPropertiesCommand
 
AddMetadataTagsCommand - Class in co.cask.cdap.cli.command.metadata
Adds metadata tags for an entity.
AddMetadataTagsCommand(CLIConfig, MetadataClient) - Constructor for class co.cask.cdap.cli.command.metadata.AddMetadataTagsCommand
 
addModule(String, String, Location) - Method in class co.cask.cdap.data2.datafabric.dataset.DatasetServiceClient
 
addModule(DatasetModuleId, DatasetModule) - Method in class co.cask.cdap.data2.datafabric.dataset.RemoteDatasetFramework
 
addModule(DatasetModuleId, DatasetModule, Location) - Method in class co.cask.cdap.data2.datafabric.dataset.RemoteDatasetFramework
 
addModule(DatasetModuleId, String, boolean) - Method in class co.cask.cdap.data2.datafabric.dataset.service.AuthorizationDatasetTypeService
 
addModule(HttpRequest, HttpResponder, String, String, boolean, String) - Method in class co.cask.cdap.data2.datafabric.dataset.service.DatasetTypeHandler
 
addModule(DatasetModuleId, String, boolean) - Method in interface co.cask.cdap.data2.datafabric.dataset.service.DatasetTypeService
Adds a new DatasetModule.
addModule(DatasetModuleId, String, boolean) - Method in class co.cask.cdap.data2.datafabric.dataset.service.DefaultDatasetTypeService
Adds a new DatasetModule.
addModule(DatasetModuleId, String, Location, boolean) - Method in class co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager
Add datasets module in a namespace
addModule(DatasetModuleId, DatasetModule) - Method in interface co.cask.cdap.data2.dataset2.DatasetFramework
Adds dataset types by adding dataset module to the system.
addModule(DatasetModuleId, DatasetModule, Location) - Method in interface co.cask.cdap.data2.dataset2.DatasetFramework
Adds dataset types by adding dataset module to the system with a jar location containing all dataset classes needed by the module.
addModule(DatasetModuleId, DatasetModule) - Method in class co.cask.cdap.data2.dataset2.ForwardingDatasetFramework
 
addModule(DatasetModuleId, DatasetModule, Location) - Method in class co.cask.cdap.data2.dataset2.ForwardingDatasetFramework
 
addModule(DatasetModuleId, DatasetModule) - Method in class co.cask.cdap.data2.dataset2.InMemoryDatasetFramework
 
addModule(DatasetModuleId, DatasetModule, Location) - Method in class co.cask.cdap.data2.dataset2.InMemoryDatasetFramework
 
addModule(DatasetModuleId, DatasetModule) - Method in class co.cask.cdap.data2.dataset2.StaticDatasetFramework
 
addModule(DatasetModuleId, DatasetModule, Location) - Method in class co.cask.cdap.data2.dataset2.StaticDatasetFramework
 
addMultiPortNodes(String...) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addMultiPortNodes(Collection<String>) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addNamedOutput(Job, String, String, Class<?>, Class<?>, Map<String, String>) - Static method in class co.cask.cdap.internal.app.runtime.batch.dataset.output.MultipleOutputs
Adds a named output for the job.
addNamespace(NamespaceMeta) - Method in class co.cask.cdap.explore.client.AbstractExploreClient
 
addNamespace(NamespaceMeta) - Method in interface co.cask.cdap.explore.client.ExploreClient
Creates a namespace in Explore.
addNamespace(NamespaceMeta) - Method in class co.cask.cdap.explore.client.MockExploreClient
 
addNotification(ProgramScheduleRecord, Notification) - Method in interface co.cask.cdap.internal.app.runtime.schedule.queue.JobQueue
Adds the given notification to jobs for the given schedule.
addNotification(ProgramScheduleRecord, Notification) - Method in class co.cask.cdap.internal.app.runtime.schedule.queue.JobQueueDataset
 
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(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.
addOutput(Output) - Method in class co.cask.cdap.etl.batch.mapreduce.MapReduceBatchContext
 
addOutput(Output) - Method in class co.cask.cdap.etl.spark.batch.SparkBatchSinkContext
 
addOutput(Output) - Method in class co.cask.cdap.internal.app.runtime.batch.MapReduceLifecycleContext
 
addOutputConsumer(PipeStage<RecordInfo>) - Method in class co.cask.cdap.etl.batch.PipeEmitter.Builder
 
addOutputConsumer(PipeStage<RecordInfo>, String) - Method in class co.cask.cdap.etl.batch.PipeEmitter.Builder
 
addOutputPortSchema(String, String, Schema) - Method in class co.cask.cdap.etl.spec.StageSpec.Builder
 
addOutputPortSchemas(Map<String, StageSpec.Port>) - Method in class co.cask.cdap.etl.spec.StageSpec.Builder
 
addOutputSchema(Schema, String...) - Method in class co.cask.cdap.etl.spec.StageSpec.Builder
 
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.
addPartition(ResourceRequirement.Partition) - Method in class co.cask.cdap.common.zookeeper.coordination.ResourceRequirement.Builder
Adds a partition.
addPartition(PartitionKey, String) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset
 
addPartition(PartitionKey, String, Map<String, String>) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset
 
addPartition(PartitionKey, String, Map<String, String>, boolean, boolean) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset
 
addPartition() - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset.BasicPartitionOutput
 
addPartition(long, String) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.TimePartitionedFileSetDataset
 
addPartition(long, String, Map<String, String>) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.TimePartitionedFileSetDataset
 
addPartition(DatasetId, DatasetSpecification, PartitionKey, String) - Method in class co.cask.cdap.explore.client.AbstractExploreClient
 
addPartition(DatasetId, DatasetSpecification, PartitionKey, String) - Method in interface co.cask.cdap.explore.client.ExploreClient
Add a partition to a dataset's table.
addPartition(DatasetId, DatasetSpecification, PartitionKey, String) - Method in class co.cask.cdap.explore.client.ExploreFacade
 
addPartition(DatasetId, DatasetSpecification, PartitionKey, String) - Method in class co.cask.cdap.explore.client.MockExploreClient
 
addPartition(FullHttpRequest, HttpResponder, String, String, String) - Method in class co.cask.cdap.explore.executor.ExploreExecutorHttpHandler
 
addPartition(DatasetId, Map<String, String>, PartitionKey, String) - Method in class co.cask.cdap.explore.service.ExploreTableManager
Adds a partition to the Hive table for the given dataset.
addPartitions(String, int, int) - Method in class co.cask.cdap.common.zookeeper.coordination.ResourceRequirement.Builder
Adds N partitions with each partition named by a prefix followed by a sequence id, starting from 0.
addPartitionToExplore(PartitionKey, String) - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset
 
addPattern(Grok, String) - Method in class co.cask.cdap.format.GrokRecordFormat
 
addPatterns(Grok) - Method in class co.cask.cdap.format.GrokRecordFormat
 
addPayload(String, String) - Method in class co.cask.cdap.common.service.RegisteredServerInfo
 
addPayload(String) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder
Adds a single payload string to the request.
addPayload(byte[]) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder
Adds a single byte array to the payload of the request.
addPayloads(Iterator<byte[]>) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder
Adds a list of byte arrays as the payloads of the request.
addPayloads(Iterable<byte[]>) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder
Adds a list of byte arrays as the payloads of the request.
addPlugin(PluginClass) - Method in class co.cask.cdap.api.artifact.ArtifactClasses.Builder
 
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(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(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(ArtifactId, Set<ArtifactRange>, Class<?>, Class<?>...) - Static method in class co.cask.cdap.test.TestBase
Build an artifact from the specified plugin classes and then add it.
addPluginArtifact(ArtifactId, ArtifactId, Class<?>, Class<?>...) - Method in interface co.cask.cdap.test.TestManager
Builds an artifact from the specified plugin classes and then adds it.
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(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(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
 
addPlugins(PluginClass...) - Method in class co.cask.cdap.api.artifact.ArtifactClasses.Builder
 
addPlugins(Iterable<PluginClass>) - Method in class co.cask.cdap.api.artifact.ArtifactClasses.Builder
 
addPlugins(Map<String, Plugin>) - Method in class co.cask.cdap.internal.app.AbstractConfigurer
 
addPostAction(ETLStage) - Method in class co.cask.cdap.etl.proto.v2.ETLBatchConfig.Builder
 
addPostActions(Collection<ETLStage>) - Method in class co.cask.cdap.etl.proto.v2.ETLBatchConfig.Builder
 
addPrevious(MetadataRecordV2) - Method in class co.cask.cdap.data2.audit.payload.builder.MetadataPayloadBuilder
Add the previous value of metadata.
addProfileArgs(Map<String, String>, Profile) - Static method in class co.cask.cdap.internal.app.runtime.SystemArguments
Adds any profile related arguments to the map
addProfileAssignment(ProfileId, EntityId) - Method in class co.cask.cdap.internal.app.store.profile.ProfileDataset
Add an assignment to the profile.
addProfileAssignment(ProfileId, EntityId) - Method in class co.cask.cdap.internal.profile.ProfileService
Add an assignment to the profile.
addProgramSchedule(ProgramSchedule) - Method in class co.cask.cdap.internal.app.runtime.schedule.AbstractTimeSchedulerService
 
addProgramSchedule(ProgramSchedule) - Method in class co.cask.cdap.internal.app.runtime.schedule.TimeScheduler
 
addProgramSchedule(ProgramSchedule) - Method in interface co.cask.cdap.internal.app.runtime.schedule.TimeSchedulerService
Add a new schedule converted from the given ProgramSchedule.
addProperties(MetadataEntity, Map<String, String>) - Method in interface co.cask.cdap.api.metadata.MetadataWriter
Adds the specified Map to the metadata of the specified metadataEntity.
addProperties(EntityId, Map<String, String>) - Method in class co.cask.cdap.common.metadata.AbstractMetadataClient
 
addProperties(MetadataEntity, Map<String, String>) - Method in class co.cask.cdap.common.metadata.AbstractMetadataClient
Adds properties to an application.
addProperties(Map<String, String>) - Method in class co.cask.cdap.config.PreferencesService
Set instance level preferences if they are not already set.
addProperties(MetadataEntity, Map<String, String>) - Method in class co.cask.cdap.etl.common.AbstractStageContext
 
addProperties(MetadataEntity, Map<String, String>) - Method in class co.cask.cdap.etl.mock.action.MockActionContext
 
addProperties(MetadataEntity, Map<String, String>) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
 
addProperties(MetadataEntity, Map<String, String>) - Method in class co.cask.cdap.internal.app.runtime.AbstractContext
 
addProperties(MetadataEntity, Map<String, String>) - Method in class co.cask.cdap.internal.app.runtime.batch.MapReduceLifecycleContext
 
addProperties(MetadataEntity, Map<String, String>) - Method in class co.cask.cdap.metadata.DefaultMetadataAdmin
 
addProperties(MetadataEntity, Map<String, String>) - Method in interface co.cask.cdap.metadata.MetadataAdmin
Adds the specified Map to the metadata of the specified metadataEntity.
addProperties(FullHttpRequest, HttpResponder, String) - Method in class co.cask.cdap.metadata.MetadataHttpHandler
 
addProperty(String, String) - Method in class co.cask.cdap.data2.util.hbase.ColumnFamilyDescriptorBuilder
 
addProperty(String, String) - Method in class co.cask.cdap.data2.util.hbase.TableDescriptorBuilder
 
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.
addReduceNodes(String...) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addReduceNodes(Collection<String>) - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
addResource(String) - Method in class co.cask.cdap.common.conf.Configuration
Add a configuration resource.
addResource(URL) - Method in class co.cask.cdap.common.conf.Configuration
Add a configuration resource.
addResource(InputStream) - Method in class co.cask.cdap.common.conf.Configuration
Add a configuration resource.
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.Dataset.Executor
for the address (hostname) of the dataset server.
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.LogSaver
 
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.Metrics
 
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.MetricsProcessor
 
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.Preview
Guice named bindings.
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.Router
 
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.Stream
 
ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.Transaction.Container
 
addRoleToPrincipal(Role, Principal) - Method in class co.cask.cdap.client.AuthorizationClient
 
addRoleToPrincipal(HttpRequest, HttpResponder, String, String, String) - Method in class co.cask.cdap.gateway.handlers.AuthorizationHandler
 
addRoleToPrincipal(Role, Principal) - Method in interface co.cask.cdap.security.spi.authorization.Authorizer
Add a role to the specified Principal.
addRoleToPrincipal(Role, Principal) - Method in class co.cask.cdap.security.spi.authorization.NoOpAuthorizer
 
AddRoleToPrincipalCommand - Class in co.cask.cdap.cli.command.security
Adds a Role to a Principal
addRunnable(String, TwillRunnable, int, Map<String, String>, Resources) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addRunnable(String, TwillRunnable, int, Map<String, String>, Resources, Integer) - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
addSchedule(ApplicationId, ScheduleDetail) - Method in class co.cask.cdap.client.ApplicationClient
Add a schedule to an application.
addSchedule(FullHttpRequest, HttpResponder, String, String, String) - Method in class co.cask.cdap.gateway.handlers.ProgramLifecycleHttpHandler
 
addSchedule(FullHttpRequest, HttpResponder, String, String, String, String) - Method in class co.cask.cdap.gateway.handlers.ProgramLifecycleHttpHandler
 
addSchedule(ProgramSchedule) - Method in class co.cask.cdap.internal.app.runtime.schedule.store.ProgramScheduleStoreDataset
Add a schedule to the store.
addSchedule(ProgramSchedule) - Method in class co.cask.cdap.scheduler.CoreSchedulerService
 
addSchedule(ProgramSchedule) - Method in class co.cask.cdap.scheduler.NoOpScheduler
 
addSchedule(ProgramSchedule) - Method in interface co.cask.cdap.scheduler.Scheduler
Add a schedule to the store.
addSchedule(ScheduleDetail) - Method in interface co.cask.cdap.test.ApplicationManager
Adds a schedule to the app.
addSchedule(ScheduleId, ScheduleDetail) - Method in class co.cask.cdap.test.IntegrationTestManager
 
addSchedule(ScheduleDetail) - Method in class co.cask.cdap.test.internal.DefaultApplicationManager
 
addSchedule(ScheduleDetail) - Method in class co.cask.cdap.test.remote.RemoteApplicationManager
 
addSchedule(ScheduleId, ScheduleDetail) - Method in class co.cask.cdap.test.TestBase
Add a new schedule to an existing application
addSchedule(ScheduleId, ScheduleDetail) - Method in interface co.cask.cdap.test.TestManager
Add a new schedule to an existing application
addSchedule(ScheduleId, ScheduleDetail) - Method in class co.cask.cdap.test.UnitTestManager
 
addSchedules(Iterable<? extends ProgramSchedule>) - Method in class co.cask.cdap.internal.app.runtime.schedule.store.ProgramScheduleStoreDataset
Add one or more schedules to the store.
addSchedules(Iterable<? extends ProgramSchedule>) - Method in class co.cask.cdap.scheduler.CoreSchedulerService
 
addSchedules(Iterable<? extends ProgramSchedule>) - Method in class co.cask.cdap.scheduler.NoOpScheduler
 
addSchedules(Iterable<? extends ProgramSchedule>) - Method in interface co.cask.cdap.scheduler.Scheduler
Add one or more schedules to the store.
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.
addSecureStore(SecureStore) - Method in class co.cask.cdap.internal.app.runtime.distributed.ForwardingTwillPreparer
 
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.
addService(Service) - Method in class co.cask.cdap.app.DefaultAppConfigurer
 
addServices(List<? super Service>) - Method in class co.cask.cdap.common.twill.AbstractMasterTwillRunnable
Class extending AbstractMasterTwillRunnable should populate services with a list of Services which will be started in increasing order of index.
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.DatasetOpExecutorServerTwillRunnable
 
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.ExploreServiceTwillRunnable
 
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.LogSaverTwillRunnable
 
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.MessagingServiceTwillRunnable
 
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.MetricsProcessorTwillRunnable
 
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.MetricsTwillRunnable
 
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.StreamHandlerRunnable
 
addServices(List<? super Service>) - Method in class co.cask.cdap.data.runtime.main.TransactionServiceTwillRunnable
 
addServices(List<String>) - Method in class co.cask.cdap.proto.DistributedProgramLiveInfo
 
addSink(ETLStage) - Method in class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
addSinks(Collection<ETLStage>) - Method in class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
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
addSpark(Spark) - Method in class co.cask.cdap.app.DefaultAppConfigurer
 
addSpark(String) - Method in class co.cask.cdap.datapipeline.ConditionToConditionAdder
 
addSpark(String) - Method in class co.cask.cdap.datapipeline.ConditionToForkAdder
 
addSpark(String) - Method in class co.cask.cdap.datapipeline.ConditionToTrunkAdder
 
addSpark(String) - Method in class co.cask.cdap.datapipeline.ForkToConditionAdder
 
addSpark(String) - Method in class co.cask.cdap.datapipeline.ForkToForkAdder
 
addSpark(String) - Method in class co.cask.cdap.datapipeline.ForkToTrunkAdder
 
addSpark(String) - Method in class co.cask.cdap.datapipeline.TrunkProgramAdder
 
addSpark(String) - Method in interface co.cask.cdap.datapipeline.WorkflowProgramAdder
 
addSpark(String) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConditionConfigurer
 
addSpark(String) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConfigurer
 
addSpark(String) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowForkConfigurer
 
addStage(StageSpec) - Method in class co.cask.cdap.etl.common.PipelinePhase.Builder
 
addStage(ETLStage) - Method in class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
addStage(StageSpec) - Method in class co.cask.cdap.etl.spec.PipelineSpec.Builder
 
addStageInput(String) - Method in class co.cask.cdap.datapipeline.StageOperationsValidator.Builder
Add field from input schema of the stage.
addStageInputs(Collection<String>) - Method in class co.cask.cdap.datapipeline.StageOperationsValidator.Builder
Add collection of fields from input schema of the stage.
addStageOutput(String) - Method in class co.cask.cdap.datapipeline.StageOperationsValidator.Builder
Add field from output schema of the stage.
addStageOutputs(Collection<String>) - Method in class co.cask.cdap.datapipeline.StageOperationsValidator.Builder
Add collection of fields which are part of output schema of the stage.
addStages(Collection<StageSpec>) - Method in class co.cask.cdap.etl.common.PipelinePhase.Builder
 
addStages(Collection<StageSpec>) - Method in class co.cask.cdap.etl.spec.PipelineSpec.Builder
 
addStatus(Status) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
addStream(Stream) - Method in interface co.cask.cdap.api.DatasetConfigurer
Deprecated.
As of release 5.0.0, use Kafka as a replacement technology for Streams
addStream(String) - Method in interface co.cask.cdap.api.DatasetConfigurer
Deprecated.
As of release 5.0.0, use Kafka as a replacement technology for Streams
addStream(NamespaceId, StreamSpecification) - Method in interface co.cask.cdap.app.store.Store
Creates a new stream if it does not exist.
addStream(StreamId) - Method in class co.cask.cdap.data.stream.service.InMemoryStreamMetaStore
 
addStream(StreamId, String) - Method in class co.cask.cdap.data.stream.service.InMemoryStreamMetaStore
 
addStream(StreamId) - Method in class co.cask.cdap.data.stream.service.MDSStreamMetaStore
 
addStream(StreamId, String) - Method in class co.cask.cdap.data.stream.service.MDSStreamMetaStore
 
addStream(StreamId) - Method in interface co.cask.cdap.data.stream.service.StreamMetaStore
Adds a stream to the meta store.
addStream(StreamId, String) - Method in interface co.cask.cdap.data.stream.service.StreamMetaStore
Adds a stream to the meta store (or updates the description of stream, if stream exists).
addStream(Stream) - Method in class co.cask.cdap.etl.common.DefaultPipelineConfigurer
 
addStream(String) - Method in class co.cask.cdap.etl.common.DefaultPipelineConfigurer
 
addStream(Stream) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer
 
addStream(String) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer
 
addStream(String) - Method in class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable
Deprecated.
As of release 5.0.0, use Kafka as a replacement technology for Streams
addStream(Stream) - Method in class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable
Deprecated.
As of release 5.0.0, use Kafka as a replacement technology for Streams
addStream(Stream) - Method in class co.cask.cdap.internal.api.DefaultDatasetConfigurer
 
addStream(String) - Method in class co.cask.cdap.internal.api.DefaultDatasetConfigurer
 
addStream(NamespaceId, StreamSpecification) - Method in class co.cask.cdap.internal.app.store.DefaultStore
 
addStreams(Map<String, StreamSpecification>) - Method in class co.cask.cdap.internal.api.DefaultDatasetConfigurer
 
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.
addSystemArtifacts() - Method in interface co.cask.cdap.internal.app.runtime.artifact.ArtifactRepository
Scan all files in the local system artifact directory, looking for jar files and adding them as system artifacts.
addSystemArtifacts() - Method in class co.cask.cdap.internal.app.runtime.artifact.AuthorizationArtifactRepository
 
addSystemArtifacts() - Method in class co.cask.cdap.internal.app.runtime.artifact.DefaultArtifactRepository
 
addTags(MetadataEntity, String...) - Method in interface co.cask.cdap.api.metadata.MetadataWriter
Adds the specified tags to specified MetadataEntity.
addTags(MetadataEntity, Iterable<String>) - Method in interface co.cask.cdap.api.metadata.MetadataWriter
Adds all the specified tags to specified MetadataEntity.
addTags(EntityId, Set<String>) - Method in class co.cask.cdap.common.metadata.AbstractMetadataClient
 
addTags(MetadataEntity, Set<String>) - Method in class co.cask.cdap.common.metadata.AbstractMetadataClient
 
addTags(MetadataEntity, Set<String>) - Method in class co.cask.cdap.data2.metadata.dataset.MetadataDataset
Adds a new tag for the specified MetadataEntity.
addTags(MetadataScope, MetadataEntity, Set<String>) - Method in class co.cask.cdap.data2.metadata.store.DefaultMetadataStore
Adds tags for the specified MetadataEntity.
addTags(MetadataScope, MetadataEntity, Set<String>) - Method in interface co.cask.cdap.data2.metadata.store.MetadataStore
Adds tags for the specified MetadataEntity in the specified MetadataScope.
addTags(MetadataScope, MetadataEntity, Set<String>) - Method in class co.cask.cdap.data2.metadata.store.NoOpMetadataStore
 
addTags(MetadataEntity, String...) - Method in class co.cask.cdap.etl.common.AbstractStageContext
 
addTags(MetadataEntity, Iterable<String>) - Method in class co.cask.cdap.etl.common.AbstractStageContext
 
addTags(MetadataEntity, String...) - Method in class co.cask.cdap.etl.mock.action.MockActionContext
 
addTags(MetadataEntity, Iterable<String>) - Method in class co.cask.cdap.etl.mock.action.MockActionContext
 
addTags(MetadataEntity, String...) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
 
addTags(MetadataEntity, Iterable<String>) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
 
addTags(MetadataEntity, String...) - Method in class co.cask.cdap.internal.app.runtime.AbstractContext
 
addTags(MetadataEntity, Iterable<String>) - Method in class co.cask.cdap.internal.app.runtime.AbstractContext
 
addTags(MetadataEntity, String...) - Method in class co.cask.cdap.internal.app.runtime.batch.MapReduceLifecycleContext
 
addTags(MetadataEntity, Iterable<String>) - Method in class co.cask.cdap.internal.app.runtime.batch.MapReduceLifecycleContext
 
addTags(MetadataEntity, Set<String>) - Method in class co.cask.cdap.metadata.DefaultMetadataAdmin
 
addTags(MetadataEntity, Set<String>) - Method in interface co.cask.cdap.metadata.MetadataAdmin
Adds the specified tags to specified MetadataEntity.
addTags(FullHttpRequest, HttpResponder, String) - Method in class co.cask.cdap.metadata.MetadataHttpHandler
 
addTargetIdToKey(MDSKey.Builder, NamespacedEntityId) - Static method in class co.cask.cdap.data2.dataset2.lib.table.EntityIdKeyHelper
 
AddTimeScheduleCommand - Class in co.cask.cdap.cli.command.schedule
Adds a schedule.
AddTimeScheduleCommand(CLIConfig, ScheduleClient) - Constructor for class co.cask.cdap.cli.command.schedule.AddTimeScheduleCommand
 
addToArchive(File, ZipOutputStream) - Static method in class co.cask.cdap.common.lang.jar.BundleJarUtil
Adds file(s) to a zip archive.
addToArchive(File, boolean, ZipOutputStream) - Static method in class co.cask.cdap.common.lang.jar.BundleJarUtil
Adds file(s) to a zip archive.
addToOnlineRegions(HRegion) - Method in class co.cask.cdap.data2.util.hbase.MockRegionServerServices
 
addTransactionAware(TransactionAware) - Method in class co.cask.cdap.data2.transaction.AbstractTransactionContext
 
addTransform(ETLStage) - Method in class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
addTransforms(Collection<ETLStage>) - Method in class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
addTypeAdapters(GsonBuilder) - Static method in class co.cask.cdap.internal.app.ApplicationSpecificationAdapter
 
addTypeAdapters(GsonBuilder) - Static method in class co.cask.cdap.internal.app.runtime.schedule.TriggeringScheduleInfoAdapter
 
addTypeAdapters(GsonBuilder) - Static method in class co.cask.cdap.report.util.TriggeringScheduleInfoAdapter
 
addURL(URL) - Method in class org.apache.spark.executor.ExecutorURLClassLoader
 
addURL(URL) - Method in interface org.apache.spark.executor.MutableURLClassLoader
Add a URL.
addURL(URL) - Method in class org.apache.spark.util.MutableURLClassLoader
 
addURLs(Seq<URL>) - Method in class co.cask.cdap.app.runtime.spark.dynamic.SparkClassFileHandler
Adds a set of URLs to the class file search path.
addUsedByModule(String) - Method in class co.cask.cdap.proto.DatasetModuleMeta
Adds module to the list of dependant modules
addValueCondition(String, T) - Method in class co.cask.cdap.api.dataset.lib.PartitionFilter.Builder
Add a condition that matches by equality.
addWarn(String) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
addWarn(String, Throwable) - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
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.
addWorker(Worker) - Method in class co.cask.cdap.app.DefaultAppConfigurer
 
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.
addWorkflow(Workflow) - Method in class co.cask.cdap.app.DefaultAppConfigurer
 
addWorkflowConditionNode(Predicate<WorkflowContext>, List<WorkflowNode>, List<WorkflowNode>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConditionConfigurer
 
addWorkflowConditionNode(Condition, List<WorkflowNode>, List<WorkflowNode>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConditionConfigurer
 
addWorkflowConditionNode(Predicate<WorkflowContext>, List<WorkflowNode>, List<WorkflowNode>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConfigurer
 
addWorkflowConditionNode(Condition, List<WorkflowNode>, List<WorkflowNode>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConfigurer
 
addWorkflowConditionNode(Predicate<WorkflowContext>, List<WorkflowNode>, List<WorkflowNode>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowForkConfigurer
 
addWorkflowConditionNode(Condition, List<WorkflowNode>, List<WorkflowNode>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowForkConfigurer
 
addWorkflowConditionNode(Predicate<WorkflowContext>, List<WorkflowNode>, List<WorkflowNode>) - Method in interface co.cask.cdap.internal.app.workflow.WorkflowConditionAdder
Adds a WorkflowConditionNode to the Workflow.
addWorkflowConditionNode(Condition, List<WorkflowNode>, List<WorkflowNode>) - Method in interface co.cask.cdap.internal.app.workflow.WorkflowConditionAdder
Adds a WorkflowConditionNode to the Workflow.
addWorkflowDetails(String, String, long, Map<String, Long>) - Method in class co.cask.cdap.proto.WorkflowStatsComparison.ProgramNodes
 
addWorkflowForkNode(List<List<WorkflowNode>>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConditionConfigurer
 
addWorkflowForkNode(List<List<WorkflowNode>>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowConfigurer
 
addWorkflowForkNode(List<List<WorkflowNode>>) - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowForkConfigurer
 
addWorkflowNodeState(ProgramRunId, WorkflowNodeStateDetail) - Method in class co.cask.cdap.internal.app.runtime.workflow.BasicWorkflowStateWriter
 
addWorkflowNodeState(ProgramRunId, WorkflowNodeStateDetail) - Method in class co.cask.cdap.internal.app.runtime.workflow.MessagingWorkflowStateWriter
 
addWorkflowNodeState(ProgramRunId, WorkflowNodeStateDetail) - Method in interface co.cask.cdap.internal.app.runtime.workflow.WorkflowStateWriter
Add node state for the given Workflow run.
addWorkflowNodeState(ProgramRunId, WorkflowNodeStateDetail) - Method in class co.cask.cdap.internal.app.store.AppMetadataStore
This method is called to associate node state of custom action with the Workflow run.
Admin - Interface in co.cask.cdap.api
This interface provides methods for operational calls from within a CDAP application.
admin - Variable in class co.cask.cdap.data2.util.hbase.DefaultHBaseDDLExecutor
 
admin - Variable in class co.cask.cdap.etl.batch.AbstractBatchContext
 
adminClass(Class<?>) - Method in class co.cask.cdap.security.ApplicationSecurity.Builder
Defines the admin class that has capability to operate outside of restriction as set by ApplicationSecurity.
AdminEventPublisher - Class in co.cask.cdap.internal.profile
Class for publishing the profile metadata change request to tms
AdminEventPublisher(CConfiguration, MessagingContext) - Constructor for class co.cask.cdap.internal.profile.AdminEventPublisher
 
advanceField() - Method in class co.cask.cdap.internal.io.ReflectionRowReader
 
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.
AGG_GROUPS - Static variable in class co.cask.cdap.etl.common.Constants.Metrics
 
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.
aggregate(GROUP_KEY, Iterator<GROUP_VALUE>, Emitter<OUT>) - Method in class co.cask.cdap.etl.common.plugin.WrappedBatchAggregator
 
aggregate(Object, Iterator<StructuredRecord>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator
 
aggregate(String, Iterator<StructuredRecord>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.GroupFilterAggregator
 
aggregate(StructuredRecord, Iterator<StructuredRecord>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator
 
aggregate(StageSpec, Integer, StageStatisticsCollector) - Method in class co.cask.cdap.etl.spark.batch.RDDCollection
 
aggregate(StageSpec, Integer, StageStatisticsCollector) - Method in interface co.cask.cdap.etl.spark.SparkCollection
 
aggregate(StageSpec, Integer, StageStatisticsCollector) - Method in class co.cask.cdap.etl.spark.streaming.DStreamCollection
 
AggregatedMetricsCollectionService - Class in co.cask.cdap.metrics.collect
Base class for MetricsCollectionService which collect metrics through a set of cached AggregatedMetricsEmitter.
AggregatedMetricsCollectionService() - Constructor for class co.cask.cdap.metrics.collect.AggregatedMetricsCollectionService
 
aggregateMetricValue(MetricTimeSeries) - Method in class co.cask.cdap.operations.cdap.AbstractCDAPStats
 
Aggregation - Interface in co.cask.cdap.data2.dataset2.lib.cube
Defines an aggregation in DefaultCube.
AggregationAlias - Class in co.cask.cdap.data2.dataset2.lib.cube
Class to encapsulate dimension name aliases
AggregationAlias(Map<String, String>) - Constructor for class co.cask.cdap.data2.dataset2.lib.cube.AggregationAlias
 
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.
AggregatorAggregateFunction<GROUP_KEY,GROUP_VAL,OUT> - Class in co.cask.cdap.etl.spark.function
Function that uses a BatchAggregator to perform the aggregate part of the aggregator.
AggregatorAggregateFunction(PluginFunctionContext) - Constructor for class co.cask.cdap.etl.spark.function.AggregatorAggregateFunction
 
AggregatorContextProvider - Class in co.cask.cdap.etl.common.submit
Creates DefaultAggregatorContexts.
AggregatorContextProvider(PipelineRuntime, StageSpec, Admin) - Constructor for class co.cask.cdap.etl.common.submit.AggregatorContextProvider
 
AggregatorGroupByFunction<GROUP_KEY,GROUP_VAL> - Class in co.cask.cdap.etl.spark.function
Function that uses a BatchAggregator to perform the groupBy part of the aggregator.
AggregatorGroupByFunction(PluginFunctionContext) - Constructor for class co.cask.cdap.etl.spark.function.AggregatorGroupByFunction
 
Alert - Class in co.cask.cdap.etl.api
An alert emitted by a stage in the pipeline.
Alert(String, Map<String, String>) - Constructor for class co.cask.cdap.etl.api.Alert
 
alertConsumers - Variable in class co.cask.cdap.etl.batch.PipeEmitter.Builder
 
AlertEmitter - Interface in co.cask.cdap.etl.api
Emits alerts.
AlertPassFilter - Class in co.cask.cdap.etl.spark.function
Filters a SparkCollection containing both output and errors to one that just contains alerts.
AlertPassFilter() - Constructor for class co.cask.cdap.etl.spark.function.AlertPassFilter
 
AlertPublisher - Class in co.cask.cdap.etl.api
A pipeline stage that can publish any alerts emitted by the previous stage.
AlertPublisher() - Constructor for class co.cask.cdap.etl.api.AlertPublisher
 
AlertPublisherContext - Interface in co.cask.cdap.etl.api
Context for an AlertPublisher, exposing methods to publish messages to TMS.
AlertPublisherSink - Class in co.cask.cdap.etl.batch.connector
Internal batch sink used as a connector between a mapreduce job and the workflow client that actually publishes the alerts.
AlertPublisherSink(String, String) - Constructor for class co.cask.cdap.etl.batch.connector.AlertPublisherSink
 
AlertReader - Class in co.cask.cdap.etl.batch.connector
Read alerts written by an AlertPublisherSink.
AlertReader(FileSet) - Constructor for class co.cask.cdap.etl.batch.connector.AlertReader
 
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.
alive() - Method in interface co.cask.cdap.app.runtime.ProgramController.Listener
 
alive() - Method in class co.cask.cdap.internal.app.program.StateChangeListener
 
alive() - Method in class co.cask.cdap.internal.app.runtime.AbstractListener
 
ALL - Static variable in class co.cask.cdap.api.data.format.Formats
 
all(LogSampler...) - Static method in class co.cask.cdap.common.logging.LogSamplers
Returns a LogSampler that will accept a log event if all of the provided LogSamplers accepted the log event.
ALL_PROGRAMS - Static variable in class co.cask.cdap.client.app.FakeApp
 
AllCollector<Element> - Class in co.cask.cdap.common.collect
This collector will collect until it runs out of memory, it never returns false.
AllCollector() - Constructor for class co.cask.cdap.common.collect.AllCollector
 
AllErrorTransform - Class in co.cask.cdap.etl.mock.transform
Transform used to test error emission.
AllErrorTransform() - Constructor for class co.cask.cdap.etl.mock.transform.AllErrorTransform
 
allKeys - Variable in class co.cask.cdap.security.auth.MapBackedKeyManager
 
ALLOW_ALL - Static variable in class co.cask.cdap.security.spi.authorization.AbstractAuthorizer
 
AllPairCollector<KEY,VALUE> - Class in co.cask.cdap.common.collect
This collector will collect every entry.
AllPairCollector() - Constructor for class co.cask.cdap.common.collect.AllPairCollector
 
allProceduresAreCallable() - Method in class co.cask.cdap.explore.jdbc.ExploreDatabaseMetaData
 
allSystemServicesOk() - Method in class co.cask.cdap.client.MonitorClient
 
allTablesAreSelectable() - Method in class co.cask.cdap.explore.jdbc.ExploreDatabaseMetaData
 
AlreadyExistsException - Exception in co.cask.cdap.common
Thrown when an element already exists.
AlreadyExistsException(String) - Constructor for exception co.cask.cdap.common.AlreadyExistsException
 
AlreadyExistsException(EntityId) - Constructor for exception co.cask.cdap.common.AlreadyExistsException
 
AlreadyExistsException(EntityId, String) - Constructor for exception co.cask.cdap.common.AlreadyExistsException
 
AlreadyExistsException - Exception in co.cask.cdap.security.spi.authorization
Exception thrown when a Role or an entity already exists
AlreadyExistsException(Role) - Constructor for exception co.cask.cdap.security.spi.authorization.AlreadyExistsException
 
AlreadyExistsException(String) - Constructor for exception co.cask.cdap.security.spi.authorization.AlreadyExistsException
 
also() - Method in interface co.cask.cdap.api.workflow.WorkflowForkConfigurer
Adds a branch to the WorkflowForkNode
also() - Method in class co.cask.cdap.datapipeline.ConditionToConditionAdder
 
also() - Method in class co.cask.cdap.datapipeline.ConditionToForkAdder
 
also() - Method in class co.cask.cdap.datapipeline.ConditionToTrunkAdder
 
also() - Method in class co.cask.cdap.datapipeline.ForkToConditionAdder
 
also() - Method in class co.cask.cdap.datapipeline.ForkToForkAdder
 
also() - Method in class co.cask.cdap.datapipeline.ForkToTrunkAdder
 
also() - Method in class co.cask.cdap.datapipeline.TrunkProgramAdder
 
also() - Method in interface co.cask.cdap.datapipeline.WorkflowProgramAdder
 
also() - Method in class co.cask.cdap.internal.app.workflow.DefaultWorkflowForkConfigurer
 
AlterPartitionStatementBuilder - Class in co.cask.cdap.explore.table
Builds alter table partition statements for Hive.
AlterPartitionStatementBuilder(String, String, PartitionKey, boolean) - Constructor for class co.cask.cdap.explore.table.AlterPartitionStatementBuilder
 
AlterStatementBuilder - Class in co.cask.cdap.explore.table
Builds alter table statements for Hive.
AlterStatementBuilder(String, String, String, boolean) - Constructor for class co.cask.cdap.explore.table.AlterStatementBuilder
 
AltStyleTableRenderer - Class in co.cask.cdap.cli.util.table
TableRenderer implementation to print an ASCII table in the alt style.
AltStyleTableRenderer() - Constructor for class co.cask.cdap.cli.util.table.AltStyleTableRenderer
 
AltStyleTableRenderer(int, String) - Constructor for class co.cask.cdap.cli.util.table.AltStyleTableRenderer
 
ALWAYS_ACCEPT - Static variable in class co.cask.cdap.data.file.ReadFilter
Always accept what it sees.
ALWAYS_MATCH - Static variable in class co.cask.cdap.api.dataset.lib.PartitionFilter
 
ALWAYS_REJECT_OFFSET - Static variable in class co.cask.cdap.data.file.ReadFilter
Always reject offset.
ALWAYS_TRUE - Static variable in class co.cask.cdap.common.service.Retries
 
alwaysAccept() - Static method in class co.cask.cdap.messaging.store.MessageFilter
Creates a MessageFilter that always accept.
and(Trigger...) - Method in interface co.cask.cdap.api.schedule.TriggerFactory
Creates a trigger which is satisfied when all of the given triggers are satisfied.
and(ReadFilter...) - Static method in class co.cask.cdap.data.file.ReadFilters
 
and(Trigger...) - Method in class co.cask.cdap.internal.app.runtime.schedule.trigger.DefaultTriggerFactory
 
and(ProtoTrigger...) - Static method in class co.cask.cdap.proto.ProtoTrigger
Shorthand helper method to create an instance of ProtoTrigger.AndTrigger
AndFilter - Class in co.cask.cdap.logging.filter
Represents an And Filter where all sub expressions are and-ed together.
AndFilter(List<? extends Filter>) - Constructor for class co.cask.cdap.logging.filter.AndFilter
 
AndReadFilter - Class in co.cask.cdap.data.file.filter
AND multiple @{link ReadFilter}s.
AndReadFilter(ReadFilter...) - Constructor for class co.cask.cdap.data.file.filter.AndReadFilter
 
AndTrigger - Class in co.cask.cdap.internal.app.runtime.schedule.trigger
A Trigger that schedules a ProgramSchedule, when all internal triggers are satisfied.
AndTrigger(SatisfiableTrigger...) - Constructor for class co.cask.cdap.internal.app.runtime.schedule.trigger.AndTrigger
 
AndTrigger(List<SatisfiableTrigger>) - Constructor for class co.cask.cdap.internal.app.runtime.schedule.trigger.AndTrigger
 
AndTrigger(List<ProtoTrigger>) - Constructor for class co.cask.cdap.proto.ProtoTrigger.AndTrigger
 
AndTriggerBuilder - Class in co.cask.cdap.internal.app.runtime.schedule.trigger
A Trigger builder that builds a AndTrigger.
AndTriggerBuilder(Trigger...) - Constructor for class co.cask.cdap.internal.app.runtime.schedule.trigger.AndTriggerBuilder
 
ANNOUNCE_PORT - Static variable in class co.cask.cdap.common.conf.Constants.Dataset.Manager
 
ANOTHER_FAKE_NAME - Static variable in class co.cask.cdap.client.app.FakeWorkflow.FakeAction
 
any(LogSampler...) - Static method in class co.cask.cdap.common.logging.LogSamplers
Returns a LogSampler that will accept a log event if any of the provided LogSamplers accepted the log event.
ANY_INPUT - Static variable in class co.cask.cdap.api.flow.FlowletDefinition
Deprecated.
 
ApacheAccessLog - Class in co.cask.cdap.examples.loganalysis
This class represents an Apache access log line.
API_KEY - Static variable in class co.cask.cdap.common.conf.Constants.Gateway
 
API_VERSION_3 - Static variable in class co.cask.cdap.common.conf.Constants.Gateway
 
API_VERSION_3_TOKEN - Static variable in class co.cask.cdap.common.conf.Constants.Gateway
v3 API.
APP - Static variable in class co.cask.cdap.common.conf.Constants.Metrics.Tag
 
app(String) - Method in class co.cask.cdap.proto.id.NamespaceId
 
app(String, String) - Method in class co.cask.cdap.proto.id.NamespaceId
 
APP_CONFIG_HEADER - Static variable in class co.cask.cdap.gateway.handlers.util.AbstractAppFabricHttpHandler
 
APP_FABRIC_HTTP - Static variable in class co.cask.cdap.common.conf.Constants.Service
 
APP_FABRIC_HTTP - Static variable in class co.cask.cdap.gateway.router.RouterPathLookup
 
APP_META_INSTANCE_ID - Static variable in class co.cask.cdap.internal.app.store.AppMetadataStore
 
APP_META_UPGRADE_TIMEOUT_SECS - Static variable in class co.cask.cdap.common.conf.Constants
 
APP_NAME - Static variable in class co.cask.cdap.examples.purchase.PurchaseApp
 
APP_PRINCIPAL_EXISTS - Static variable in class co.cask.cdap.internal.app.runtime.ProgramOptionConstants
 
APP_SCHEDULER_QUEUE - Static variable in class co.cask.cdap.common.conf.Constants.AppFabric
 
APP_SPEC_FILE - Static variable in class co.cask.cdap.internal.app.runtime.ProgramOptionConstants
 
APP_STRING - Static variable in class co.cask.cdap.metrics.query.MetricsQueryHelper
 
APP_UPDATE_SCHEDULES - Static variable in class co.cask.cdap.common.conf.Constants.AppFabric
 
AppConfig() - Constructor for class co.cask.cdap.client.app.FakeApp.AppConfig
 
AppConfig(boolean, String, String) - Constructor for class co.cask.cdap.client.app.FakeApp.AppConfig
 
AppCreator - Class in co.cask.cdap.internal.bootstrap.executor
Creates an application if it doesn't already exist.
AppDeploymentInfo - Class in co.cask.cdap.internal.app.deploy.pipeline
Information required by application deployment pipeline LocalApplicationManager.
AppDeploymentInfo(ArtifactDescriptor, NamespaceId, String, String, String, String) - Constructor for class co.cask.cdap.internal.app.deploy.pipeline.AppDeploymentInfo
 
AppDeploymentInfo(ArtifactDescriptor, NamespaceId, String, String, String, String, KerberosPrincipalId, boolean) - Constructor for class co.cask.cdap.internal.app.deploy.pipeline.AppDeploymentInfo
 
append(String, String) - Method in class co.cask.cdap.api.metadata.MetadataEntity.Builder
Put the given key (case insensitive) with the given value in MetadataEntity.Builder.
append(T) - Method in interface co.cask.cdap.data.file.FileWriter
Appends an event to the file.
append(T) - Method in class co.cask.cdap.data.file.PartitionedFileWriter
 
append(ByteBuf) - Method in class co.cask.cdap.data.stream.service.upload.AsyncChannelBufferInputStream
Appends more content to be consumable through this stream.
append(ByteBuffer, boolean) - Method in interface co.cask.cdap.data.stream.service.upload.ContentWriter
 
append(StreamEvent) - Method in class co.cask.cdap.data.stream.StreamDataFileWriter
 
append(MDSKey) - Method in class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
append(ILoggingEvent) - Method in class co.cask.cdap.etl.log.LogStageAppender
 
append(ILoggingEvent) - Method in class co.cask.cdap.logging.appender.LogAppender
 
append(ILoggingEvent) - Method in class co.cask.cdap.logging.appender.system.CDAPLogAppender
 
append(ILoggingEvent) - Method in class co.cask.cdap.logging.appender.system.MetricsLogAppender
 
append(ProgramRunInfo) - Method in class co.cask.cdap.report.main.RunMetaFileManager
append ProgramRunInfo and flush to file.
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.sftp.SFTPFileSystem
 
appendAll(Iterator<? extends T>) - Method in interface co.cask.cdap.data.file.FileWriter
Appends multiple events to the file.
appendAll(Iterator<? extends T>) - Method in class co.cask.cdap.data.file.PartitionedFileWriter
 
appendAll(Iterator<ByteBuffer>, boolean) - Method in interface co.cask.cdap.data.stream.service.upload.ContentWriter
 
appendAll(Iterator<? extends StreamEvent>) - Method in class co.cask.cdap.data.stream.StreamDataFileWriter
Writes multiple events to the stream file.
appendAsType(String, String) - Method in class co.cask.cdap.api.metadata.MetadataEntity.Builder
Put the given key (case insensitive) with the given value in MetadataEntity.Builder.
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
 
appendEvent(LogMessage) - Method in class co.cask.cdap.logging.appender.kafka.KafkaLogAppender
 
appendEvent(LogMessage) - Method in class co.cask.cdap.logging.appender.LogAppender
 
appendEvent(LogMessage) - Method in class co.cask.cdap.logging.appender.tms.TMSLogAppender
 
appendEvent(LogMessage) - Method in class co.cask.cdap.logging.framework.local.LocalLogAppender
 
appendEvent(ILoggingEvent) - Method in class co.cask.cdap.logging.framework.local.LocalLogAppender
 
appendFile(StreamId, Location, Location, long, TimestampCloseable) - Method in class co.cask.cdap.data.stream.service.ConcurrentStreamWriter
Appends a new stream file to the given stream.
appendRequestBody(String) - Method in class co.cask.cdap.common.logging.AuditLogEntry
 
appendResponseBody(String) - Method in class co.cask.cdap.common.logging.AuditLogEntry
 
AppFabric() - Constructor for class co.cask.cdap.common.conf.Constants.AppFabric
 
AppFabricDatasetModule - Class in co.cask.cdap.internal.app
The DatasetModule for adding dataset definitions defined in app-fabric.
AppFabricDatasetModule() - Constructor for class co.cask.cdap.internal.app.AppFabricDatasetModule
 
AppFabricServer - Class in co.cask.cdap.internal.app.services
AppFabric Server.
AppFabricServer(CConfiguration, SConfiguration, DiscoveryService, NotificationService, InetAddress, Set<HttpHandler>, MetricsCollectionService, ProgramRuntimeService, RunRecordCorrectorService, ApplicationLifecycleService, ProgramNotificationSubscriberService, StreamCoordinatorClient, Set<String>, Set<String>, PluginService, RouteStore, CoreSchedulerService, ProvisioningService, BootstrapService, RunCountUpgradeService) - Constructor for class co.cask.cdap.internal.app.services.AppFabricServer
Construct the AppFabricServer with service factory and cConf coming from guice injection.
AppFabricServiceManager - Class in co.cask.cdap.internal.app.runtime.distributed
App Fabric Service Management in Distributed Mode.
AppFabricServiceManager(InetAddress) - Constructor for class co.cask.cdap.internal.app.runtime.distributed.AppFabricServiceManager
 
AppFabricServiceRuntimeModule - Class in co.cask.cdap.app.guice
AppFabric Service Runtime Module.
AppFabricServiceRuntimeModule() - Constructor for class co.cask.cdap.app.guice.AppFabricServiceRuntimeModule
 
appId - Variable in class co.cask.cdap.cli.command.app.BaseBatchCommand.Args
 
appId - Variable in class co.cask.cdap.proto.BatchProgram
 
AppIdCompleter - Class in co.cask.cdap.cli.completer.element
Completer for application IDs.
AppIdCompleter(ApplicationClient, CLIConfig) - Constructor for class co.cask.cdap.cli.completer.element.AppIdCompleter
 
Application<T extends Config> - Interface in co.cask.cdap.api.app
Defines a CDAP Application.
APPLICATION - Static variable in class co.cask.cdap.api.metadata.MetadataEntity
 
Application(Id.Namespace, String) - Constructor for class co.cask.cdap.common.id.Id.Application
 
application - Variable in class co.cask.cdap.test.AbstractApplicationManager
 
APPLICATION_ID - Static variable in class co.cask.cdap.app.program.ManifestFields
 
APPLICATION_NAME - Static variable in class co.cask.cdap.report.util.Constants
 
APPLICATION_VERSION - Static variable in class co.cask.cdap.report.util.Constants
 
ApplicationClass - Class in co.cask.cdap.api.artifact
Contains information about an Application class.
ApplicationClass(String, String, Schema) - Constructor for class co.cask.cdap.api.artifact.ApplicationClass
 
ApplicationClassInfo - Class in co.cask.cdap.proto.artifact
Represents the objects returned by /classes/app/{classname}
ApplicationClassInfo(ArtifactSummary, String, Schema) - Constructor for class co.cask.cdap.proto.artifact.ApplicationClassInfo
 
ApplicationClassSummary - Class in co.cask.cdap.proto.artifact
Represents the objects returned by /classes/app
ApplicationClassSummary(ArtifactSummary, String) - Constructor for class co.cask.cdap.proto.artifact.ApplicationClassSummary
 
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
 
applicationClient() - Method in class co.cask.cdap.docgen.client.GenerateClientUsageExample
 
ApplicationCommands - Class in co.cask.cdap.cli.commandset
Application commands.
ApplicationCommands(Injector) - Constructor for class co.cask.cdap.cli.commandset.ApplicationCommands
 
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.
ApplicationDeployable - Class in co.cask.cdap.internal.app.deploy.pipeline
Represents information of an application that is undergoing deployment.
ApplicationDeployable(ArtifactId, Location, ApplicationId, ApplicationSpecification, ApplicationSpecification, ApplicationDeployScope) - Constructor for class co.cask.cdap.internal.app.deploy.pipeline.ApplicationDeployable
 
ApplicationDeployable(ArtifactId, Location, ApplicationId, ApplicationSpecification, ApplicationSpecification, ApplicationDeployScope, KerberosPrincipalId, boolean) - Constructor for class co.cask.cdap.internal.app.deploy.pipeline.ApplicationDeployable
 
ApplicationDeployScope - Enum in co.cask.cdap.internal.app.deploy.pipeline
Represents the scope of an application undergoing deployment.
ApplicationDetail - Class in co.cask.cdap.proto
Represents an application returned for /apps/{app-id}.
ApplicationDetail(String, String, String, List<StreamDetail>, List<DatasetDetail>, List<ProgramRecord>, List<PluginDetail>, ArtifactSummary) - Constructor for class co.cask.cdap.proto.ApplicationDetail
 
ApplicationDetail(String, String, String, List<StreamDetail>, List<DatasetDetail>, List<ProgramRecord>, List<PluginDetail>, ArtifactSummary, String) - Constructor for class co.cask.cdap.proto.ApplicationDetail
 
ApplicationDetail(String, String, String, String, List<StreamDetail>, List<DatasetDetail>, List<ProgramRecord>, List<PluginDetail>, ArtifactSummary, String) - Constructor for class co.cask.cdap.proto.ApplicationDetail
 
ApplicationExistenceVerifier - Class in co.cask.cdap.internal.app.runtime
applicationExists(ApplicationId) - Method in interface co.cask.cdap.app.store.Store
Check if an application exists.
applicationExists(ApplicationId) - Method in class co.cask.cdap.internal.app.store.DefaultStore
 
ApplicationId - Class in co.cask.cdap.proto.id
Uniquely identifies an application.
ApplicationId(String, String) - Constructor for class co.cask.cdap.proto.id.ApplicationId
 
ApplicationId(String, String, String) - Constructor for class co.cask.cdap.proto.id.ApplicationId
 
ApplicationLifecycleService - Class in co.cask.cdap.internal.app.services
Service that manage lifecycle of Applications.
ApplicationLoggingContext - Class in co.cask.cdap.common.logging
Application logging context.
ApplicationLoggingContext(String, String, String) - Constructor for class co.cask.cdap.common.logging.ApplicationLoggingContext
Constructs ApplicationLoggingContext.
ApplicationManager - Interface in co.cask.cdap.test
Instance of this class is for managing deployed application.
ApplicationManagerFactory - Interface in co.cask.cdap.test.internal
 
ApplicationMeta - Class in co.cask.cdap.internal.app.store
Holds application metadata
ApplicationMeta(String, ApplicationSpecification) - Constructor for class co.cask.cdap.internal.app.store.ApplicationMeta
 
ApplicationNameVersion(String, String) - Constructor for class co.cask.cdap.proto.ops.DashboardProgramRunRecord.ApplicationNameVersion
 
ApplicationNotFoundException - Exception in co.cask.cdap.common
Thrown when an application is not found.
ApplicationNotFoundException(ApplicationId) - Constructor for exception co.cask.cdap.common.ApplicationNotFoundException
 
ApplicationRecord - Class in co.cask.cdap.proto
Represents item in the list from /apps
ApplicationRecord(ArtifactSummary, ApplicationId, String) - Constructor for class co.cask.cdap.proto.ApplicationRecord
 
ApplicationRecord(ArtifactSummary, ApplicationId, String, String) - Constructor for class co.cask.cdap.proto.ApplicationRecord
 
ApplicationRegistrationStage - Class in co.cask.cdap.internal.app.deploy.pipeline
 
ApplicationRegistrationStage(Store, UsageRegistry, OwnerAdmin) - Constructor for class co.cask.cdap.internal.app.deploy.pipeline.ApplicationRegistrationStage
 
ApplicationSecurity - Class in co.cask.cdap.security
This class is a extention of the existing java SecurityManager to allow managing the permission of containers of application started by app-fabric.
ApplicationSecurity.Builder - Class in co.cask.cdap.security
Builder for constructing the permissions collection.
ApplicationSpecification - Interface in co.cask.cdap.api.app
Application Specification used in core code.
ApplicationSpecificationAdapter - Class in co.cask.cdap.internal.app
Helper class to encoded/decode ApplicationSpecification to/from json.
ApplicationVerification - Class in co.cask.cdap.internal.app.verification
This class is responsible for verifying the Application details of the ApplicationSpecification.
ApplicationVerification() - Constructor for class co.cask.cdap.internal.app.verification.ApplicationVerification
 
ApplicationVerificationStage - Class in co.cask.cdap.internal.app.deploy.pipeline
This Stage is responsible for verifying the specification and components of specification.
ApplicationVerificationStage(Store, DatasetFramework, OwnerAdmin, AuthenticationContext) - Constructor for class co.cask.cdap.internal.app.deploy.pipeline.ApplicationVerificationStage
 
ApplicationWithPrograms - Class in co.cask.cdap.internal.app.deploy.pipeline
Represents information of an application and all programs inside it that is undergoing deployment.
ApplicationWithPrograms(ApplicationDeployable, Iterable<? extends ProgramDescriptor>) - Constructor for class co.cask.cdap.internal.app.deploy.pipeline.ApplicationWithPrograms
 
AppLifecycleHttpHandler - Class in co.cask.cdap.gateway.handlers
HttpHandler for managing application lifecycle.
apply(T) - Method in interface co.cask.cdap.api.Predicate
Returns the result of applying this predicate to input.
apply(T) - Method in interface co.cask.cdap.common.conf.PropertyUpdater
Computes the updated copy of property asynchronously.
apply(T) - Method in class co.cask.cdap.common.conf.SyncPropertyUpdater
 
apply(F) - Method in interface co.cask.cdap.common.lang.FunctionWithException
 
apply(ResourceRequirement) - Method in interface co.cask.cdap.common.zookeeper.coordination.ResourceModifier
Called to produce a new ResourceRequirement.
apply(ConditionContext) - Method in class co.cask.cdap.etl.api.condition.Condition
Returns the result of execution of the condition.
apply(WorkflowContext) - Method in class co.cask.cdap.etl.batch.condition.PipelineCondition
 
apply(ConditionContext) - Method in class co.cask.cdap.etl.mock.condition.MockCondition
 
apply(T) - Method in class co.cask.cdap.messaging.store.MessageFilter
 
apply(MessageTable.Entry) - Method in class co.cask.cdap.messaging.store.TransactionMessageFilter
 
apply(T) - Method in class co.cask.cdap.report.proto.Filter
Checks whether the given value of the field is allowed to be included in the report.
apply(T) - Method in class co.cask.cdap.report.proto.RangeFilter
 
apply(T) - Method in class co.cask.cdap.report.proto.ValueFilter
 
apply() - Method in class co.cask.cdap.security.ApplicationSecurity.Builder
Applies the permission.
AppMetadataStore - Class in co.cask.cdap.internal.app.store
Store for application metadata.
AppMetadataStore(Table, CConfiguration) - Constructor for class co.cask.cdap.internal.app.store.AppMetadataStore
 
AppMetadataStore - Class in co.cask.cdap.logging.gateway.handlers.store
Duplicate store class for application meatadata.
AppMetadataStore(Table) - Constructor for class co.cask.cdap.logging.gateway.handlers.store.AppMetadataStore
 
AppMetaStore() - Constructor for class co.cask.cdap.common.conf.Constants.AppMetaStore
 
AppRequest<T> - Class in co.cask.cdap.proto.artifact
Request body when creating or updating an app.
AppRequest(ArtifactSummary) - Constructor for class co.cask.cdap.proto.artifact.AppRequest
 
AppRequest(ArtifactSummary, T) - Constructor for class co.cask.cdap.proto.artifact.AppRequest
 
AppRequest(ArtifactSummary, T, PreviewConfig) - Constructor for class co.cask.cdap.proto.artifact.AppRequest
 
AppRequest(ArtifactSummary, T, String) - Constructor for class co.cask.cdap.proto.artifact.AppRequest
 
AppRequest(ArtifactSummary, T, PreviewConfig, String, Boolean) - Constructor for class co.cask.cdap.proto.artifact.AppRequest
 
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
 
AppSystemMetadataWriter - Class in co.cask.cdap.data2.metadata.system
A AbstractSystemMetadataWriter for an application.
AppSystemMetadataWriter(MetadataStore, ApplicationId, ApplicationSpecification) - Constructor for class co.cask.cdap.data2.metadata.system.AppSystemMetadataWriter
 
AppSystemMetadataWriter(MetadataStore, ApplicationId, ApplicationSpecification, boolean) - Constructor for class co.cask.cdap.data2.metadata.system.AppSystemMetadataWriter
 
ARCHIVE - Static variable in class co.cask.cdap.common.conf.Constants.Plugin
 
ARCHIVE_DIR - Static variable in class co.cask.cdap.common.conf.Constants
 
ARCHIVE_NAME_HEADER - Static variable in class co.cask.cdap.gateway.handlers.util.AbstractAppFabricHttpHandler
Name of the header that should specify the application archive
ARG_APPFABRIC_STANDALONE_DEPLOY_COMMAND - Static variable in class co.cask.cdap.StartStandaloneAndDeployApplicationHelper
 
Args(ApplicationId, Set<ProgramType>, List<T>) - Constructor for class co.cask.cdap.cli.command.app.BaseBatchCommand.Args
 
ArgService() - Constructor for class co.cask.cdap.client.app.AppReturnsArgs.ArgService
 
ArgumentMapping - Class in co.cask.cdap.etl.proto.v2
The mapping between a triggering pipeline argument to a triggered pipeline argument.
ArgumentMapping(String, String) - Constructor for class co.cask.cdap.etl.proto.v2.ArgumentMapping
 
ArgumentName - Enum in co.cask.cdap.cli
Argument names.
ArgumentParser - Class in co.cask.cdap.cli.util
Utility class for parsing arguments from user input based on command pattern.
ArgumentParser() - Constructor for class co.cask.cdap.cli.util.ArgumentParser
 
Arguments - Interface in co.cask.cdap.app.runtime
 
Arguments - Interface in co.cask.cdap.etl.api
Provides access to the pipeline arguments at runtime.
arguments - Variable in class co.cask.cdap.etl.common.AbstractStageContext
 
ArgumentsCodec - Class in co.cask.cdap.internal.app.runtime.codec
A Gson codec for Arguments.
ArgumentsCodec() - Constructor for class co.cask.cdap.internal.app.runtime.codec.ArgumentsCodec
 
arrayOf(Schema) - Static method in class co.cask.cdap.api.data.schema.Schema
Creates an ARRAY Schema of the given component type.
arrayToString(String[]) - Static method in class co.cask.cdap.common.conf.StringUtils
Given an array of strings, return a comma-separated list of its elements.
Article - Class in co.cask.cdap.cli.english
English article.
Article() - Constructor for class co.cask.cdap.cli.english.Article
 
ARTIFACT - Static variable in class co.cask.cdap.api.metadata.MetadataEntity
 
Artifact(Id.Namespace, String, ArtifactVersion) - Constructor for class co.cask.cdap.common.id.Id.Artifact
 
artifact - Variable in class co.cask.cdap.proto.artifact.PluginSummary
 
artifact(String, String) - Method in class co.cask.cdap.proto.id.NamespaceId
 
ARTIFACT_CLASSLOADER_KEY - Static variable in class co.cask.cdap.internal.app.deploy.LocalApplicationManager
The key used in the Stage Context property for storing the artifact classloader of the artifact used during deployment.
ARTIFACT_ID - Static variable in class co.cask.cdap.internal.app.runtime.ProgramOptionConstants
Option for the program artifact id.
ARTIFACT_ID - Static variable in class co.cask.cdap.report.util.Constants
 
ARTIFACT_ID - Static variable in class co.cask.cdap.report.util.Constants.Notification
 
ARTIFACT_INFO_SCHEMA - Static variable in class co.cask.cdap.report.main.ProgramRunInfoSerializer
 
ARTIFACT_NAME - Static variable in class co.cask.cdap.report.util.Constants
 
ARTIFACT_NAMES - Static variable in class co.cask.cdap.etl.tool.config.Upgrader
 
ARTIFACT_SCOPE - Static variable in class co.cask.cdap.report.util.Constants
 
ARTIFACT_VERSION - Static variable in class co.cask.cdap.report.util.Constants
 
ArtifactAggregate - Class in co.cask.cdap.report.proto.summary
Represents an aggregate of program runs by the parent artifact.
ArtifactAggregate(String, String, String, long) - Constructor for class co.cask.cdap.report.proto.summary.ArtifactAggregate
 
ArtifactAlreadyExistsException - Exception in co.cask.cdap.common
Thrown when an artifact already exists.
ArtifactAlreadyExistsException(ArtifactId) - Constructor for exception co.cask.cdap.common.ArtifactAlreadyExistsException
 
ArtifactAlreadyExistsException(String) - Constructor for exception co.cask.cdap.common.ArtifactAlreadyExistsException
 
ArtifactClasses - Class in co.cask.cdap.api.artifact
Classes contained in an artifact, such as plugin classes and application classes.
ArtifactClasses.Builder - Class in co.cask.cdap.api.artifact
Builder to more easily add application and plugin classes, and in the future, program and dataset classes.
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
 
ArtifactCommands - Class in co.cask.cdap.cli.commandset
Artifact commands.
ArtifactCommands(Injector) - Constructor for class co.cask.cdap.cli.commandset.ArtifactCommands
 
ArtifactConfig - Class in co.cask.cdap.common.conf
Represents metadata about an artifact that can be specified by users.
ArtifactConfig() - Constructor for class co.cask.cdap.common.conf.ArtifactConfig
 
ArtifactConfig(Set<ArtifactRange>, Set<PluginClass>, Map<String, String>) - Constructor for class co.cask.cdap.common.conf.ArtifactConfig
 
ArtifactConfigReader - Class in co.cask.cdap.common.conf
Reads files into ArtifactConfigs for a specific namespace.
ArtifactConfigReader() - Constructor for class co.cask.cdap.common.conf.ArtifactConfigReader
 
ArtifactDescriptor - Class in co.cask.cdap.internal.app.runtime.artifact
Uniquely describes an artifact.
ArtifactDescriptor(ArtifactId, Location) - Constructor for class co.cask.cdap.internal.app.runtime.artifact.ArtifactDescriptor
 
ArtifactDetail - Class in co.cask.cdap.internal.app.runtime.artifact
Details about an artifact, including info about the artifact itself and metadata about the contents of the artifact.
ArtifactDetail(ArtifactDescriptor, ArtifactMeta) - Constructor for class co.cask.cdap.internal.app.runtime.artifact.ArtifactDetail
 
ArtifactExistenceVerifier - Class in co.cask.cdap.internal.app.runtime.artifact
ArtifactHttpHandler - Class in co.cask.cdap.gateway.handlers
HttpHandler for managing artifacts.
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
 
ArtifactId - Class in co.cask.cdap.proto.id
Uniquely identifies an artifact.
ArtifactId(String, String, String) - Constructor for class co.cask.cdap.proto.id.ArtifactId
 
ArtifactId(String, String) - Constructor for class co.cask.cdap.proto.id.ArtifactId
Parses a string expected to be of the form {name}-{version}.jar into an ArtifactId, where name is a valid id and version is of the form expected by ArtifactVersion.
ArtifactInfo - Class in co.cask.cdap.api.artifact
Represents an artifact returned by /artifacts/{artifact-name}/versions/{artifact-version}.
ArtifactInfo(ArtifactId, ArtifactClasses, Map<String, String>) - Constructor for class co.cask.cdap.api.artifact.ArtifactInfo
 
ArtifactInfo(ArtifactId, ArtifactClasses, Map<String, String>, Set<ArtifactRange>) - Constructor for class co.cask.cdap.api.artifact.ArtifactInfo
 
ArtifactInfo(String, String, ArtifactScope, ArtifactClasses, Map<String, String>) - Constructor for class co.cask.cdap.api.artifact.ArtifactInfo
 
ArtifactInfo(String, String, ArtifactScope, ArtifactClasses, Map<String, String>, Set<ArtifactRange>) - Constructor for class co.cask.cdap.api.artifact.ArtifactInfo
 
ArtifactManager - Interface in co.cask.cdap.api.artifact
Provides access to artifacts
ArtifactManager - Interface in co.cask.cdap.test
An interface to manage interactions with an artifact in tests.
ArtifactManagerFactory - Interface in co.cask.cdap.internal.app.runtime.artifact
Factory interface for creating ArtifactManager that binds to a giving namespace.
ArtifactManagerFactory - Interface in co.cask.cdap.test.internal
A Guice factory to create ArtifactManager.
ArtifactMeta - Class in co.cask.cdap.internal.app.runtime.artifact
Metadata about an artifact, such as what plugins are contained in the artifact, and what other artifacts can use the plugins in this artifact.
ArtifactMeta(ArtifactClasses) - Constructor for class co.cask.cdap.internal.app.runtime.artifact.ArtifactMeta
 
ArtifactMeta(ArtifactClasses, Set<ArtifactRange>) - Constructor for class co.cask.cdap.internal.app.runtime.artifact.ArtifactMeta
 
ArtifactMeta(ArtifactClasses, Set<ArtifactRange>, Map<String, String>) - Constructor for class co.cask.cdap.internal.app.runtime.artifact.ArtifactMeta
 
ArtifactNameCompleter - Class in co.cask.cdap.cli.completer.element
Completer for application IDs.
ArtifactNameCompleter(ArtifactClient, CLIConfig) - Constructor for class co.cask.cdap.cli.completer.element.ArtifactNameCompleter
 
ArtifactNotFoundException - Exception in co.cask.cdap.common
Thrown when an artifact does not exist.
ArtifactNotFoundException(String, String) - Constructor for exception co.cask.cdap.common.ArtifactNotFoundException
 
ArtifactNotFoundException(NamespaceId, String) - Constructor for exception co.cask.cdap.common.ArtifactNotFoundException
 
ArtifactNotFoundException(ArtifactId) - Constructor for exception co.cask.cdap.common.ArtifactNotFoundException
 
ArtifactPropertiesRequest - Class in co.cask.cdap.proto.artifact
A request to get properties for an artifact.
ArtifactPropertiesRequest(String, String, ArtifactScope, List<String>) - Constructor for class co.cask.cdap.proto.artifact.ArtifactPropertiesRequest
 
ArtifactRange - Class in co.cask.cdap.api.artifact
Represents a range of versions for an artifact.
ArtifactRange(String, String, ArtifactVersion, ArtifactVersion) - Constructor for class co.cask.cdap.api.artifact.ArtifactRange
 
ArtifactRange(String, String, ArtifactVersion, boolean, ArtifactVersion, boolean) - Constructor for class co.cask.cdap.api.artifact.ArtifactRange
 
ArtifactRange(String, String, ArtifactVersionRange) - Constructor for class co.cask.cdap.api.artifact.ArtifactRange
 
ArtifactRangeCodec - Class in co.cask.cdap.internal.app.runtime.artifact
Gson serialize and deserialize ArtifactRange.
ArtifactRangeCodec() - Constructor for class co.cask.cdap.internal.app.runtime.artifact.ArtifactRangeCodec
 
ArtifactRangeNotFoundException - Exception in co.cask.cdap.common
Thrown when a range of artifacts are not found.
ArtifactRangeNotFoundException(String) - Constructor for exception co.cask.cdap.common.ArtifactRangeNotFoundException
 
ArtifactRangeNotFoundException(Collection<ArtifactRange>) - Constructor for exception co.cask.cdap.common.ArtifactRangeNotFoundException
 
ArtifactRanges - Class in co.cask.cdap.proto.artifact
Utility class for parsing ArtifactRange
ArtifactRepository - Interface in co.cask.cdap.internal.app.runtime.artifact
This class manages artifact and artifact metadata.
Artifacts - Class in co.cask.cdap.internal.app.runtime.artifact
Util class that contains helper methods related to handling of artifacts.
ArtifactScope - Enum in co.cask.cdap.api.artifact
The scope of an artifact.
ArtifactSelector - Class in co.cask.cdap.etl.common
Selects which plugin to use based on optional artifact scope, name, and version fields.
ArtifactSelector(String, String, ArtifactScope, String, ArtifactVersionRange) - Constructor for class co.cask.cdap.etl.common.ArtifactSelector
 
ArtifactSelectorConfig - Class in co.cask.cdap.etl.proto
Part of the etl configuration, used to choose which artifact to use for a plugin.
ArtifactSelectorConfig() - Constructor for class co.cask.cdap.etl.proto.ArtifactSelectorConfig
 
ArtifactSelectorConfig(String, String, String) - Constructor for class co.cask.cdap.etl.proto.ArtifactSelectorConfig
 
ArtifactSelectorProvider - Class in co.cask.cdap.etl.common
ArtifactSelectorProvider(String, String) - Constructor for class co.cask.cdap.etl.common.ArtifactSelectorProvider
 
ArtifactSortOrder - Enum in co.cask.cdap.proto.artifact
Enum class for the sort order info about artifacts.
ArtifactStore - Class in co.cask.cdap.internal.app.runtime.artifact
This class manages artifacts as well as metadata for each artifact.
ArtifactSummary - Class in co.cask.cdap.api.artifact
Represents an artifact returned by /artifacts and /artifacts/{artifact-name}.
ArtifactSummary(String, String) - Constructor for class co.cask.cdap.api.artifact.ArtifactSummary
 
ArtifactSummary(String, String, ArtifactScope) - Constructor for class co.cask.cdap.api.artifact.ArtifactSummary
 
ArtifactSummaryProperties - Class in co.cask.cdap.proto.artifact
An ArtifactSummary with properties.
ArtifactSummaryProperties(String, String, ArtifactScope, Map<String, String>) - Constructor for class co.cask.cdap.proto.artifact.ArtifactSummaryProperties
 
ArtifactSystemMetadataWriter - Class in co.cask.cdap.data2.metadata.system
A AbstractSystemMetadataWriter for an artifact.
ArtifactSystemMetadataWriter(MetadataStore, ArtifactId, ArtifactInfo) - Constructor for class co.cask.cdap.data2.metadata.system.ArtifactSystemMetadataWriter
 
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.
ArtifactVersionRange - Class in co.cask.cdap.api.artifact
Represents a version range of an artifact.
ArtifactVersionRange(ArtifactVersion, boolean, ArtifactVersion, boolean) - Constructor for class co.cask.cdap.api.artifact.ArtifactVersionRange
 
asMap() - Method in class co.cask.cdap.api.dataset.lib.PartitionMetadata
 
asMap() - Method in interface co.cask.cdap.app.runtime.Arguments
Returns an immutable map that represents all arguments.
asMap() - Method in interface co.cask.cdap.etl.api.action.SettableArguments
Returns an unmodifiable map that represents all arguments.
asMap() - Method in class co.cask.cdap.etl.common.BasicArguments
 
asMap() - Method in class co.cask.cdap.etl.mock.common.MockArguments
 
asMap() - Method in class co.cask.cdap.internal.app.runtime.BasicArguments
 
ASMDatumWriterFactory - Class in co.cask.cdap.internal.io
A factory class for creating DatumWriter instance for different data type and schema.
ASMDatumWriterFactory(FieldAccessorFactory) - Constructor for class co.cask.cdap.internal.io.ASMDatumWriterFactory
 
ASMFieldAccessorFactory - Class in co.cask.cdap.internal.io
A FieldAccessorFactory that uses ASM to generate a specific FieldAccessor class for each field.
ASMFieldAccessorFactory() - Constructor for class co.cask.cdap.internal.io.ASMFieldAccessorFactory
 
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
assign(ResourceRequirement, Set<T>, ResourceAssigner<T>) - Method in interface co.cask.cdap.common.zookeeper.coordination.AssignmentStrategy
Assigns handler to PartitionReplica.
assign(ResourceRequirement, Set<T>, ResourceAssigner<T>) - Method in class co.cask.cdap.common.zookeeper.coordination.BalancedAssignmentStrategy
 
AssignmentChangeListener - Interface in co.cask.cdap.common.zookeeper.coordination
Listener to watch for changes in assignments.
AssignmentStrategy - Interface in co.cask.cdap.common.zookeeper.coordination
Strategy for assigning service to resource.
AssociationTable - Class in co.cask.cdap.examples.wordcount
 
AssociationTable(DatasetSpecification, Table) - Constructor for class co.cask.cdap.examples.wordcount.AssociationTable
 
asTransactionFailure(Throwable) - Static method in class co.cask.cdap.data2.transaction.Transactions
Wraps the given Throwable as a TransactionFailureException if it is not already an instance of TransactionFailureException.
asTransactionFailure(Throwable, String) - Static method in class co.cask.cdap.data2.transaction.Transactions
Wraps the given Throwable as a TransactionFailureException if it is not already an instance of TransactionFailureException.
ASYNC_QUEUE_SIZE - Static variable in class co.cask.cdap.common.conf.Constants.Stream
 
ASYNC_WORKER_THREADS - Static variable in class co.cask.cdap.common.conf.Constants.Stream
 
AsyncChannelBufferInputStream - Class in co.cask.cdap.data.stream.service.upload
An InputStream implementation that reads data from ByteBuf.
AsyncChannelBufferInputStream() - Constructor for class co.cask.cdap.data.stream.service.upload.AsyncChannelBufferInputStream
 
asyncEnqueue(StreamId, Map<String, String>, ByteBuf, Executor) - Method in class co.cask.cdap.data.stream.service.ConcurrentStreamWriter
Writes an event to the given stream asynchronously.
asyncEnqueue(FullHttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.data.stream.service.StreamHandler
 
AsyncFunctions - Class in co.cask.cdap.common.async
Static utility methods for operating with AsyncFunction.
asyncSendEvent(StreamId, String) - Method in class co.cask.cdap.client.StreamClient
Sends an event to a stream.
asyncWrap(Function<I, O>, Executor) - Static method in class co.cask.cdap.common.async.AsyncFunctions
Converts a Function into AsyncFunction by performing the operation in the given executor.
asyncWrap(Function<I, O>) - Static method in class co.cask.cdap.common.async.AsyncFunctions
Converts a Function into AsyncFunction by performing the operation in the same thread.
ATLEAST_ONE_CONNECTION - Static variable in class co.cask.cdap.error.Err.Flow
 
ATLEAST_ONE_FLOWLET - Static variable in class co.cask.cdap.error.Err.Flow
 
ATLEAST_ONE_PROCESSOR - Static variable in class co.cask.cdap.error.Err.Application
 
Audit() - Constructor for class co.cask.cdap.common.conf.Constants.Audit
 
AUDIT_LOGGER_NAME - Static variable in class co.cask.cdap.common.conf.Constants.Router
 
AuditDetail - Enum in co.cask.cdap.common.security
Declares which content needs to be audit logged.
AuditLogConfig - Class in co.cask.cdap.common.logging
Audit log content which indicates what additional info is needed for the AuditLogEntry
AuditLogConfig(HttpMethod, boolean, boolean, Iterable<String>) - Constructor for class co.cask.cdap.common.logging.AuditLogConfig
 
AuditLogEntry - Class in co.cask.cdap.common.logging
Represents an entry in an audit log.
AuditLogEntry(HttpRequest, String) - Constructor for class co.cask.cdap.common.logging.AuditLogEntry
 
AuditLogEntry(HttpRequest, String, Set<String>) - Constructor for class co.cask.cdap.common.logging.AuditLogEntry
 
AuditLogEntry(String, String, String, Map<String, String>) - Constructor for class co.cask.cdap.common.logging.AuditLogEntry
 
AuditLogHandler - Class in co.cask.cdap.gateway.router.handlers
A ChannelDuplexHandler that captures HttpRequest and corresponding HttpResponse over the forwarding connections from router to CDAP services (via the client bootstrap) for audit log purpose.
AuditLogHandler() - Constructor for class co.cask.cdap.gateway.router.handlers.AuditLogHandler
 
AuditLogHandler - Class in co.cask.cdap.security.server
Handler for audit logging for the ExternalAuthenticationServer.
AuditLogHandler(Logger) - Constructor for class co.cask.cdap.security.server.AuditLogHandler
 
AuditMessage - Class in co.cask.cdap.proto.audit
Represents a change on an entity that needs to be audited.
AuditMessage(long, EntityId, String, AuditType, AuditPayload) - Constructor for class co.cask.cdap.proto.audit.AuditMessage
 
AuditMessage(long, MetadataEntity, String, AuditType, AuditPayload) - Constructor for class co.cask.cdap.proto.audit.AuditMessage
 
AuditMessageTypeAdapter - Class in co.cask.cdap.proto.codec
Code for AuditMessage.
AuditMessageTypeAdapter() - Constructor for class co.cask.cdap.proto.codec.AuditMessageTypeAdapter
 
AuditModule - Class in co.cask.cdap.data2.audit
Guice bindings for publishing audit.
AuditModule() - Constructor for class co.cask.cdap.data2.audit.AuditModule
 
AuditPayload - Class in co.cask.cdap.proto.audit
Paylod of AuditMessage based on AuditType.
AuditPayload() - Constructor for class co.cask.cdap.proto.audit.AuditPayload
 
AuditPolicy - Annotation Type in co.cask.cdap.common.security
Annotates a REST endpoint method to indicate which content needs to be audit logged.
AuditPublisher - Interface in co.cask.cdap.data2.audit
AuditPublisher is used to publish non-data changes to entities that need to be logged for audit purpose.
AuditPublishers - Class in co.cask.cdap.data2.audit
Helper class to publish audit.
AuditType - Enum in co.cask.cdap.proto.audit
Types of AuditMessages.
AUTH_HANDLER_CLASS - Static variable in class co.cask.cdap.common.conf.Constants.Security
Authentication Handler class name
AUTH_HANDLER_CONFIG_BASE - Static variable in class co.cask.cdap.common.conf.Constants.Security
Prefix for all configurable properties of an Authentication handler.
AUTH_KEY_UPDATE_INTERVAL - Static variable in class co.cask.cdap.common.conf.Constants.HBase
 
AUTH_SERVER_ANNOUNCE_URLS - Static variable in class co.cask.cdap.common.conf.Constants.Security
Comma separated URL's that clients should use to communicate with the Authentication Server.
AUTH_SERVER_BIND_ADDRESS - Static variable in class co.cask.cdap.common.conf.Constants.Security
Address the Authentication Server should bind to.
AUTH_SERVER_BIND_PORT - Static variable in class co.cask.cdap.common.conf.Constants.Security
Configuration for External Authentication Server.
AuthEnforce - Annotation Type in co.cask.cdap.common.security
Annotation for a method that needs Authorization enforcement.
AuthEnforceRewriter - Class in co.cask.cdap.common.security
A ClassRewriter for rewriting bytecode of classes which needs Authorization Enforcement and uses AuthEnforce annotation.
AuthEnforceRewriter() - Constructor for class co.cask.cdap.common.security.AuthEnforceRewriter
 
AuthEnforceUtil - Class in co.cask.cdap.common.security
Class used by AuthEnforceRewriter to rewrite classes with AuthEnforce annotation and call enforcement methods in this class to perform authorization enforcement.
AUTHENTICATION_CONTEXT_FIELD_NAME - Static variable in class co.cask.cdap.common.security.AuthEnforceRewriter
 
AUTHENTICATION_HANDLER - Static variable in class co.cask.cdap.security.server.ExternalAuthenticationServer.HandlerType
 
AuthenticationChannelHandler - Class in co.cask.cdap.common.http
An UpstreamHandler that verifies the userId in a request header and updates the SecurityRequestContext.
AuthenticationChannelHandler() - Constructor for class co.cask.cdap.common.http.AuthenticationChannelHandler
 
AuthenticationContext - Interface in co.cask.cdap.security.spi.authentication
A context that determines authentication details.
AuthenticationContextModules - Class in co.cask.cdap.security.auth.context
Exposes the right AuthenticationContext via an AbstractModule based on the context in which it is being invoked.
AuthenticationContextModules() - Constructor for class co.cask.cdap.security.auth.context.AuthenticationContextModules
 
AuthenticationGuiceServletContextListener - Class in co.cask.cdap.security.server
RestEasy context listener used to bind handlers.
AuthenticationGuiceServletContextListener(Map<String, Object>) - Constructor for class co.cask.cdap.security.server.AuthenticationGuiceServletContextListener
Create an AuthenticationGuiceServletContextListener that binds handlers.
AuthenticationHandler - Class in co.cask.cdap.gateway.router.handlers
A ChannelInboundHandler for inspecting authentication access token for all incoming HTTP requests to the router.
AuthenticationHandler(CConfiguration, TokenValidator, DiscoveryServiceClient, AccessTokenTransformer) - Constructor for class co.cask.cdap.gateway.router.handlers.AuthenticationHandler
 
AuthenticationServer() - Constructor for class co.cask.cdap.common.conf.Constants.Security.AuthenticationServer
 
AuthenticationServerMain - Class in co.cask.cdap.security.runtime
Server for authenticating clients accessing CDAP.
AuthenticationServerMain() - Constructor for class co.cask.cdap.security.runtime.AuthenticationServerMain
 
AuthenticationTestContext - Class in co.cask.cdap.security.auth.context
A dummy AuthenticationContext to be used in tests.
AuthenticationTestContext() - Constructor for class co.cask.cdap.security.auth.context.AuthenticationTestContext
 
Authorizable - Class in co.cask.cdap.proto.security
Class to represent entities on which privileges can be granted/revoked.
Authorizable(EntityType, Map<EntityType, String>) - Constructor for class co.cask.cdap.proto.security.Authorizable
 
Authorization() - Constructor for class co.cask.cdap.common.conf.Constants.Security.Authorization
 
AUTHORIZATION_BASE - Static variable in class co.cask.cdap.client.AuthorizationClient
 
AUTHORIZATION_ENFORCER_FIELD_NAME - Static variable in class co.cask.cdap.common.security.AuthEnforceRewriter
 
AuthorizationArtifactRepository - Class in co.cask.cdap.internal.app.runtime.artifact
/** A class which has a delegation ArtifactRepository which has authorization enforce on the methods.
AuthorizationArtifactRepository(ArtifactRepository, AuthorizationEnforcer, AuthenticationContext) - Constructor for class co.cask.cdap.internal.app.runtime.artifact.AuthorizationArtifactRepository
 
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
 
AuthorizationContext - Interface in co.cask.cdap.security.spi.authorization
A context for Authorizer extensions to interact with CDAP.
AuthorizationContextFactory - Interface in co.cask.cdap.security.authorization
Guice factory for creating AuthorizationContext instances
AuthorizationDatasetTypeService - Class in co.cask.cdap.data2.datafabric.dataset.service
A class which has a delegation DatasetTypeService which has authorization enforce on the methods.
AuthorizationDatasetTypeService(DatasetTypeService, AuthorizationEnforcer, AuthenticationContext) - Constructor for class co.cask.cdap.data2.datafabric.dataset.service.AuthorizationDatasetTypeService
 
AuthorizationEnforcementModule - Class in co.cask.cdap.security.authorization
A module that contains bindings for AuthorizationEnforcer.
AuthorizationEnforcementModule() - Constructor for class co.cask.cdap.security.authorization.AuthorizationEnforcementModule
 
AuthorizationEnforcer - Interface in co.cask.cdap.security.spi.authorization
Enforces authorization for a Principal to perform an Action on an EntityId.
AuthorizationHandler - Class in co.cask.cdap.gateway.handlers
Exposes Authorizer operations via HTTP.
AuthorizationModule - Class in co.cask.cdap.app.guice
PrivateModule for authorization classes.
AuthorizationModule() - Constructor for class co.cask.cdap.app.guice.AuthorizationModule
 
AuthorizationPrivilege - Class in co.cask.cdap.proto.security
Key for caching Privileges on containers.
AuthorizationPrivilege(Principal, EntityId, Action) - Constructor for class co.cask.cdap.proto.security.AuthorizationPrivilege
 
AuthorizationRequest - Class in co.cask.cdap.proto.security
Contains components for an Authorization request.
AuthorizationRequest(Authorizable, Principal, Set<Action>) - Constructor for class co.cask.cdap.proto.security.AuthorizationRequest
 
AuthorizationStreamAdmin - Class in co.cask.cdap.data2.transaction.stream
 
AuthorizationStreamAdmin(StreamAdmin, AuthenticationContext, AuthorizationEnforcer, OwnerAdmin) - Constructor for class co.cask.cdap.data2.transaction.stream.AuthorizationStreamAdmin
 
AuthorizationUtil - Class in co.cask.cdap.security.authorization
Utility functions for Authorization
authorizeAs(String, Callable<T>) - Static method in class co.cask.cdap.security.authorization.AuthorizationUtil
Helper function, to run the callable as the principal provided and reset back when the call is done
Authorizer - Interface in co.cask.cdap.security.spi.authorization
Interface for managing principals' authorization for actions on CDAP entities.
AuthorizerClassLoader - Class in co.cask.cdap.security.authorization
AuthorizerInstantiator - Class in co.cask.cdap.security.authorization
Class to instantiate Authorizer extensions.
AuthorizerInstantiator(CConfiguration, AuthorizationContextFactory) - Constructor for class co.cask.cdap.security.authorization.AuthorizerInstantiator
 
autoCommitFailureClosesAllResultSets() - Method in class co.cask.cdap.explore.jdbc.ExploreDatabaseMetaData
 
AVG_TIME - Static variable in class co.cask.cdap.etl.common.Constants.Metrics
 
AVRO - Static variable in class co.cask.cdap.api.data.format.Formats
 
AvroRecordFormat - Class in co.cask.cdap.format
Stream record format that interprets the body as avro encoded binary data.
AvroRecordFormat() - Constructor for class co.cask.cdap.format.AvroRecordFormat
 
awaitTermination(long, TimeUnit) - Method in class co.cask.cdap.common.async.KeyedExecutor
Calls ExecutorService.awaitTermination(long, TimeUnit) on the underlying executor

B

BACKLINK_URL_STREAM - Static variable in class co.cask.cdap.examples.sparkpagerank.SparkPageRankApp
 
BACKLOG_CONNECTIONS - Static variable in class co.cask.cdap.common.conf.Constants.AppFabric
 
BACKLOG_CONNECTIONS - Static variable in class co.cask.cdap.common.conf.Constants.Dataset.Manager
 
BACKLOG_CONNECTIONS - Static variable in class co.cask.cdap.common.conf.Constants.Explore
 
BACKLOG_CONNECTIONS - Static variable in class co.cask.cdap.common.conf.Constants.Metrics
 
BACKLOG_CONNECTIONS - Static variable in class co.cask.cdap.common.conf.Constants.Router
 
BadRequestException - Exception in co.cask.cdap.common
Thrown when the input was bad.
BadRequestException(String) - Constructor for exception co.cask.cdap.common.BadRequestException
 
BadRequestException(Throwable) - Constructor for exception co.cask.cdap.common.BadRequestException
 
BadRequestException(String, Throwable) - Constructor for exception co.cask.cdap.common.BadRequestException
 
BadRequestException - Exception in co.cask.cdap.security.spi.authorization
Exception thrown on invalid input
BadRequestException(Role) - Constructor for exception co.cask.cdap.security.spi.authorization.BadRequestException
 
BadRequestException(String) - Constructor for exception co.cask.cdap.security.spi.authorization.BadRequestException
 
BalancedAssignmentStrategy - Class in co.cask.cdap.common.zookeeper.coordination
A AssignmentStrategy that tries to balance partition replica assignment with minimum movement.
BalancedAssignmentStrategy() - Constructor for class co.cask.cdap.common.zookeeper.coordination.BalancedAssignmentStrategy
 
BASE_DATASET_FRAMEWORK - Static variable in class co.cask.cdap.data.runtime.DataSetsModules
 
BASE_DATASET_FRAMEWORK - Static variable in class co.cask.cdap.data.runtime.preview.PreviewDataModules
 
BASE_DIR - Static variable in class co.cask.cdap.common.conf.Constants.Stream
 
BASE_PATH - Static variable in class co.cask.cdap.api.dataset.lib.FileSetProperties
The base path of the dataset.
BaseBatchCommand<T extends BatchProgram> - Class in co.cask.cdap.cli.command.app
Base class for commands that work on multiple programs in an application.
BaseBatchCommand(ApplicationClient, CLIConfig) - Constructor for class co.cask.cdap.cli.command.app.BaseBatchCommand
 
BaseBatchCommand.Args<T> - Class in co.cask.cdap.cli.command.app
Container for command arguments.
BaseHiveExploreService - Class in co.cask.cdap.explore.service.hive
Defines common functionality used by different HiveExploreServices.
BaseHiveExploreService(TransactionSystemClient, DatasetFramework, CConfiguration, Configuration, File, File, StreamAdmin, NamespaceQueryAdmin, SystemDatasetInstantiatorFactory, AuthorizationEnforcer, AuthenticationContext) - Constructor for class co.cask.cdap.explore.service.hive.BaseHiveExploreService
 
BaseResourceListener<T> - Class in co.cask.cdap.security.zookeeper
Simple ResourceListener implementation with no-op implementations.
BaseResourceListener() - Constructor for class co.cask.cdap.security.zookeeper.BaseResourceListener
 
BaseStepExecutor<T extends co.cask.cdap.internal.bootstrap.executor.Validatable> - Class in co.cask.cdap.internal.bootstrap.executor
Executes a bootstrap step.
BaseStepExecutor() - Constructor for class co.cask.cdap.internal.bootstrap.executor.BaseStepExecutor
 
baseURL() - Method in class co.cask.cdap.common.internal.guava.ClassPath.ResourceInfo
Returns the base URL of the resource.
BASIC_REALM_FILE - Static variable in class co.cask.cdap.common.conf.Constants.Security
Realm file for Basic Authentication
BasicActionContext - Class in co.cask.cdap.etl.batch.customaction
Default implementation for the ActionContext.
BasicActionContext(CustomActionContext, PipelineRuntime, StageSpec) - Constructor for class co.cask.cdap.etl.batch.customaction.BasicActionContext
 
BasicArguments - Class in co.cask.cdap.etl.common
Default implementation of SettableArguments.
BasicArguments(Map<String, String>) - Constructor for class co.cask.cdap.etl.common.BasicArguments
 
BasicArguments(T) - Constructor for class co.cask.cdap.etl.common.BasicArguments
 
BasicArguments(WorkflowToken, Map<String, String>) - Constructor for class co.cask.cdap.etl.common.BasicArguments
 
BasicArguments - Class in co.cask.cdap.internal.app.runtime
 
BasicArguments() - Constructor for class co.cask.cdap.internal.app.runtime.BasicArguments
 
BasicArguments(Map<String, String>) - Constructor for class co.cask.cdap.internal.app.runtime.BasicArguments
 
BasicAuthenticationHandler - Class in co.cask.cdap.security.server
Handler for basic authentication of users.
BasicAuthenticationHandler() - Constructor for class co.cask.cdap.security.server.BasicAuthenticationHandler
 
BasicConditionContext - Class in co.cask.cdap.etl.batch.condition
Default implementation of the ConditionContext.
BasicConditionContext(WorkflowContext, PipelineRuntime, StageSpec) - Constructor for class co.cask.cdap.etl.batch.condition.BasicConditionContext
 
BasicCustomActionContext - Class in co.cask.cdap.internal.app.runtime.customaction
Implementation of CustomActionContext.
BasicCustomActionContext(Program, ProgramOptions, CConfiguration, CustomActionSpecification, WorkflowProgramInfo, MetricsCollectionService, DatasetFramework, TransactionSystemClient, DiscoveryServiceClient, PluginInstantiator, SecureStore, SecureStoreManager, MessagingService, MetadataReader, MetadataPublisher) - Constructor for class co.cask.cdap.internal.app.runtime.customaction.BasicCustomActionContext
 
BasicErrorRecord<T> - Class in co.cask.cdap.etl.common
Default implementation of ErrorRecord.
BasicErrorRecord(T, String, int, String) - Constructor for class co.cask.cdap.etl.common.BasicErrorRecord
 
BasicHttpServiceContext - Class in co.cask.cdap.internal.app.runtime.service.http
Default implementation of HttpServiceContext which simply stores and retrieves the spec provided when this class is instantiated
BasicHttpServiceContext(Program, ProgramOptions, CConfiguration, HttpServiceHandlerSpecification, int, AtomicInteger, MetricsCollectionService, DatasetFramework, DiscoveryServiceClient, TransactionSystemClient, PluginInstantiator, SecureStore, SecureStoreManager, MessagingService, ArtifactManager, MetadataReader, MetadataPublisher) - Constructor for class co.cask.cdap.internal.app.runtime.service.http.BasicHttpServiceContext
Creates a BasicHttpServiceContext for the given HttpServiceHandlerSpecification.
BasicHttpServiceContextFactory - Interface in co.cask.cdap.internal.app.services
Factory for creating BasicHttpServiceContext.
BasicLineageWriter - Class in co.cask.cdap.data2.metadata.writer
Basic implementation of LineageWriter and FieldLineageWriter.
BasicLineageWriter(DatasetFramework, TransactionSystemClient) - Constructor for class co.cask.cdap.data2.metadata.writer.BasicLineageWriter
 
BasicMapReduceTaskContext<KEYOUT,VALUEOUT> - Class in co.cask.cdap.internal.app.runtime.batch
Mapreduce task runtime context which delegates to BasicMapReduceContext for non task-specific methods.
BasicMessagingAdmin - Class in co.cask.cdap.messaging.context
A basic implementation of MessagingAdmin by delegating to MessagingService.
BasicMessagingAdmin(MessagingService, NamespaceId) - Constructor for class co.cask.cdap.messaging.context.BasicMessagingAdmin
 
BasicNotificationContext - Class in co.cask.cdap.notifications.service
Implementation of NotificationContext.
BasicNotificationContext(NamespaceId, DatasetFramework, TransactionSystemClient) - Constructor for class co.cask.cdap.notifications.service.BasicNotificationContext
 
BasicOutputFormatProvider - Class in co.cask.cdap.internal.app.runtime.batch
Simple implementation of OutputFormatProvider.
BasicOutputFormatProvider(String, Map<String, String>) - Constructor for class co.cask.cdap.internal.app.runtime.batch.BasicOutputFormatProvider
 
BasicPartitionOutput(PartitionedFileSetDataset, String, PartitionKey) - Constructor for class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset.BasicPartitionOutput
 
BasicProgramContext - Class in co.cask.cdap.internal.app.runtime
Straight forward implementation of ProgramContext.
BasicProgramContext(ProgramRunId) - Constructor for class co.cask.cdap.internal.app.runtime.BasicProgramContext
 
BasicProgramContext(ProgramRunId, NamespacedEntityId) - Constructor for class co.cask.cdap.internal.app.runtime.BasicProgramContext
 
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
 
BasicSparkExecutionPluginContext - Class in co.cask.cdap.etl.spark.batch
Implementation of SparkExecutionPluginContext by delegating to JavaSparkExecutionContext.
BasicSparkExecutionPluginContext(JavaSparkExecutionContext, JavaSparkContext, DatasetContext, PipelineRuntime, StageSpec) - Constructor for class co.cask.cdap.etl.spark.batch.BasicSparkExecutionPluginContext
 
BasicSparkPluginContext - Class in co.cask.cdap.etl.spark.batch
Implementation of SparkPluginContext that delegates to a SparkContext.
BasicSparkPluginContext(SparkClientContext, PipelineRuntime, StageSpec, DatasetContext, Admin) - Constructor for class co.cask.cdap.etl.spark.batch.BasicSparkPluginContext
 
BasicStageStatistics - Class in co.cask.cdap.etl.batch.condition
Default implementation of the StageStatistics.
BasicStageStatistics(long, long, long) - Constructor for class co.cask.cdap.etl.batch.condition.BasicStageStatistics
 
BasicStreamWriterSizeCollector - Class in co.cask.cdap.data.stream.service
Basic implementation of a StreamWriterSizeCollector.
BasicStreamWriterSizeCollector() - Constructor for class co.cask.cdap.data.stream.service.BasicStreamWriterSizeCollector
 
BasicThrowable - Class in co.cask.cdap.proto
Maintains basic information about a Throwable, for easy serialization/deserialization.
BasicThrowable(String, String, StackTraceElement[], BasicThrowable) - Constructor for class co.cask.cdap.proto.BasicThrowable
This constructor is used by BasicThrowableCodec during de-serialization.
BasicThrowable(Throwable) - Constructor for class co.cask.cdap.proto.BasicThrowable
This constructor is used to create serializable instance from Throwable.
BasicThrowableCodec - Class in co.cask.cdap.proto.codec
Codec for BasicThrowable.
BasicThrowableCodec() - Constructor for class co.cask.cdap.proto.codec.BasicThrowableCodec
 
BasicUsageRegistry - Class in co.cask.cdap.data2.registry
Basic implementation of UsageRegistry that read/write to UsageDataset directly.
BasicUsageRegistry(DatasetFramework, TransactionSystemClient, DatasetId) - Constructor for class co.cask.cdap.data2.registry.BasicUsageRegistry
 
BasicWorkflowStateWriter - Class in co.cask.cdap.internal.app.runtime.workflow
Implementation of WorkflowStateWriter that writes to AppMetadataStore directly.
BasicWorkflowToken - Class in co.cask.cdap.internal.app.runtime.workflow
Implementation of the WorkflowToken interface.
BasicWorkflowToken(int) - Constructor for class co.cask.cdap.internal.app.runtime.workflow.BasicWorkflowToken
Creates a BasicWorkflowToken with the specified maximum size.
Batch - Annotation Type in co.cask.cdap.api.annotation
Deprecated.
As of release 5.0.0, replaced by @ProgramType.SPARK for realtime processing.
batch(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.data.stream.service.StreamHandler
 
BATCH_BUFFER_THRESHOLD - Static variable in class co.cask.cdap.common.conf.Constants.Stream
 
BATCH_NAME - Static variable in class co.cask.cdap.etl.tool.config.Upgrader
 
BATCH_SIZE - Static variable in class co.cask.cdap.common.conf.Constants.RuntimeMonitor
 
BATCH_TAG - Static variable in class co.cask.cdap.data2.metadata.system.DatasetSystemMetadataProvider
 
BATCH_UNLIMITED - Static variable in class co.cask.cdap.data2.increment.hbase.IncrementHandlerState
 
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
BatchPhaseSpec - Class in co.cask.cdap.etl.batch
Information required by one phase of a batch pipeline.
BatchPhaseSpec(String, PipelinePhase, Resources, Resources, Resources, boolean, boolean, Map<String, String>, int, Map<String, String>, boolean) - Constructor for class co.cask.cdap.etl.batch.BatchPhaseSpec
 
BatchPipelineSpec - Class in co.cask.cdap.etl.batch
Specification for a batch pipeline.
BatchPipelineSpec.Builder - Class in co.cask.cdap.etl.batch
Builder for creating a BatchPipelineSpec.
BatchPipelineSpecGenerator<T extends PluginConfigurer & DatasetConfigurer> - Class in co.cask.cdap.etl.batch
Generates a pipeline spec for batch apps.
BatchPipelineSpecGenerator(T, Set<String>, Set<String>, Engine) - Constructor for class co.cask.cdap.etl.batch.BatchPipelineSpecGenerator
 
BatchProgram - Class in co.cask.cdap.proto
Array components of the batch status request to POST /namespaces/{namespace}/status.
BatchProgram(String, ProgramType, String) - Constructor for class co.cask.cdap.proto.BatchProgram
 
BatchProgramCount - Class in co.cask.cdap.proto
Result for the program count for http response
BatchProgramCount(BatchProgram, int, String, Long) - Constructor for class co.cask.cdap.proto.BatchProgramCount
 
BatchProgramCount(ProgramId, int, String, Long) - Constructor for class co.cask.cdap.proto.BatchProgramCount
 
BatchProgramHistory - Class in co.cask.cdap.proto
Result for the batch program runs endpoint
BatchProgramHistory(BatchProgram, int, String, List<RunRecord>) - Constructor for class co.cask.cdap.proto.BatchProgramHistory
 
BatchProgramResult - Class in co.cask.cdap.proto
Describes the results returned by the batch stop/start endpoints POST /namespaces/{namespace}/stop|start.
BatchProgramResult(BatchProgram, int, String) - Constructor for class co.cask.cdap.proto.BatchProgramResult
 
BatchProgramResult(String, ProgramType, String, int, String, String) - Constructor for class co.cask.cdap.proto.BatchProgramResult
 
BatchProgramResult(BatchProgram, int, String, String) - Constructor for class co.cask.cdap.proto.BatchProgramResult
 
BatchProgramStart - Class in co.cask.cdap.proto
Array components of the batch start request to POST /namespaces/{namespace}/start.
BatchProgramStart(BatchProgram) - Constructor for class co.cask.cdap.proto.BatchProgramStart
 
BatchProgramStart(BatchProgram, Map<String, String>) - Constructor for class co.cask.cdap.proto.BatchProgramStart
 
BatchProgramStart(String, ProgramType, String) - Constructor for class co.cask.cdap.proto.BatchProgramStart
 
BatchProgramStart(String, ProgramType, String, Map<String, String>) - Constructor for class co.cask.cdap.proto.BatchProgramStart
 
BatchProgramStatus - Class in co.cask.cdap.proto
Describes the status of a program, as returned by the batch status endpoint POST /namespaces/{namespace}/status.
BatchProgramStatus(BatchProgram, int, String, String) - Constructor for class co.cask.cdap.proto.BatchProgramStatus
 
BatchReadable<KEY,VALUE> - Interface in co.cask.cdap.api.data.batch
Interface for datasets that can be input to a batch job.
BatchRunnable - Class in co.cask.cdap.proto
Array components of the batch status request to POST /namespaces/{namespace}/instances.
BatchRunnable(String, ProgramType, String, String) - Constructor for class co.cask.cdap.proto.BatchRunnable
 
BatchRunnableInstances - Class in co.cask.cdap.proto
Describes the instances of a program, as returned by the batch instances endpoint POST /namespaces/{namespace}/instances.
BatchRunnableInstances(BatchRunnable, int, int, int) - Constructor for class co.cask.cdap.proto.BatchRunnableInstances
 
BatchRunnableInstances(BatchRunnable, int, String) - Constructor for class co.cask.cdap.proto.BatchRunnableInstances
 
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.
BatchSinkFunction<IN,OUT_KEY,OUT_VAL> - Class in co.cask.cdap.etl.spark.function
Function that uses a BatchSink to transform one object into a pair.
BatchSinkFunction(PluginFunctionContext) - Constructor for class co.cask.cdap.etl.spark.function.BatchSinkFunction
 
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.
BatchSourceFunction - Class in co.cask.cdap.etl.spark.function
Function that uses a BatchSource to transform a pair of objects into a single object.
BatchSourceFunction(PluginFunctionContext, int) - Constructor for class co.cask.cdap.etl.spark.function.BatchSourceFunction
 
BatchSparkPipelineDriver - Class in co.cask.cdap.etl.spark.batch
Batch Spark pipeline driver.
BatchSparkPipelineDriver() - Constructor for class co.cask.cdap.etl.spark.batch.BatchSparkPipelineDriver
 
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
 
beforeLaunch(Program, ProgramOptions) - Method in class co.cask.cdap.internal.app.runtime.distributed.DistributedFlowProgramRunner
 
beforeLaunch(Program, ProgramOptions) - Method in class co.cask.cdap.internal.app.runtime.distributed.DistributedProgramRunner
The extra hook to be called right before the program is launch.
beforeSubmit() - Method in class co.cask.cdap.app.runtime.spark.submit.AbstractSparkSubmitter
Called before submitting the Spark job.
beforeSubmit() - Method in class co.cask.cdap.app.runtime.spark.submit.DistributedSparkSubmitter
 
beforeTest() - Method in class co.cask.cdap.test.TestBase
 
beginsWithVowel() - Method in class co.cask.cdap.cli.english.Word
 
beginTry() - Method in class co.cask.cdap.internal.asm.FinallyAdapter
Sub-class should call this to signal the beginning of the try block.
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.
BinaryDecoder - Class in co.cask.cdap.common.io
An Decoder for binary-format data.
BinaryDecoder(InputStream) - Constructor for class co.cask.cdap.common.io.BinaryDecoder
 
BinaryEncoder - Class in co.cask.cdap.common.io
An Encoder for binary-format data.
BinaryEncoder(OutputStream) - Constructor for class co.cask.cdap.common.io.BinaryEncoder
 
BIND_PORT - Static variable in class co.cask.cdap.common.conf.Constants.Dashboard
Port for the dashboard to bind to in non-SSL mode.
bindHandlers(Binder, String) - Static method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule
 
BindingException - Exception in co.cask.cdap.api.spark.dynamic
Exception to indicate there is an error in binding variable.
BindingException(String, String, Object, String...) - Constructor for exception co.cask.cdap.api.spark.dynamic.BindingException
 
bindKeyManager(Binder) - Method in class co.cask.cdap.security.guice.FileBasedSecurityModule
 
bindKeyManager(Binder) - Method in class co.cask.cdap.security.guice.SecurityModule
 
blockForAvailableThreads() - Method in class co.cask.cdap.internal.app.runtime.schedule.ExecutorThreadPool
 
bold(String) - Static method in class co.cask.cdap.cli.util.StringStyler
 
bootstrap(HttpRequest, HttpResponder) - Method in class co.cask.cdap.gateway.handlers.BootstrapHttpHandler
 
bootstrap() - Method in class co.cask.cdap.internal.bootstrap.BootstrapService
Execute all steps in the loaded bootstrap config without skipping any of them.
bootstrap(Predicate<BootstrapStep>) - Method in class co.cask.cdap.internal.bootstrap.BootstrapService
Execute the steps in the loaded bootstrap config.
BOOTSTRAP_FILE - Static variable in class co.cask.cdap.common.conf.Constants
 
BootstrapConfig - Class in co.cask.cdap.internal.bootstrap
Specified operations to perform to bootstrap a CDAP instance.
BootstrapConfig(List<BootstrapStep>) - Constructor for class co.cask.cdap.internal.bootstrap.BootstrapConfig
 
BootstrapConfigProvider - Interface in co.cask.cdap.internal.bootstrap
BootstrapHttpHandler - Class in co.cask.cdap.gateway.handlers
Bootstrap HTTP Handler.
BootstrapModules - Class in co.cask.cdap.internal.bootstrap.guice
Guice bindings for bootstrap classes.
BootstrapModules() - Constructor for class co.cask.cdap.internal.bootstrap.guice.BootstrapModules
 
bootstrapped() - Method in class co.cask.cdap.internal.bootstrap.BootstrapStore
Mark the CDAP instance as bootstrapped.
BootstrapResult - Class in co.cask.cdap.proto.bootstrap
Result of executing bootstrap steps.
BootstrapResult(List<BootstrapStepResult>) - Constructor for class co.cask.cdap.proto.bootstrap.BootstrapResult
 
BootstrapService - Class in co.cask.cdap.internal.bootstrap
Performs bootstrap steps.
BootstrapStep - Class in co.cask.cdap.internal.bootstrap
Definition for a single step in a bootstrap process.
BootstrapStep(String, BootstrapStep.Type, BootstrapStep.RunCondition, JsonObject) - Constructor for class co.cask.cdap.internal.bootstrap.BootstrapStep
 
BootstrapStep.RunCondition - Enum in co.cask.cdap.internal.bootstrap
When a step should be run
BootstrapStep.Type - Enum in co.cask.cdap.internal.bootstrap
Bootstrap step type
BootstrapStepExecutor - Interface in co.cask.cdap.internal.bootstrap.executor
Executes a bootstrap step.
BootstrapStepResult - Class in co.cask.cdap.proto.bootstrap
Result of executing a bootstrap step.
BootstrapStepResult(String, BootstrapStepResult.Status) - Constructor for class co.cask.cdap.proto.bootstrap.BootstrapStepResult
 
BootstrapStepResult(String, BootstrapStepResult.Status, String) - Constructor for class co.cask.cdap.proto.bootstrap.BootstrapStepResult
 
BootstrapStepResult.Status - Enum in co.cask.cdap.proto.bootstrap
Status of the bootstrap step
BootstrapStore - Class in co.cask.cdap.internal.bootstrap
Fetches and stores bootstrap state.
BOSS_THREADS - Static variable in class co.cask.cdap.common.conf.Constants.AppFabric
 
BOSS_THREADS - Static variable in class co.cask.cdap.common.conf.Constants.Dataset.Manager
 
BOSS_THREADS - Static variable in class co.cask.cdap.common.conf.Constants.Metrics
 
BUFFER_BYTES - Static variable in class co.cask.cdap.logging.gateway.handlers.AbstractChunkedLogProducer
 
BufferedContentWriterFactory - Class in co.cask.cdap.data.stream.service.upload
A ContentWriterFactory that creates ContentWriter that buffer all write requests in memory and write them out at close time.
BufferedContentWriterFactory(StreamId, ConcurrentStreamWriter, Map<String, String>) - Constructor for class co.cask.cdap.data.stream.service.upload.BufferedContentWriterFactory
 
BufferedEncoder - Class in co.cask.cdap.common.io
A Encoder that performs all writes to in memory buffer.
BufferedEncoder(int, Function<OutputStream, Encoder>) - Constructor for class co.cask.cdap.common.io.BufferedEncoder
 
BufferFileInputStream - Class in co.cask.cdap.internal.app
File input stream that returns byte array while reading.
BufferFileInputStream(String, int) - Constructor for class co.cask.cdap.internal.app.BufferFileInputStream
Constructor of BufferFileInputStream with defined buffer size.
BufferFileInputStream(String) - Constructor for class co.cask.cdap.internal.app.BufferFileInputStream
Constructor of BufferFileInputStream with default buffer stream size.
BufferFileInputStream(InputStream, int) - Constructor for class co.cask.cdap.internal.app.BufferFileInputStream
Constructor of BufferFileInputStream using an input stream.
BufferingTable - Class in co.cask.cdap.data2.dataset2.lib.table
An abstract TransactionAware implementation of Table which keeps data in memory buffer until transaction commits.
BufferingTable(String) - Constructor for class co.cask.cdap.data2.dataset2.lib.table.BufferingTable
Creates an instance of BufferingTable with row level conflict detection, without readless increments, and no schema.
BufferingTable(String, ConflictDetection) - Constructor for class co.cask.cdap.data2.dataset2.lib.table.BufferingTable
Creates an instance of BufferingTable without readless increments disabled and no schema.
BufferingTable(String, boolean, Map<String, String>) - Constructor for class co.cask.cdap.data2.dataset2.lib.table.BufferingTable
Creates an instance of BufferingTable.
build() - Method in class co.cask.cdap.api.artifact.ArtifactClasses.Builder
 
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.metadata.MetadataEntity.Builder
Builds a MetadataEntity from the builder.
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.cli.LaunchOptions.Builder
 
build() - Method in class co.cask.cdap.cli.util.table.Table.Builder
 
build() - Method in class co.cask.cdap.cli.util.table.Table.Builder.Rows
 
build() - Method in class co.cask.cdap.client.config.ClientConfig.Builder
 
build() - Method in class co.cask.cdap.client.config.ConnectionConfig.Builder
 
build() - Method in class co.cask.cdap.common.http.CommonNettyHttpServiceBuilder
 
build() - Method in class co.cask.cdap.common.id.Id.NotificationFeed.Builder
 
build() - Method in class co.cask.cdap.common.service.CommandPortService.Builder
Builds the CommandPortService.
build() - Method in class co.cask.cdap.common.ssh.SSHConfig.Builder
 
build() - Method in class co.cask.cdap.common.startup.CheckRunner.Builder
Build the CheckRunner.
build() - Method in class co.cask.cdap.common.zookeeper.coordination.ResourceRequirement.Builder
 
build(StreamInputSplitFactory<T>) - Method in class co.cask.cdap.data.stream.StreamInputSplitFinder.Builder
Build the input split finder given a factory for creating splits.
build() - Method in class co.cask.cdap.data2.audit.payload.builder.MetadataPayloadBuilder
Build the metadata payload using the previous value, additions and deletions.
build() - Method in class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
build() - Method in class co.cask.cdap.data2.transaction.stream.StreamConfig.Builder
 
build() - Method in class co.cask.cdap.data2.util.hbase.ColumnFamilyDescriptorBuilder
 
build() - Method in class co.cask.cdap.data2.util.hbase.DefaultScanBuilder
 
build() - Method in interface co.cask.cdap.data2.util.hbase.DeleteBuilder
 
build() - Method in interface co.cask.cdap.data2.util.hbase.GetBuilder
 
build() - Method in class co.cask.cdap.data2.util.hbase.HTableDescriptorBuilder
 
build() - Method in interface co.cask.cdap.data2.util.hbase.IncrementBuilder
 
build() - Method in interface co.cask.cdap.data2.util.hbase.PutBuilder
 
build() - Method in interface co.cask.cdap.data2.util.hbase.ScanBuilder
 
build() - Method in class co.cask.cdap.data2.util.hbase.TableDescriptorBuilder
 
build() - Method in class co.cask.cdap.datapipeline.StageOperationsValidator.Builder
 
build() - Method in class co.cask.cdap.datastreams.DataStreamsPipelineSpec.Builder
 
build() - Method in class co.cask.cdap.etl.batch.BatchPipelineSpec.Builder
 
build() - Method in class co.cask.cdap.etl.batch.ConnectorSourceEmitter.Builder
 
build() - Method in class co.cask.cdap.etl.batch.PipeEmitter.Builder
 
build() - Method in class co.cask.cdap.etl.common.PipelinePhase.Builder
 
build() - Method in class co.cask.cdap.etl.common.RecordInfo.Builder
 
build() - Method in class co.cask.cdap.etl.planner.ConnectorDag.Builder
 
build() - Method in class co.cask.cdap.etl.proto.v1.ETLBatchConfig.Builder
 
build() - Method in class co.cask.cdap.etl.proto.v2.DataStreamsConfig.Builder
 
build() - Method in class co.cask.cdap.etl.proto.v2.ETLBatchConfig.Builder
 
build() - Method in class co.cask.cdap.etl.spec.PipelineSpec.Builder
 
build() - Method in class co.cask.cdap.etl.spec.StageSpec.Builder
 
build() - Method in class co.cask.cdap.internal.app.runtime.plugin.MacroParser.Builder
 
build(String, String, String) - Method in class co.cask.cdap.internal.app.runtime.schedule.DefaultScheduleBuilder.ScheduleCreationBuilder
 
build(String, String, String) - Method in class co.cask.cdap.internal.app.runtime.schedule.trigger.AndTriggerBuilder
 
build(String, String, String) - Method in class co.cask.cdap.internal.app.runtime.schedule.trigger.OrTriggerBuilder
 
build(String, String, String) - Method in class co.cask.cdap.internal.app.runtime.schedule.trigger.ProgramStatusTriggerBuilder
 
build(String, String, String) - Method in interface co.cask.cdap.internal.app.runtime.schedule.trigger.TriggerBuilder
Builds a Trigger given the deployed namespace, application, and application version.
build() - Method in class co.cask.cdap.internal.app.store.RunRecordMeta.Builder
 
build() - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder
Creates a StoreRequest based on the settings in this builder.
build() - Method in class co.cask.cdap.proto.NamespaceMeta.Builder
 
build() - Method in class co.cask.cdap.proto.RunRecord.Builder
 
build() - Method in class co.cask.cdap.proto.SystemServiceLiveInfo.Builder
 
buildAddStatement(String) - Method in class co.cask.cdap.explore.table.AlterPartitionStatementBuilder
Builds ADD PARTITION statement.
buildConcatenateStatement() - Method in class co.cask.cdap.explore.table.AlterPartitionStatementBuilder
Builds PARTITION CONCATENATE statement.
buildDelete(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildDelete(Delete) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildDelete(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildDelete(Delete) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildDelete(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildDelete(Delete) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildDelete(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a DeleteBuilder for the given row.
buildDelete(Delete) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a DeleteBuilder by copying from another Delete instance.
buildDropStatement() - Method in class co.cask.cdap.explore.table.AlterPartitionStatementBuilder
Builds DROP PARTITION statement.
builder() - Static method in class co.cask.cdap.api.artifact.ArtifactClasses
 
Builder() - Constructor for class co.cask.cdap.api.artifact.ArtifactClasses.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() - Constructor for class co.cask.cdap.api.data.stream.StreamSpecification.Builder
Deprecated.
 
builder() - Static method in class co.cask.cdap.api.dataset.DatasetProperties
 
Builder() - Constructor for class co.cask.cdap.api.dataset.DatasetProperties.Builder
 
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() - Constructor for class co.cask.cdap.api.dataset.ExploreProperties.Builder
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery
 
Builder() - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery.Builder
 
builder() - Static method in class co.cask.cdap.api.dataset.lib.cube.CubeQuery
 
Builder() - Constructor for class co.cask.cdap.api.dataset.lib.cube.CubeQuery.Builder
 
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() - Constructor for class co.cask.cdap.api.dataset.lib.PartitionFilter.Builder
 
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() - Constructor for class co.cask.cdap.api.dataset.lib.PartitionKey.Builder
 
builder() - Static method in class co.cask.cdap.api.dataset.table.TableProperties
 
Builder() - Constructor for class co.cask.cdap.api.dataset.table.TableProperties.Builder
 
builder() - Static method in class co.cask.cdap.api.metadata.MetadataEntity
 
builder(MetadataEntity) - Static method in class co.cask.cdap.api.metadata.MetadataEntity
 
builder() - Static method in class co.cask.cdap.api.plugin.PluginProperties
 
builder() - Static method in class co.cask.cdap.cli.LaunchOptions
 
Builder() - Constructor for class co.cask.cdap.cli.LaunchOptions.Builder
 
builder() - Static method in class co.cask.cdap.cli.util.table.Table
 
Builder() - Constructor for class co.cask.cdap.cli.util.table.Table.Builder
 
builder() - Static method in class co.cask.cdap.client.config.ClientConfig
 
Builder() - Constructor for class co.cask.cdap.client.config.ClientConfig.Builder
 
Builder(ClientConfig) - Constructor for class co.cask.cdap.client.config.ClientConfig.Builder
 
builder() - Static method in class co.cask.cdap.client.config.ConnectionConfig
 
builder(ConnectionConfig) - Static method in class co.cask.cdap.client.config.ConnectionConfig
 
Builder() - Constructor for class co.cask.cdap.client.config.ConnectionConfig.Builder
 
Builder(ConnectionConfig) - Constructor for class co.cask.cdap.client.config.ConnectionConfig.Builder
 
Builder() - Constructor for class co.cask.cdap.common.id.Id.NotificationFeed.Builder
 
Builder(Id.NotificationFeed) - Constructor for class co.cask.cdap.common.id.Id.NotificationFeed.Builder
 
builder(String) - Static method in class co.cask.cdap.common.service.CommandPortService
Returns a CommandPortService.Builder to build instance of this class.
builder(String) - Static method in class co.cask.cdap.common.ssh.SSHConfig
Creates a new instance of SSHConfig.Builder.
builder(Injector) - Static method in class co.cask.cdap.common.startup.CheckRunner
Create a builder that uses the specified injector to instantiate checks to run.
Builder(Injector) - Constructor for class co.cask.cdap.common.startup.CheckRunner.Builder
 
builder(String) - Static method in class co.cask.cdap.common.zookeeper.coordination.ResourceRequirement
Builder(String) - Constructor for class co.cask.cdap.common.zookeeper.coordination.ResourceRequirement.Builder
 
builder(URI) - Static method in class co.cask.cdap.data.stream.StreamInputSplitFinder
Get a builder for creating an input split finder for a stream.
Builder(URI) - Constructor for class co.cask.cdap.data.stream.StreamInputSplitFinder.Builder
 
Builder() - Constructor for class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
Builder(MDSKey) - Constructor for class co.cask.cdap.data2.dataset2.lib.table.MDSKey.Builder
 
builder(StreamConfig) - Static method in class co.cask.cdap.data2.transaction.stream.StreamConfig
 
Builder(List<FieldOperation>) - Constructor for class co.cask.cdap.datapipeline.StageOperationsValidator.Builder
 
builder(long) - Static method in class co.cask.cdap.datastreams.DataStreamsPipelineSpec
 
Builder(long) - Constructor for class co.cask.cdap.datastreams.DataStreamsPipelineSpec.Builder
 
builder() - Static method in class co.cask.cdap.etl.batch.BatchPipelineSpec
 
Builder() - Constructor for class co.cask.cdap.etl.batch.BatchPipelineSpec.Builder
 
builder(String) - Static method in class co.cask.cdap.etl.batch.ConnectorSourceEmitter
Get a builder to create a PipeEmitter for the specified stage
builder(String) - Static method in class co.cask.cdap.etl.batch.PipeEmitter
Get a builder to create a PipeEmitter for the specified stage
Builder(String) - Constructor for class co.cask.cdap.etl.batch.PipeEmitter.Builder
 
builder(Set<String>) - Static method in class co.cask.cdap.etl.common.PipelinePhase
Get a builder used to create a pipeline phase.
Builder(Set<String>) - Constructor for class co.cask.cdap.etl.common.PipelinePhase.Builder
 
builder(T, String, RecordType) - Static method in class co.cask.cdap.etl.common.RecordInfo
 
builder() - Static method in class co.cask.cdap.etl.planner.ConnectorDag
 
builder(String) - Static method in class co.cask.cdap.etl.proto.v1.ETLBatchConfig
 
Builder(String) - Constructor for class co.cask.cdap.etl.proto.v1.ETLBatchConfig.Builder
 
Builder() - Constructor for class co.cask.cdap.etl.proto.v1.ETLConfig.Builder
 
builder() - Static method in class co.cask.cdap.etl.proto.v2.DataStreamsConfig
 
Builder() - Constructor for class co.cask.cdap.etl.proto.v2.DataStreamsConfig.Builder
 
builder(String) - Static method in class co.cask.cdap.etl.proto.v2.ETLBatchConfig
builder() - Static method in class co.cask.cdap.etl.proto.v2.ETLBatchConfig
 
Builder(String) - Constructor for class co.cask.cdap.etl.proto.v2.ETLBatchConfig.Builder
Builder() - Constructor for class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
builder() - Static method in class co.cask.cdap.etl.spec.PipelineSpec
 
Builder() - Constructor for class co.cask.cdap.etl.spec.PipelineSpec.Builder
 
builder(String, PluginSpec) - Static method in class co.cask.cdap.etl.spec.StageSpec
 
Builder(String, PluginSpec) - Constructor for class co.cask.cdap.etl.spec.StageSpec.Builder
 
builder(MacroEvaluator) - Static method in class co.cask.cdap.internal.app.runtime.plugin.MacroParser
 
builder() - Static method in class co.cask.cdap.internal.app.store.RunRecordMeta
 
builder(RunRecordMeta) - Static method in class co.cask.cdap.internal.app.store.RunRecordMeta
 
Builder() - Constructor for class co.cask.cdap.proto.NamespaceMeta.Builder
 
Builder(NamespaceMeta) - Constructor for class co.cask.cdap.proto.NamespaceMeta.Builder
 
builder() - Static method in class co.cask.cdap.proto.RunRecord
 
builder(RunRecord) - Static method in class co.cask.cdap.proto.RunRecord
 
Builder() - Constructor for class co.cask.cdap.proto.RunRecord.Builder
 
Builder(RunRecord) - Constructor for class co.cask.cdap.proto.RunRecord.Builder
 
builder() - Static method in class co.cask.cdap.proto.SystemServiceLiveInfo
 
Builder() - Constructor for class co.cask.cdap.proto.SystemServiceLiveInfo.Builder
 
builder() - Static method in class co.cask.cdap.security.ApplicationSecurity
Static builder for constructing list of permissions.
BuilderException - Exception in co.cask.cdap.common.builder
Exception that is raised when there is an issue building the object.
BuilderException() - Constructor for exception co.cask.cdap.common.builder.BuilderException
Basic construction of exception.
BuilderException(String) - Constructor for exception co.cask.cdap.common.builder.BuilderException
Construction of exception with reason specified.
BuilderException(Throwable) - Constructor for exception co.cask.cdap.common.builder.BuilderException
Construction of exception with a Throwable.
BuilderException(String, Throwable) - Constructor for exception co.cask.cdap.common.builder.BuilderException
Construction of exception with reason and throwable.
buildGet(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildGet(Get) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildGet(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildGet(Get) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildGet(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildGet(Get) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildGet(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a GetBuilder for the given row.
buildGet(Get) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a GetBuilder by copying from another Get instance.
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase10CDH550TableUtil
 
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase10CDH550TableUtil
 
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase10CDHTableUtil
 
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase10CDHTableUtil
 
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase96TableUtil
 
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase96TableUtil
 
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil
 
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBase98TableUtil
 
buildHTableDescriptor(TableId) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a new HTableDescriptorBuilder which may contain an HBase namespace depending on the HBase version
buildHTableDescriptor(HTableDescriptor) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a new HTableDescriptorBuilder which may contain an HBase namespace depending on the HBase version
buildIncrement(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildIncrement(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildIncrement(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildIncrement(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a IncrementBuilder for the given row.
buildInterpreter() - Method in class co.cask.cdap.logging.pipeline.LogPipelineConfigurator
 
buildPut(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildPut(Put) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildPut(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildPut(Put) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildPut(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildPut(Put) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildPut(byte[]) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a PutBuilder for the given row.
buildPut(Put) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a PutBuilder by copying from another Put instance.
buildScan() - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildScan(Scan) - Method in class co.cask.cdap.data2.util.hbase.HBase10TableUtil
 
buildScan() - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildScan(Scan) - Method in class co.cask.cdap.data2.util.hbase.HBase11TableUtil
 
buildScan() - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildScan(Scan) - Method in class co.cask.cdap.data2.util.hbase.HBase12CDH570TableUtil
 
buildScan() - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a ScanBuilder.
buildScan(Scan) - Method in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
Creates a ScanBuilder by copying from another Scan instance.
buildSchedule(String, ProgramType, String) - Method in class co.cask.cdap.api.app.AbstractApplication
Get a ScheduleBuilder for the specified program.
buildSchedule(String, ProgramType, String) - Method in interface co.cask.cdap.api.app.ApplicationConfigurer
Get a ScheduleBuilder for the specified program.
buildSchedule(String, ProgramType, String) - Method in class co.cask.cdap.app.DefaultAppConfigurer
 
buildWithDelimiter(String) - Method in class co.cask.cdap.explore.table.AlterStatementBuilder
Changes the delimiter for the row format.
buildWithFileFormat(String) - Method in class co.cask.cdap.explore.table.AlterStatementBuilder
Sets a native Hive file format for the table.
buildWithFileFormat(String) - Method in class co.cask.cdap.explore.table.CreateStatementBuilder
Builds a create statement for a native Hive table which is stored as a native Hive file format.
buildWithFormats(String, String, String) - Method in class co.cask.cdap.explore.table.AlterStatementBuilder
 
buildWithFormats(String, String) - Method in class co.cask.cdap.explore.table.CreateStatementBuilder
Builds a create statement for a native Hive table which is stored as a file format that uses an input format and output format.
buildWithLocation(Location) - Method in class co.cask.cdap.explore.table.AlterStatementBuilder
Set the location of the Hive table.
buildWithoutKeytabURIVersion() - Method in class co.cask.cdap.proto.NamespaceMeta.Builder
 
buildWithSchema(Schema) - Method in class co.cask.cdap.explore.table.AlterStatementBuilder
Set the hive schema for the table.
buildWithSchema(String) - Method in class co.cask.cdap.explore.table.AlterStatementBuilder
Set the hive schema for the table.
buildWithStorageHandler(String, Map<String, String>) - Method in class co.cask.cdap.explore.table.CreateStatementBuilder
Builds a create statement for a custom (non-native) Hive table.
buildWithTableProperties(Map<String, String>) - Method in class co.cask.cdap.explore.table.AlterStatementBuilder
Set table properties.
BUNDLE_VERSION - Static variable in class co.cask.cdap.app.program.ManifestFields
 
BundleJarUtil - Class in co.cask.cdap.common.lang.jar
Utility functions that operate on bundle jars.
BYPASS_AUTHENTICATION_REGEX - Static variable in class co.cask.cdap.common.conf.Constants.Security.Router
Paths to exclude from authentication, given by a single regular expression
ByteArrayComparator() - Constructor for class co.cask.cdap.api.common.Bytes.ByteArrayComparator
Constructor.
ByteBuffers - Class in co.cask.cdap.common.io
A utility class that helps to use a ByteBuffer correctly and efficiently.
ByteCodeClassLoader - Class in co.cask.cdap.internal.asm
A ClassLoader for loading known bytecode.
ByteCodeClassLoader(ClassLoader) - Constructor for class co.cask.cdap.internal.asm.ByteCodeClassLoader
 
bytecodes - Variable in class co.cask.cdap.internal.asm.ByteCodeClassLoader
Map from class name to bytecode.
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_COMPARATOR - Static variable in class co.cask.cdap.api.common.Bytes
Pass this to TreeMaps where byte [] are keys.
BYTES_TO_UPDATE - Static variable in class co.cask.cdap.data2.dataset2.lib.table.Updates
 
BytesStreamEventDecoder - Class in co.cask.cdap.data.stream.decoder
A StreamEventDecoder that decodes StreamEvent into LongWritable as key and BytesWritable as value for Mapper input.
BytesStreamEventDecoder() - Constructor for class co.cask.cdap.data.stream.decoder.BytesStreamEventDecoder
 
byTime(String) - Method in interface co.cask.cdap.api.schedule.TriggerFactory
Creates a trigger which is satisfied based upon the given cron expression.
byTime(String) - Method in class co.cask.cdap.internal.app.runtime.schedule.trigger.DefaultTriggerFactory
 

C

cache() - Method in class co.cask.cdap.etl.spark.batch.RDDCollection
 
cache() - Method in interface co.cask.cdap.etl.spark.SparkCollection
 
cache() - Method in class co.cask.cdap.etl.spark.streaming.DStreamCollection
 
CACHE_MAX_ENTRIES - Static variable in class co.cask.cdap.common.conf.Constants.Security.Authorization
Maximum number of entries the authorization cache will hold
CACHE_SIZE_MB - Static variable in class co.cask.cdap.common.conf.Constants.MessagingSystem
 
CACHE_TTL_SECS - Static variable in class co.cask.cdap.common.conf.Constants.Security.Authorization
TTL for entries in container's privilege cache
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
 
CacheSupplier<T extends com.google.common.util.concurrent.Service> - Interface in co.cask.cdap.data2.transaction.coprocessor
Provides ability to get and release obejcts
CachingTableFactory - Class in co.cask.cdap.messaging.store.cache
A TableFactory with optional caching for MessageTable that it creates.
calculateUpdateInterval(CConfiguration, Configuration) - Static method in class co.cask.cdap.security.TokenSecureStoreRenewer
Calculates the secure token update interval based on the given configurations.
call(DatasetContext) - Method in interface co.cask.cdap.api.TxCallable
Provides a DatasetContext to get instances of Datasets.
call() - Method in interface co.cask.cdap.common.service.Retries.Callable
 
call(Function<UsageDataset, T>) - Method in class co.cask.cdap.data2.registry.BasicUsageRegistry
 
call(Callable<T>) - Method in class co.cask.cdap.etl.common.plugin.Caller
Call a Callable.
call(Callable<T>) - Method in class co.cask.cdap.etl.common.plugin.NoStageLoggingCaller
 
call(Callable<T>) - Method in class co.cask.cdap.etl.common.plugin.StageLoggingCaller
 
call(Tuple2<GROUP_KEY, Iterable<GROUP_VAL>>) - Method in class co.cask.cdap.etl.spark.function.AggregatorAggregateFunction
 
call(GROUP_VAL) - Method in class co.cask.cdap.etl.spark.function.AggregatorGroupByFunction
 
call(RecordInfo<Object>) - Method in class co.cask.cdap.etl.spark.function.AlertPassFilter
 
call(IN) - Method in class co.cask.cdap.etl.spark.function.BatchSinkFunction
 
call(Tuple2<Object, Object>) - Method in class co.cask.cdap.etl.spark.function.BatchSourceFunction
 
call(T) - Method in class co.cask.cdap.etl.spark.function.CountingFunction
 
call(RecordInfo<Object>) - Method in class co.cask.cdap.etl.spark.function.ErrorPassFilter
 
call(ErrorRecord<T>) - Method in class co.cask.cdap.etl.spark.function.ErrorTransformFunction
 
call(T) - Method in interface co.cask.cdap.etl.spark.function.FlatMapFunc
 
call(T) - Method in class co.cask.cdap.etl.spark.function.InitialJoinFunction
 
call(Tuple2<List<JoinElement<T>>, T>) - Method in class co.cask.cdap.etl.spark.function.JoinFlattenFunction
 
call(Tuple2<JOIN_KEY, List<JoinElement<INPUT_RECORD>>>) - Method in class co.cask.cdap.etl.spark.function.JoinMergeFunction
 
call(INPUT_RECORD) - Method in class co.cask.cdap.etl.spark.function.JoinOnFunction
 
call(Tuple2<List<JoinElement<T>>, Optional<T>>) - Method in class co.cask.cdap.etl.spark.function.LeftJoinFlattenFunction
 
call(T) - Method in class co.cask.cdap.etl.spark.function.MultiOutputTransformFunction
 
call(Tuple2<Optional<List<JoinElement<T>>>, Optional<T>>) - Method in class co.cask.cdap.etl.spark.function.OuterJoinFlattenFunction
 
call(RecordInfo<Object>) - Method in class co.cask.cdap.etl.spark.function.OutputPassFilter
 
call(T) - Method in interface co.cask.cdap.etl.spark.function.PairFlatMapFunc
 
call(T) - Method in class co.cask.cdap.etl.spark.function.TransformFunction
 
call(JavaRDD<T>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.ComputeTransformFunction
 
call(JavaRDD<T>) - Method in class co.cask.cdap.etl.spark.streaming.function.CountingTransformFunction
 
call(JavaPairRDD<GROUP_KEY, Iterable<GROUP_VAL>>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.DynamicAggregatorAggregate
 
call(JavaRDD<GROUP_VAL>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.DynamicAggregatorGroupBy
 
call(JavaPairRDD<JOIN_KEY, List<JoinElement<INPUT_RECORD>>>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.DynamicJoinMerge
 
call(JavaRDD<T>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.DynamicJoinOn
 
call(JavaRDD<T>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.DynamicTransform
 
call(JavaRDD<T>) - Method in class co.cask.cdap.etl.spark.streaming.function.preview.LimitingFunction
 
call(JavaRDD<Alert>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.StreamingAlertPublishFunction
 
call(JavaRDD<T>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.StreamingBatchSinkFunction
 
call(JavaRDD<T>, Time) - Method in class co.cask.cdap.etl.spark.streaming.function.StreamingSparkSinkFunction
 
call(T) - Method in class co.cask.cdap.etl.spark.streaming.function.WrapOutputTransformFunction
 
callArtifactPluginMethod(FullHttpRequest, HttpResponder, String, String, String, String, String, String, String) - Method in class co.cask.cdap.gateway.handlers.ArtifactHttpHandler
 
Callback - Interface in co.cask.cdap.api.flow.flowlet
Deprecated.
Callback - Interface in co.cask.cdap.logging.kafka
Callback interface to receive Kafka messages.
Callback - Interface in co.cask.cdap.logging.read
Callback to handle log events.
callbackHandlerClass - Variable in class co.cask.cdap.security.server.JAASLoginService
 
Caller - Class in co.cask.cdap.etl.common.plugin
Calls a callable.
Caller() - Constructor for class co.cask.cdap.etl.common.plugin.Caller
 
CallerClassSecurityManager - Class in co.cask.cdap.internal.lang
A SecurityManager to help get access to classes in the call stack.
CallServiceCommand - Class in co.cask.cdap.cli.command
Call an endpoint of a Service.
CallServiceCommand(ClientConfig, RESTClient, ServiceClient, CLIConfig, FilePathResolver) - Constructor for class co.cask.cdap.cli.command.CallServiceCommand
 
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
callUnchecked(Callable<T>) - Method in class co.cask.cdap.etl.common.plugin.Caller
Call a Callable that does not throw checked exceptions.
callWithInterruptibleRetries(Retries.Callable<V, T>, RetryStrategy, Predicate<Throwable>) - Static method in class co.cask.cdap.common.service.Retries
Executes a Retries.Callable, retrying the call if it throws something retryable.
callWithRetries(Retries.Callable<V, T>, RetryStrategy) - Static method in class co.cask.cdap.common.service.Retries
The same as calling Retries.callWithRetries(Callable, RetryStrategy, Predicate) where a retryable failure is defined as a RetryableException.
callWithRetries(Retries.Callable<V, T>, RetryStrategy, Predicate<Throwable>) - Static method in class co.cask.cdap.common.service.Retries
Executes a Retries.Callable, retrying the call if it throws something retryable.
callWithRetries(Retries.Callable<V, T>) - Method in class co.cask.cdap.data2.transaction.RetryingTransactionSystemClient
 
cancel() - Method in class co.cask.cdap.explore.jdbc.ExploreStatement
 
cancelProvisionTask(ProgramRunId) - Method in class co.cask.cdap.internal.provision.ProvisioningService
Cancel the provision task for the program run.
cancelTimer() - Method in class co.cask.cdap.replication.TableUpdater
 
canCheckStatus() - Method in class co.cask.cdap.common.twill.AbstractDistributedMasterServiceManager
 
canCheckStatus() - Method in class co.cask.cdap.common.twill.AbstractInMemoryMasterServiceManager
 
canCheckStatus() - Method in interface co.cask.cdap.common.twill.MasterServiceManager
Possible to check the status of the service.
canCheckStatus() - Method in class co.cask.cdap.internal.app.runtime.distributed.AppFabricServiceManager
 
canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.DelegatingTransactionSystemClientService
 
canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.DistributedTransactionSystemClientService
 
canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.RetryingLongTransactionSystemClient
 
canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.RetryingTransactionSystemClient
 
canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.TransactionSystemClientAdapter
 
canCommit(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
canCommitOrThrow(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.DelegatingTransactionSystemClientService
 
canCommitOrThrow(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.DistributedTransactionSystemClientService
 
canCommitOrThrow(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.RetryingLongTransactionSystemClient
 
canCommitOrThrow(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.RetryingTransactionSystemClient
 
canCommitOrThrow(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.data2.transaction.TransactionSystemClientAdapter
 
canCommitOrThrow(Transaction, Collection<byte[]>) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
canConsume(ConsumerConfig, Transaction, long, int, byte[], byte[]) - Static method in class co.cask.cdap.data2.transaction.queue.QueueEntryRow
Looks at specific queue entry and determines if consumer with given consumer config and current transaction can consume this entry.
canContainResults() - Method in interface co.cask.cdap.explore.client.ExploreExecutionResult
Some SQL statememt never return results - like CREATE statements - for which this method will return false.
CannotBeCreatedException - Exception in co.cask.cdap.common
Thrown when an element cannot be created.
CannotBeCreatedException(EntityId, Throwable) - Constructor for exception co.cask.cdap.common.CannotBeCreatedException
 
CannotBeDeletedException - Exception in co.cask.cdap.common
Thrown when an element cannot be deleted.
CannotBeDeletedException(EntityId) - Constructor for exception co.cask.cdap.common.CannotBeDeletedException
 
CannotBeDeletedException(EntityId, String) - Constructor for exception co.cask.cdap.common.CannotBeDeletedException
 
CannotBeDeletedException(EntityId, Throwable) - Constructor for exception co.cask.cdap.common.CannotBeDeletedException
 
canScale() - Method in enum co.cask.cdap.cli.ElementType
 
canStart() - Method in enum co.cask.cdap.cli.ElementType
 
canStartMaster() - Method in class co.cask.cdap.master.startup.MasterStartupTool
 
canStop() - Method in enum co.cask.cdap.cli.ElementType
 
canTransitionTo(ProgramRunClusterStatus) - Method in enum co.cask.cdap.proto.ProgramRunClusterStatus
Return whether this state can transition to the specified state.
canTransitionTo(ProgramRunStatus) - Method in enum co.cask.cdap.proto.ProgramRunStatus
Return whether this state can transition to the specified state.
canUpdateSchedules() - Method in class co.cask.cdap.internal.app.deploy.pipeline.AppDeploymentInfo
return true if we can update the schedules of the app
canUpdateSchedules() - Method in class co.cask.cdap.internal.app.deploy.pipeline.ApplicationDeployable
 
canUpdateSchedules() - Method in class co.cask.cdap.proto.artifact.AppRequest
 
canUpgrade() - Method in interface co.cask.cdap.etl.proto.UpgradeableConfig
 
canUpgrade() - Method in class co.cask.cdap.etl.proto.v0.ETLBatchConfig
 
canUpgrade() - Method in class co.cask.cdap.etl.proto.v1.ETLBatchConfig
 
canUpgrade() - Method in class co.cask.cdap.etl.proto.v2.ETLConfig
 
Capabilities - Class in co.cask.cdap.runtime.spi.provisioner
A class to encapsulate all the different capabilities of a Provisioner
Capabilities(Set<String>) - Constructor for class co.cask.cdap.runtime.spi.provisioner.Capabilities
Creates a Capabilities object from the given Set.
capture() - Method in class co.cask.cdap.internal.app.runtime.service.http.AbstractDelegatorContext
 
capture() - Method in interface co.cask.cdap.internal.app.runtime.service.http.DelegatorContext
Capture the current context.
CaseInsensitiveEnumTypeAdapterFactory - Class in co.cask.cdap.common.io
Type adapter that serializes enums in lowercase and deserializes enums in a case insensitive way.
CaseInsensitiveEnumTypeAdapterFactory() - Constructor for class co.cask.cdap.common.io.CaseInsensitiveEnumTypeAdapterFactory
 
CaseInsensitiveEnumTypeAdapterFactory(boolean) - Constructor for class co.cask.cdap.common.io.CaseInsensitiveEnumTypeAdapterFactory
 
CatalogLookupService - Class in co.cask.cdap.examples.purchase
A Catalog Lookup Service implementation that provides ids for products.
CatalogLookupService() - Constructor for class co.cask.cdap.examples.purchase.CatalogLookupService
 
CatalogLookupService.ProductCatalogLookup - Class in co.cask.cdap.examples.purchase
Lookup Handler to serve requests.
catalogs() - Method in class co.cask.cdap.explore.client.AbstractExploreClient
 
catalogs() - Method in interface co.cask.cdap.explore.client.ExploreClient
Retrieves the catalog names available in this database.
catalogs() - Method in class co.cask.cdap.explore.client.MockExploreClient
 
categorizeCommands(Iterable<CommandSet<Command>>, CommandCategory, Predicate<Command>) - Method in class co.cask.cdap.cli.command.system.HelpCommand
 
Categorized - Interface in co.cask.cdap.cli
Implement this to have a category.
cConf - Variable in class co.cask.cdap.common.twill.AbstractDistributedMasterServiceManager
 
cConf - Variable in class co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin
 
cConf - Variable in class co.cask.cdap.data2.dataset2.lib.table.AbstractTableDefinition
 
cConf - Variable in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
 
cConf - Variable in class co.cask.cdap.data2.util.hbase.HBaseVersionSpecificFactory
 
cConf - Variable in class co.cask.cdap.internal.app.runtime.AbstractProgramRunnerWithPlugin
 
cConf - Variable in class co.cask.cdap.internal.app.runtime.distributed.DistributedProgramRunner
 
cConf - Variable in class co.cask.cdap.master.startup.AbstractMasterCheck
 
cConf - Variable in class co.cask.cdap.master.startup.ServiceResourceKeys
 
cConf - Variable in class co.cask.cdap.security.impersonation.AbstractCachedUGIProvider
 
CCONF_KEY - Static variable in class co.cask.cdap.common.conf.Constants.Explore
 
CConfCodec - Class in co.cask.cdap.hive.context
Codec to encode/decode CConfiguration object.
CConfiguration - Class in co.cask.cdap.common.conf
CConfiguration is an extension of the Hadoop Configuration class.
CConfigurationCache - Class in co.cask.cdap.data2.transaction.coprocessor
Thread that refreshes CConfiguration periodically.
CConfigurationCache(CoprocessorEnvironment, String, String, int) - Constructor for class co.cask.cdap.data2.transaction.coprocessor.CConfigurationCache
 
CConfigurationCacheSupplier - Class in co.cask.cdap.data2.transaction.coprocessor
Supplies instances of CConfigurationCache implementations.
CConfigurationCacheSupplier(CoprocessorEnvironment, String, String, int) - Constructor for class co.cask.cdap.data2.transaction.coprocessor.CConfigurationCacheSupplier
 
CConfigurationReader - Interface in co.cask.cdap.data2.util.hbase
This interface abstracts out the details of reading the CConfiguration from HBase using ConfigurationReader.
CConfigurationUtil - Class in co.cask.cdap.common.conf
Utilities for CConfiguration.
CDAP - Static variable in class co.cask.cdap.common.id.Id.Namespace
 
CDAP - Static variable in class co.cask.cdap.proto.id.NamespaceId
 
CDAP_CONF_FILE - Static variable in class co.cask.cdap.internal.app.runtime.ProgramOptionConstants
 
CDAP_HBASE_VERSION - Static variable in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
 
CDAP_HOME - Static variable in class co.cask.cdap.cli.util.FilePathResolver
 
CDAP_NAME - Static variable in class co.cask.cdap.common.conf.Constants.Explore
 
CDAP_SHUTDOWN_TIME_FILENAME - Static variable in class co.cask.cdap.common.conf.Constants.Replication
 
CDAP_SITE - Static variable in exception co.cask.cdap.common.FeatureDisabledException
 
CDAP_SPARK_EXECUTION_SERVICE_URI - Static variable in class co.cask.cdap.app.runtime.spark.SparkRuntimeUtils
 
CDAP_VERSION - Static variable in class co.cask.cdap.common.conf.Constants.Explore
 
CDAP_VERSION - Static variable in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
 
CDAP_VERSION - Static variable in class co.cask.cdap.internal.app.services.ProgramNotificationSubscriberService
 
CDAPConnectionsMXBean - Interface in co.cask.cdap.operations.cdap
MXBean for reporting CDAP Router request statistics.
CDAPEntities - Class in co.cask.cdap.operations.cdap
OperationalStats for reporting CDAP entities.
CDAPEntities() - Constructor for class co.cask.cdap.operations.cdap.CDAPEntities
 
CDAPEntitiesMXBean - Interface in co.cask.cdap.operations.cdap
MXBean for reporting CDAP entities
CDAPInfo - Class in co.cask.cdap.operations.cdap
OperationalStats representing CDAP information.
CDAPInfo() - Constructor for class co.cask.cdap.operations.cdap.CDAPInfo
 
CDAPInfoMXBean - Interface in co.cask.cdap.operations.cdap
MXBean representing CDAP information.
CDAPLoad - Class in co.cask.cdap.operations.cdap
OperationalStats for reporting Load on the CDAP Router in the past hour.
CDAPLoad() - Constructor for class co.cask.cdap.operations.cdap.CDAPLoad
 
CDAPLogAppender - Class in co.cask.cdap.logging.appender.system
Log Appender implementation for CDAP Log framework TODO : Refactor package CDAP-8196
CDAPLogAppender() - Constructor for class co.cask.cdap.logging.appender.system.CDAPLogAppender
 
CDAPTransactions - Class in co.cask.cdap.operations.cdap
OperationalStats for reporting CDAP transaction statistics.
CDAPTransactions() - Constructor for class co.cask.cdap.operations.cdap.CDAPTransactions
 
CDAPTransactionsMXBean - Interface in co.cask.cdap.operations.cdap
MXBean for reporting CDAP transaction stats.
centers(HttpServiceRequest, HttpServiceResponder, Integer) - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp.ResponseCounterHandler
 
centers(HttpServiceRequest, HttpServiceResponder, int) - Method in class co.cask.cdap.examples.sparkkmeans.SparkKMeansApp.CentersServiceHandler
 
centers(HttpServiceRequest, HttpServiceResponder, Integer) - Method in class co.cask.cdap.examples.sparkpagerank.SparkPageRankApp.SparkPageRankServiceHandler
 
centers(HttpServiceRequest, HttpServiceResponder, String) - Method in class co.cask.cdap.examples.sparkstreaming.SpamClassifier.SpamClassifierServiceHandler
 
CentersService() - Constructor for class co.cask.cdap.examples.sparkkmeans.SparkKMeansApp.CentersService
 
CentersServiceHandler() - Constructor for class co.cask.cdap.examples.sparkkmeans.SparkKMeansApp.CentersServiceHandler
 
CERT_VALIDITY - Static variable in class co.cask.cdap.common.conf.Constants.Security.SSL
Validity of the self generated certificate in days
CFG_CDAP_MASTER_KRB_KEYTAB_PATH - Static variable in class co.cask.cdap.common.conf.Constants.Security
Path to the Kerberos keytab file used by CDAP master
CFG_CDAP_MASTER_KRB_PRINCIPAL - Static variable in class co.cask.cdap.common.conf.Constants.Security
Kerberos principal used by CDAP master
CFG_DATA_INMEMORY_PERSISTENCE - Static variable in class co.cask.cdap.common.conf.Constants
defines which persistence engine to use when running all in one JVM.
CFG_DATA_LEVELDB_BLOCKSIZE - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_DATA_LEVELDB_CACHESIZE - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_DATA_LEVELDB_DIR - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_DATA_LEVELDB_FSYNC - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_FILE_BASED_KEYFILE_PATH - Static variable in class co.cask.cdap.common.conf.Constants.Security
 
CFG_HBASE_TABLE_COMPRESSION - Static variable in class co.cask.cdap.data2.util.hbase.HBaseTableUtil
This property is ONLY used in test cases.
CFG_HDFS_LIB_DIR - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_HDFS_NAMESPACE - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_HDFS_USER - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_LOCAL_DATA_DIR - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_LOG_COLLECTION_ROOT - Static variable in class co.cask.cdap.common.conf.Constants
Config for Log Collection.
CFG_REALM - Static variable in class co.cask.cdap.common.conf.Constants.Security
Configuration for security realm.
CFG_SCHEDULER_MAX_THREAD_POOL_SIZE - Static variable in class co.cask.cdap.common.conf.Constants.Scheduler
 
CFG_SCHEDULER_MISFIRE_THRESHOLD_MS - Static variable in class co.cask.cdap.common.conf.Constants.Scheduler
 
CFG_SESSION_TIMEOUT_MILLIS - Static variable in class co.cask.cdap.common.conf.Constants.Zookeeper
 
CFG_TWILL_NO_CONTAINER_TIMEOUT - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_TWILL_ZK_NAMESPACE - Static variable in class co.cask.cdap.common.conf.Constants
 
CFG_TX_JANITOR_ENABLE - Static variable in class co.cask.cdap.common.conf.Constants.Transaction.DataJanitor
Whether or not the TransactionDataJanitor coprocessor should be enabled on tables.
channelInactive(ChannelHandlerContext) - Method in class co.cask.cdap.gateway.router.handlers.AuditLogHandler
 
channelInactive(ChannelHandlerContext) - Method in class co.cask.cdap.gateway.router.handlers.HttpRequestRouter
 
channelInactive(ChannelHandlerContext) - Method in class co.cask.cdap.gateway.router.handlers.OutboundHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class co.cask.cdap.common.http.AuthenticationChannelHandler
Decode the AccessTokenIdentifier passed as a header and set it in a ThreadLocal.
channelRead(ChannelHandlerContext, Object) - Method in class co.cask.cdap.gateway.router.handlers.AuditLogHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class co.cask.cdap.gateway.router.handlers.AuthenticationHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class co.cask.cdap.gateway.router.handlers.HttpRequestRouter
 
channelRead(ChannelHandlerContext, Object) - Method in class co.cask.cdap.gateway.router.handlers.HttpStatusRequestHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class co.cask.cdap.gateway.router.handlers.OutboundHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class co.cask.cdap.gateway.router.handlers.HttpRequestRouter
 
channelReadComplete(ChannelHandlerContext) - Method in class co.cask.cdap.gateway.router.handlers.OutboundHandler
 
Channels - Class in co.cask.cdap.common.http
Util class to help working on netty Channel.
channelWritabilityChanged(ChannelHandlerContext) - Method in class co.cask.cdap.gateway.router.handlers.OutboundHandler
 
CHARSET - Static variable in class co.cask.cdap.format.DelimitedStringsRecordFormat
 
CHARSET - Static variable in class co.cask.cdap.format.TextRecordFormat
 
Check - Class in co.cask.cdap.common.startup
Checks something at start up, throwing an exception if the check failed.
Check() - Constructor for class co.cask.cdap.common.startup.Check
 
check(ProgramSchedule, ConstraintContext) - Method in interface co.cask.cdap.internal.app.runtime.schedule.constraint.CheckableConstraint
Checks a ConstraintContext against a program schedule.
check(ProgramSchedule, ConstraintContext) - Method in class co.cask.cdap.internal.app.runtime.schedule.constraint.ConcurrencyConstraint
 
check(ProgramSchedule, ConstraintContext) - Method in class co.cask.cdap.internal.app.runtime.schedule.constraint.DelayConstraint
 
check(ProgramSchedule, ConstraintContext) - Method in class co.cask.cdap.internal.app.runtime.schedule.constraint.LastRunConstraint
 
check(ProgramSchedule, ConstraintContext) - Method in class co.cask.cdap.internal.app.runtime.schedule.constraint.TimeRangeConstraint
 
check(boolean, String, Object...) - Method in class co.cask.cdap.internal.io.ReflectionReader
 
CHECK_CLASSES - Static variable in class co.cask.cdap.common.conf.Constants.Startup
 
CHECK_PACKAGES - Static variable in class co.cask.cdap.common.conf.Constants.Startup
 
CheckableConstraint - Interface in co.cask.cdap.internal.app.runtime.schedule.constraint
A constraint that is checked before executing a schedule.
checkAvailability(ServiceId) - Method in class co.cask.cdap.client.ServiceClient
Checks whether the Service is active.
checkExploreAndDetermineCache(ImpersonationRequest) - Method in class co.cask.cdap.security.impersonation.AbstractCachedUGIProvider
Checks the ImpersonationRequest is an explore request and determine whether to cache the result or not
checkExploreAndDetermineCache(ImpersonationRequest) - Method in class co.cask.cdap.security.impersonation.DefaultUGIProvider
On master side, we can cache the explore request
checkExploreAndDetermineCache(ImpersonationRequest) - Method in class co.cask.cdap.security.impersonation.RemoteUGIProvider
In remote mode, we should not cache the explore request
checkGetStatus(String) - Method in class co.cask.cdap.common.twill.AbstractDistributedMasterServiceManager
 
checkHiveSupport(CConfiguration) - Static method in class co.cask.cdap.explore.service.ExploreServiceUtils
 
checkHiveSupport(CConfiguration, ClassLoader) - Static method in class co.cask.cdap.explore.service.ExploreServiceUtils
Check that Hive is in the class path - with a right version.
checkInputLength(String[], int) - Method in class co.cask.cdap.cli.util.AbstractCommand
 
checkOutputSpecs(FileSystem, JobConf) - Method in class co.cask.cdap.hive.datasets.DatasetOutputFormat
 
checkOutputSpecs(JobContext) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.AbstractBatchWritableOutputFormat
 
checkOutputSpecs(JobContext) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.output.MultipleOutputsMainOutputWrapper
 
checkOutputSpecs(JobContext) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.partitioned.DynamicPartitioningOutputFormat
 
checkOutputSpecs(JobContext) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.UnsupportedOutputFormat
 
checkPermission(Permission) - Method in class co.cask.cdap.security.ApplicationSecurity
Throws a SecurityException if the requested access, specified by the given permission, is not permitted based on the Permission objects contained in the ApplicationPermissionCollection.
checkpoint() - Method in class co.cask.cdap.data2.transaction.AbstractTransactionContext
 
checkpoint(Transaction) - Method in class co.cask.cdap.data2.transaction.DelegatingTransactionSystemClientService
 
checkpoint(Transaction) - Method in class co.cask.cdap.data2.transaction.DistributedTransactionSystemClientService
 
checkpoint(Transaction) - Method in class co.cask.cdap.data2.transaction.RetryingTransactionSystemClient
 
checkpoint(Transaction) - Method in class co.cask.cdap.data2.transaction.TransactionSystemClientAdapter
 
Checkpoint - Class in co.cask.cdap.logging.meta
Represents a checkpoint that can be saved when reading from Kafka.
Checkpoint(long, long, long) - Constructor for class co.cask.cdap.logging.meta.Checkpoint
 
checkpoint(Transaction) - Method in class co.cask.cdap.test.RevealingTxSystemClient
 
CHECKPOINT_FILESET - Static variable in class co.cask.cdap.datastreams.DataStreamsApp
 
CheckpointManager - Interface in co.cask.cdap.logging.meta
Manages reading/writing of checkpoint information for a topic and partition.
CheckpointManagerFactory - Class in co.cask.cdap.logging.meta
checkpointsDisabled() - Method in class co.cask.cdap.etl.proto.v2.DataStreamsConfig
 
CheckRunner - Class in co.cask.cdap.common.startup
Runs a collection of Checks.
CheckRunner.Builder - Class in co.cask.cdap.common.startup
Builds a CheckRunner.
CheckRunner.Failure - Class in co.cask.cdap.common.startup
Contains the name of a failed check and the exception that caused the failure.
CHECKS_ENABLED - Static variable in class co.cask.cdap.common.conf.Constants.Startup
 
checkSchema(Set<Schema>, Set<Schema>) - Static method in class co.cask.cdap.internal.app.SchemaFinder
Given two schema's checks if there exists compatibility or equality.
CheckServiceAvailabilityCommand - Class in co.cask.cdap.cli.command
Check whether a Service has reached active status.
CheckServiceAvailabilityCommand(ServiceClient, CLIConfig) - Constructor for class co.cask.cdap.cli.command.CheckServiceAvailabilityCommand
 
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
 
childContext(Map<String, String>) - Method in class co.cask.cdap.logging.pipeline.LogProcessorPipelineContext
 
childContext(String, String) - Method in class co.cask.cdap.logging.pipeline.LogProcessorPipelineContext
 
chunk(ByteBuf, HttpResponder) - Method in class co.cask.cdap.common.http.AbstractBodyConsumer
 
claimEntry(byte[], byte[]) - Method in class co.cask.cdap.data2.transaction.queue.AbstractQueueConsumer
 
claimEntry(byte[], byte[]) - Method in class co.cask.cdap.data2.transaction.queue.leveldb.LevelDBQueueConsumer
 
claimFifoEntry(byte[], byte[], byte[]) - Method in class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumer
 
claimFifoEntry(byte[], byte[], byte[]) - Method in class co.cask.cdap.data2.transaction.stream.hbase.HBaseStreamFileConsumer
 
claimFifoEntry(byte[], byte[], byte[]) - Method in class co.cask.cdap.data2.transaction.stream.leveldb.LevelDBStreamFileConsumer
 
CLASS_INFO_TO_CLASS_NAME - Static variable in class co.cask.cdap.common.lang.ClassPathResources
 
ClassDefinition - Class in co.cask.cdap.internal.asm
Class for carrying information of the generated class.
ClassDefinition(byte[], String) - Constructor for class co.cask.cdap.internal.asm.ClassDefinition
 
ClassDefinition(byte[], String, Iterable<? extends Class<?>>) - Constructor for class co.cask.cdap.internal.asm.ClassDefinition
 
Classes - Class in co.cask.cdap.internal.asm
A util class to help on class inspections and manipulations through bytecode.
classes() - Method in class co.cask.cdap.internal.guava.reflect.TypeToken.TypeSet
Returns the types that are classes.
ClassLoaders - Class in co.cask.cdap.common.lang
Utility class for collection of methods for dealing with ClassLoader and loading class.
className - Variable in class co.cask.cdap.proto.artifact.PluginSummary
 
ClassPath - Class in co.cask.cdap.common.internal.guava
Scans the source of a ClassLoader and finds all loadable classes and resources.
ClassPath.ClassInfo - Class in co.cask.cdap.common.internal.guava
Represents a class that can be loaded through ClassPath.ClassInfo.load().
ClassPath.ResourceInfo - Class in co.cask.cdap.common.internal.guava
Represents a class path resource that can be either a class file or any other resource file loadable from the class path.
ClassPathResources - Class in co.cask.cdap.common.lang
Utility methods for ClassPath resources.
ClassRewriter - Interface in co.cask.cdap.common.lang
Represents classes that can rewrite class bytecode.
CLEAN_RECORDS - Static variable in class co.cask.cdap.examples.datacleansing.DataCleansing
 
cleanAll() - Method in class co.cask.cdap.data.stream.StreamFileJanitor
Performs file cleanup for all streams.
cleanTableName(String) - Method in class co.cask.cdap.explore.utils.ExploreTableNaming
 
cleanup() - Method in class co.cask.cdap.data2.transaction.AbstractTransactionContext
Performs cleanup task after a transaction is completed (either committed or aborted).
cleanup(Reducer<Text, IntWritable, byte[], byte[]>.Context) - Method in class co.cask.cdap.examples.wikipedia.TopNMapReduce.TopNReducer
 
cleanUp() - Method in class co.cask.cdap.internal.app.runtime.service.http.AbstractDelegatorContext
Cleanup user service handler instances that are not longer in use.
cleanup() - Method in class co.cask.cdap.report.main.RunMetaFileManager
 
CLEANUP_JOB_SCHEDULE_SECS - Static variable in class co.cask.cdap.common.conf.Constants.Explore
 
cleanupJob(JobContext) - Method in class co.cask.cdap.internal.app.runtime.batch.dataset.partitioned.DynamicPartitioningOutputCommitter
 
clear() - Method in class co.cask.cdap.common.conf.Configuration
Clears all keys from the configuration.
clear() - Method in class co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueue
 
clear(DataSetManager<Table>) - Static method in class co.cask.cdap.etl.mock.batch.MockSink
Clear any records written to this sink.
clear() - Method in class co.cask.cdap.etl.mock.common.MockEmitter
 
clear() - Method in class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter
 
clear(Object) - Method in class co.cask.cdap.hive.objectinspector.StandardMapObjectInspector
 
clear(NamespaceId) - Method in interface co.cask.cdap.internal.app.runtime.artifact.ArtifactRepository
Clear all artifacts in the given namespace.
clear(NamespaceId) - Method in class co.cask.cdap.internal.app.runtime.artifact.AuthorizationArtifactRepository
 
clear(NamespaceId) - Method in class co.cask.cdap.internal.app.runtime.artifact.DefaultArtifactRepository
 
clear() - Method in class co.cask.cdap.internal.profile.ProfileService
Delete all profiles.
clear() - Method in class co.cask.cdap.messaging.cache.MessageCache
Clears the cache.
clear() - Method in class co.cask.cdap.messaging.store.cache.DefaultMessageTableCacheProvider
 
clear() - Method in interface co.cask.cdap.messaging.store.cache.MessageTableCacheProvider
Resets all MessageCache created by this cache provider.
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
 
clearAllFilters() - Method in class co.cask.cdap.logging.appender.ForwardingAppender
 
clearAllForFlow(FlowId) - Method in class co.cask.cdap.data2.transaction.queue.hbase.HBaseQueueAdmin
 
clearAllForFlow(FlowId) - Method in class co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueueAdmin
 
clearAllForFlow(FlowId) - Method in class co.cask.cdap.data2.transaction.queue.leveldb.LevelDBQueueAdmin
 
clearAllForFlow(FlowId) - Method in interface co.cask.cdap.data2.transaction.queue.QueueAdmin
Clears all queues for a flow, for example if the flow is upgraded and old.
clearBatch() - Method in class co.cask.cdap.explore.jdbc.ExploreStatement
 
clearCache() - Method in class co.cask.cdap.security.authorization.RemoteAuthorizationEnforcer
 
clearDeletedFlow(Impersonator, QueueAdmin, StreamConsumerFactory, ProgramId, FlowSpecification) - Static method in class co.cask.cdap.internal.app.runtime.flow.FlowUtils
Drop all queues and stream states of a deleted flow
clearMetrics() - Method in class co.cask.cdap.etl.mock.common.MockMetrics
 
clearParameters() - Method in class co.cask.cdap.explore.jdbc.ExplorePreparedStatement
 
clearRunnables() - Method in class co.cask.cdap.internal.app.runtime.distributed.ProgramLaunchConfig
 
clearTables() - Method in class co.cask.cdap.data2.dataset2.lib.table.leveldb.LevelDBTableService
only use in unit test since the singleton may be reused for multiple tests.
clearWarnings() - Method in class co.cask.cdap.explore.jdbc.ExploreConnection
 
clearWarnings() - Method in class co.cask.cdap.explore.jdbc.ExploreStatement
 
ClicksAndViews - Class in co.cask.cdap.examples.clicksandviews
Clicks and Views sample Application.
ClicksAndViews() - Constructor for class co.cask.cdap.examples.clicksandviews.ClicksAndViews
 
ClicksAndViewsMapReduce - Class in co.cask.cdap.examples.clicksandviews
A MapReduce program that reads from a CLICKS stream and a VIEWS stream.
ClicksAndViewsMapReduce() - Constructor for class co.cask.cdap.examples.clicksandviews.ClicksAndViewsMapReduce
 
ClicksAndViewsMapReduce.ImpressionKeyingMapper - Class in co.cask.cdap.examples.clicksandviews
A Mapper which tags all of the records with the source that it is coming from.
ClicksAndViewsMapReduce.JoiningReducer - Class in co.cask.cdap.examples.clicksandviews
Reducer class which looks at all the records for the viewId.
CLIConfig - Class in co.cask.cdap.cli
Configuration for the CDAP CLI.
CLIConfig(ClientConfig, PrintStream, TableRenderer) - Constructor for class co.cask.cdap.cli.CLIConfig
 
CLIConfig() - Constructor for class co.cask.cdap.cli.CLIConfig
 
cliConfig - Variable in class co.cask.cdap.cli.util.AbstractAuthCommand
 
CLIConfig.ConnectionChangeListener - Interface in co.cask.cdap.cli
Listener for hostname changes.
CLIConnectionConfig - Class in co.cask.cdap.cli
ConnectionConfig that stores a username when available.
CLIConnectionConfig(ConnectionConfig, NamespaceId, String) - Constructor for class co.cask.cdap.cli.CLIConnectionConfig
 
CLIConnectionConfig(CLIConnectionConfig, NamespaceId) - Constructor for class co.cask.cdap.cli.CLIConnectionConfig
 
CLIConnectionConfig(NamespaceId, String, int, boolean) - Constructor for class co.cask.cdap.cli.CLIConnectionConfig
 
CLIENT_BOSS_THREADS - Static variable in class co.cask.cdap.common.conf.Constants.Router
 
CLIENT_KEYSTORE - Static variable in class co.cask.cdap.common.conf.Constants.RuntimeMonitor
 
CLIENT_RETRIES - Static variable in class co.cask.cdap.common.conf.Constants.HBase
 
CLIENT_STARTUP_TIMEOUT_MILLIS - Static variable in class co.cask.cdap.common.conf.Constants.Zookeeper
 
CLIENT_WORKER_THREADS - Static variable in class co.cask.cdap.common.conf.Constants.Router
 
ClientCConfigurationReader - Class in co.cask.cdap.data2.util.hbase
This class implements the client-side reading of the CConfiguration from HBase.
ClientCConfigurationReader(Configuration, CConfiguration) - Constructor for class co.cask.cdap.data2.util.hbase.ClientCConfigurationReader
Constructor from an HBase and CDAP configuration.
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.
ClientLocalizationContext - Interface in co.cask.cdap.api
Context that adds the capability to localize resources in programs.
ClientMessagingService - Class in co.cask.cdap.messaging.client
The client implementation of MessagingService.
ClientMessagingService(DiscoveryServiceClient) - Constructor for class co.cask.cdap.messaging.client.ClientMessagingService
 
clientResources - Variable in class co.cask.cdap.etl.proto.v2.ETLConfig.Builder
 
clientResources - Variable in class co.cask.cdap.etl.spec.PipelineSpec.Builder
 
ClientUpgradeContext - Class in co.cask.cdap.etl.tool.config
Uses an ArtifactClient to get the artifact for a specific plugin.
ClientUpgradeContext(NamespaceClient, ArtifactClient, String, String) - Constructor for class co.cask.cdap.etl.tool.config.ClientUpgradeContext
 
ClientVersion - Class in co.cask.cdap.proto
Represents the client version.
ClientVersion(String, String) - Constructor for class co.cask.cdap.proto.ClientVersion
 
ClientVersions - Class in co.cask.cdap.data.runtime.main
Provides client versions of infrastructure components.
ClientVersions() - Constructor for class co.cask.cdap.data.runtime.main.ClientVersions
 
CLIMain - Class in co.cask.cdap.cli
Main class for the CDAP CLI.
CLIMain(LaunchOptions, CLIConfig) - Constructor for class co.cask.cdap.cli.CLIMain
 
CLIMainArgs - Class in co.cask.cdap.cli
Represents the command line arguments for CLIMain.
CLIMainArgs(String[], String[]) - Constructor for class co.cask.cdap.cli.CLIMainArgs
 
cloneWritableInto(Writable, Writable) - Static method in class org.apache.hadoop.util.ReflectionUtils
Deprecated.
close() - Method in class co.cask.cdap.api.artifact.CloseableClassLoader
 
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 interface co.cask.cdap.api.spark.service.SparkHttpServicePluginContext
Close and release resources owned by this object.
close() - Method in class co.cask.cdap.app.program.DefaultProgram
 
close() - Method in class co.cask.cdap.app.runtime.spark.classloader.SparkRunnerClassLoader
 
close() - Method in class co.cask.cdap.app.runtime.spark.dynamic.SparkCompilerCleanupManager
Performs cleanup for all SparkCompiler managed by this manager.
close() - Method in class co.cask.cdap.app.runtime.spark.service.DefaultSparkHttpServicePluginContext
 
close() - Method in class co.cask.cdap.app.runtime.spark.SparkProgramRunner
Closes the ClassLoader of this SparkProgramRunner.
close() - Method in class co.cask.cdap.app.stream.DefaultStreamBatchWriter
 
close() - Method in class co.cask.cdap.common.conf.AbstractPropertyStore
 
close() - Method in class co.cask.cdap.common.lang.jar.UnpackedJarDirIterator
 
close() - Method in class co.cask.cdap.common.logging.RedirectedPrintStream
 
close() - Method in class co.cask.cdap.common.ssh.DefaultSSHSession
 
close() - Method in class co.cask.cdap.data.dataset.SystemDatasetInstantiator
 
close() - Method in class co.cask.cdap.data.file.LiveFileReader
 
close() - Method in class co.cask.cdap.data.file.PartitionedFileWriter
 
close() - Method in class co.cask.cdap.data.stream.MultiLiveStreamFileReader
 
close(StreamId) - Method in class co.cask.cdap.data.stream.service.ConcurrentStreamWriter
 
close() - Method in class co.cask.cdap.data.stream.service.ConcurrentStreamWriter
 
close() - Method in class co.cask.cdap.data.stream.service.upload.AsyncChannelBufferInputStream
 
close() - Method in class co.cask.cdap.data.stream.StreamDataFileReader
 
close() - Method in class co.cask.cdap.data.stream.StreamDataFileWriter
 
close() - Method in class co.cask.cdap.data2.datafabric.dataset.type.ConstantClassLoaderProvider
 
close() - Method in class co.cask.cdap.data2.datafabric.dataset.type.DirectoryClassLoaderProvider
 
close() - Method in class co.cask.cdap.data2.dataset2.DynamicDatasetCache
Close and dismiss all datasets that were obtained through this factory, and destroy the factory.
close() - Method in class co.cask.cdap.data2.dataset2.lib.cube.CubeDataset
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.cube.DefaultCube
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.external.ExternalDataset
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.external.ExternalDatasetAdmin
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.file.FileSetAdmin
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.file.FileSetDataset
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDataset
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.AbstractTable.TableScanner
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.BufferingTable
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.hbase.CombinedHBaseMetricsTable
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.hbase.CombinedMetricsScanner
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.hbase.HBaseMetricsTable
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.hbase.HBaseScanner
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.hbase.HBaseTable
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.inmemory.InMemoryMetricsTable
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.inmemory.InMemoryScanner
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.inmemory.InMemoryTableAdmin
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.leveldb.LevelDBMetricsTable
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.leveldb.LevelDBTableAdmin
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.leveldb.LevelDBTableService
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.table.ObjectStoreDataset.ObjectScanner
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.timeseries.EntityTable
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.timeseries.FactScanner
 
close() - Method in class co.cask.cdap.data2.dataset2.lib.timeseries.FactTable
 
close() - Method in class co.cask.cdap.data2.dataset2.MultiThreadDatasetCache
 
close() - Method in class co.cask.cdap.data2.dataset2.SingleThreadDatasetCache
 
close() - Method in class co.cask.cdap.data2.transaction.queue.AbstractQueueProducer
 
close() - Method in class co.cask.cdap.data2.transaction.queue.hbase.HBaseQueueProducer
 
close() - Method in class co.cask.cdap.data2.transaction.queue.hbase.SaltedHBaseQueueStrategy
 
close() - Method in class co.cask.cdap.data2.transaction.queue.hbase.ShardedHBaseQueueStrategy
 
close() - Method in class co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueueConsumer
 
close() - Method in class co.cask.cdap.data2.transaction.queue.leveldb.LevelDBQueueConsumer
 
close() - Method in class co.cask.cdap.data2.transaction.queue.NoopQueueConfigurer
 
close() - Method in interface co.cask.cdap.data2.transaction.queue.QueueScanner
 
close() - Method in class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumer
 
close() - Method in class co.cask.cdap.data2.transaction.stream.ForwardingStreamConsumer
 
close() - Method in class co.cask.cdap.data2.transaction.stream.hbase.HBaseStreamConsumerStateStore
 
close() - Method in class co.cask.cdap.data2.transaction.stream.inmemory.InMemoryStreamConsumerStateStore
 
close() - Method in class co.cask.cdap.data2.transaction.stream.leveldb.LevelDBStreamConsumerStateStore
 
close() - Method in class co.cask.cdap.data2.transaction.stream.QueueToStreamConsumer
 
close() - Method in class co.cask.cdap.data2.util.hbase.DefaultHBaseDDLExecutor
 
close() - Method in class co.cask.cdap.etl.batch.connector.AlertReader
 
close() - Method in class co.cask.cdap.explore.client.AbstractExploreClient
 
close() - Method in class co.cask.cdap.explore.client.MockExploreClient
 
close() - Method in class co.cask.cdap.explore.jdbc.ExploreConnection
 
close() - Method in class co.cask.cdap.explore.jdbc.ExploreResultSet
 
close() - Method in class co.cask.cdap.explore.jdbc.ExploreStatement
 
close() - Method in class co.cask.cdap.explore.jdbc.StaticEmptyExploreResultSet
 
c