A C D E F G H I J L M N P R S T U W

A

addDatasetModule(String, Class<? extends DatasetModule>) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

addDatasetType(Class<? extends Dataset>) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

addStream(Stream) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

addStream(String) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

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

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

apply(ConditionContext) - Method in class co.cask.cdap.etl.mock.condition.MockCondition

asMap() - Method in class co.cask.cdap.etl.mock.common.MockArguments

C

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

clearMetrics() - Method in class co.cask.cdap.etl.mock.common.MockMetrics

co.cask.cdap.etl.mock.action - package co.cask.cdap.etl.mock.action

co.cask.cdap.etl.mock.alert - package co.cask.cdap.etl.mock.alert

co.cask.cdap.etl.mock.batch - package co.cask.cdap.etl.mock.batch

co.cask.cdap.etl.mock.batch.aggregator - package co.cask.cdap.etl.mock.batch.aggregator

co.cask.cdap.etl.mock.batch.joiner - package co.cask.cdap.etl.mock.batch.joiner

co.cask.cdap.etl.mock.common - package co.cask.cdap.etl.mock.common

co.cask.cdap.etl.mock.condition - package co.cask.cdap.etl.mock.condition

co.cask.cdap.etl.mock.spark - package co.cask.cdap.etl.mock.spark

co.cask.cdap.etl.mock.spark.compute - package co.cask.cdap.etl.mock.spark.compute

co.cask.cdap.etl.mock.spark.streaming - package co.cask.cdap.etl.mock.spark.streaming

co.cask.cdap.etl.mock.test - package co.cask.cdap.etl.mock.test

co.cask.cdap.etl.mock.transform - package co.cask.cdap.etl.mock.transform

Conf() - Constructor for class co.cask.cdap.etl.mock.action.FileMoveAction.Conf

Conf() - Constructor for class co.cask.cdap.etl.mock.alert.NullAlertTransform.Conf

Conf() - Constructor for class co.cask.cdap.etl.mock.alert.TMSAlertPublisher.Conf

Conf() - Constructor for class co.cask.cdap.etl.mock.batch.FileDeleteAction.Conf

Conf() - Constructor for class co.cask.cdap.etl.mock.batch.NodeStatesAction.Conf

Conf() - Constructor for class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute.Conf

Conf() - Constructor for class co.cask.cdap.etl.mock.spark.streaming.MockSource.Conf

Conf() - Constructor for class co.cask.cdap.etl.mock.spark.Window.Conf

Config() - Constructor for class co.cask.cdap.etl.mock.action.MockAction.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.aggregator.GroupFilterAggregator.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.FilterTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger.Config

Config(String, String) - Constructor for class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.joiner.MockJoiner.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.LookupTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockExternalSink.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockExternalSource.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockSink.Config

Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockSource.Config

Config() - Constructor for class co.cask.cdap.etl.mock.condition.MockCondition.Config

Config() - Constructor for class co.cask.cdap.etl.mock.spark.streaming.MockSink.Config

Config() - Constructor for class co.cask.cdap.etl.mock.transform.DropNullTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.transform.FilterErrorTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.transform.IntValueFilterTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.transform.NullFieldSplitterTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.transform.SleepTransform.Config

Config() - Constructor for class co.cask.cdap.etl.mock.transform.StringValueFilterTransform.Config

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.action.FileMoveAction

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.action.MockAction

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.alert.NullAlertTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.aggregator.GroupFilterAggregator

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.FileDeleteAction

configurePipeline(MultiInputPipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

configurePipeline(MultiInputPipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.MockSink

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.MockSource

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.batch.NodeStatesAction

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.condition.MockCondition

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.spark.streaming.MockSource

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.AllErrorTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.DoubleTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.DropNullTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.ExceptionTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.FilterErrorTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.FlattenErrorTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.IdentityTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.IntValueFilterTransform

configurePipeline(MultiOutputPipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.NullFieldSplitterTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.SleepTransform

configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.StringValueFilterTransform

count(String, int) - Method in class co.cask.cdap.etl.mock.common.MockMetrics

count(String, int) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

count(String, int) - Method in class co.cask.cdap.etl.mock.common.NoopMetrics

createDataset(String, String, DatasetProperties) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

createDataset(String, String) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

createDataset(String, Class<? extends Dataset>, DatasetProperties) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

createDataset(String, Class<? extends Dataset>) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

D

deleteSecureData(String, String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

DoubleTransform - Class in co.cask.cdap.etl.mock.transform

Transform that doubles every record it receives.

DoubleTransform() - Constructor for class co.cask.cdap.etl.mock.transform.DoubleTransform

DropNullTransform - Class in co.cask.cdap.etl.mock.transform

Transform that drops a configurable field from all input records if it has a null value.

DropNullTransform(DropNullTransform.Config) - Constructor for class co.cask.cdap.etl.mock.transform.DropNullTransform

DropNullTransform.Config - Class in co.cask.cdap.etl.mock.transform

Config for the transform.

DupeFlagger - Class in co.cask.cdap.etl.mock.batch.joiner

Plugin that takes exactly 2 inputs and flags records in one input if they also appear in the other.

DupeFlagger(DupeFlagger.Config) - Constructor for class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

DupeFlagger.Config - Class in co.cask.cdap.etl.mock.batch.joiner

Config for except plugin

E

emit(T) - Method in class co.cask.cdap.etl.mock.common.MockEmitter

emit(String, Object) - Method in class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter

emitAlert(Map<String, String>) - Method in class co.cask.cdap.etl.mock.common.MockEmitter

emitAlert(Map<String, String>) - Method in class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter

emitError(InvalidEntry<T>) - Method in class co.cask.cdap.etl.mock.common.MockEmitter

emitError(InvalidEntry<E>) - Method in class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter

ExceptionTransform - Class in co.cask.cdap.etl.mock.transform

An transform that throws exception if expected condition is not met.

ExceptionTransform() - Constructor for class co.cask.cdap.etl.mock.transform.ExceptionTransform

execute(TxRunnable) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

execute(int, TxRunnable) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

F

FieldCountAggregator - Class in co.cask.cdap.etl.mock.batch.aggregator

Groups on a specific field and adds count field.

FieldCountAggregator(FieldCountAggregator.Config) - Constructor for class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator

FieldCountAggregator.Config - Class in co.cask.cdap.etl.mock.batch.aggregator

Conf for the aggregator.

FieldsPrefixTransform - Class in co.cask.cdap.etl.mock.transform

Transform which adds prefix to all the fields of structured record for testing multi input schemas

FieldsPrefixTransform(FieldsPrefixTransform.Config) - Constructor for class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform

FieldsPrefixTransform.Config - Class in co.cask.cdap.etl.mock.transform

Config for join plugin

FileDeleteAction - Class in co.cask.cdap.etl.mock.batch

Post run action that deletes files in a FileSet that match a configurable regex.

FileDeleteAction(FileDeleteAction.Conf) - Constructor for class co.cask.cdap.etl.mock.batch.FileDeleteAction

FileDeleteAction.Conf - Class in co.cask.cdap.etl.mock.batch

Conf for the token writer.

FileMoveAction - Class in co.cask.cdap.etl.mock.action

Action that moves files that match some regex.

FileMoveAction(FileMoveAction.Conf) - Constructor for class co.cask.cdap.etl.mock.action.FileMoveAction

FileMoveAction.Conf - Class in co.cask.cdap.etl.mock.action

Conf for the token writer.

FilterErrorTransform - Class in co.cask.cdap.etl.mock.transform

Filters out errors that have a specific error code

FilterErrorTransform() - Constructor for class co.cask.cdap.etl.mock.transform.FilterErrorTransform

FilterErrorTransform.Config - Class in co.cask.cdap.etl.mock.transform

Config for the error transform.

FilterTransform - Class in co.cask.cdap.etl.mock.batch

Transform which filters structured records

FilterTransform(FilterTransform.Config) - Constructor for class co.cask.cdap.etl.mock.batch.FilterTransform

FilterTransform.Config - Class in co.cask.cdap.etl.mock.batch

Config for FilterTransform

FlattenErrorTransform - Class in co.cask.cdap.etl.mock.transform

Adds the error code and error message to each record, then emits it.

FlattenErrorTransform() - Constructor for class co.cask.cdap.etl.mock.transform.FlattenErrorTransform

G

gauge(String, long) - Method in class co.cask.cdap.etl.mock.common.MockMetrics

gauge(String, long) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

gauge(String, long) - Method in class co.cask.cdap.etl.mock.common.NoopMetrics

get(String) - Method in class co.cask.cdap.etl.mock.common.MockArguments

getAlerts() - Method in class co.cask.cdap.etl.mock.common.MockEmitter

getAlerts() - Method in class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter

getArguments() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getArguments() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getCount(String) - Method in class co.cask.cdap.etl.mock.common.MockMetrics

getCount(String) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

getEmitted() - Method in class co.cask.cdap.etl.mock.common.MockEmitter

getEmitted() - Method in class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter

getEngine() - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

getErrors() - Method in class co.cask.cdap.etl.mock.common.MockEmitter

getErrors() - Method in class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter

getGauge(String) - Method in class co.cask.cdap.etl.mock.common.MockMetrics

getGauge(String) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

getInputSchema() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getInputSchema() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getInputSchemas() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getInputSchemas() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getJoinConfig() - Method in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

getJoinConfig() - Method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

getLogicalStartTime() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getLogicalStartTime() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getMetrics() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getMetrics() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getMockMetrics() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getNamespace() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getNamespace() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getOutputPortSchemas() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getOutputPortSchemas() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getOutputSchema() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getOutputSchema() - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

getOutputSchema() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getPipelineCount(String) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

getPipelineGauge(String) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

getPipelineName() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getPipelineName() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getPlugin(String, String, String, String, String, String) - Static method in class co.cask.cdap.etl.mock.action.MockAction

getPlugin(String, String, String, String) - Static method in class co.cask.cdap.etl.mock.action.MockAction

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.alert.NullAlertTransform

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.alert.TMSAlertPublisher

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.batch.aggregator.GroupFilterAggregator

getPlugin() - Static method in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.batch.FilterTransform

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

getPlugin(String, String, String) - Static method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

getPlugin(String, String, String) - Static method in class co.cask.cdap.etl.mock.batch.LookupTransform

getPlugin(String, String, String) - Static method in class co.cask.cdap.etl.mock.batch.MockExternalSink

Returns ETLPlugin for MockExternalSink.

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.batch.MockExternalSource

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.batch.MockSink

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.batch.MockSource

Get the plugin config to be used in a pipeline config.

getPlugin(String, Schema) - Static method in class co.cask.cdap.etl.mock.batch.MockSource

Get the plugin config to be used in a pipeline config.

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.batch.NodeStatesAction

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.condition.MockCondition

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.condition.MockCondition

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.spark.streaming.MockSink

Get ETL plugin

getPlugin(Schema, List<StructuredRecord>) - Static method in class co.cask.cdap.etl.mock.spark.streaming.MockSource

getPlugin(Schema, List<StructuredRecord>, Long) - Static method in class co.cask.cdap.etl.mock.spark.streaming.MockSource

getPlugin(long, long) - Static method in class co.cask.cdap.etl.mock.spark.Window

getPlugin() - Static method in class co.cask.cdap.etl.mock.transform.AllErrorTransform

getPlugin() - Static method in class co.cask.cdap.etl.mock.transform.DoubleTransform

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.transform.DropNullTransform

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.transform.ExceptionTransform

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform

getPlugin(int) - Static method in class co.cask.cdap.etl.mock.transform.FilterErrorTransform

getPlugin() - Static method in class co.cask.cdap.etl.mock.transform.FlattenErrorTransform

getPlugin() - Static method in class co.cask.cdap.etl.mock.transform.IdentityTransform

getPlugin(String, int) - Static method in class co.cask.cdap.etl.mock.transform.IntValueFilterTransform

getPlugin(String) - Static method in class co.cask.cdap.etl.mock.transform.NullFieldSplitterTransform

getPlugin(long) - Static method in class co.cask.cdap.etl.mock.transform.SleepTransform

getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.transform.StringValueFilterTransform

getPluginProperties() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getPluginProperties(String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getPluginProperties() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getPluginProperties(String) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getSecureData(String, String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getServiceURL(String, String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getServiceURL(String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getServiceURL(String, String) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getServiceURL(String) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getSlideInterval() - Method in class co.cask.cdap.etl.mock.spark.Window

getStageConfigurer() - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

getStageName() - Method in class co.cask.cdap.etl.mock.action.MockActionContext

getStageName() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

getStream(StreamingContext) - Method in class co.cask.cdap.etl.mock.spark.streaming.MockSource

getValues(Set<String>, DataSetManager<KeyValueTable>) - Static method in class co.cask.cdap.etl.mock.spark.streaming.MockSink

Get the values associated with the specified keys.

getWidth() - Method in class co.cask.cdap.etl.mock.spark.Window

groupBy(StructuredRecord, Emitter<Object>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator

groupBy(StructuredRecord, Emitter<String>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.GroupFilterAggregator

groupBy(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

GroupFilterAggregator - Class in co.cask.cdap.etl.mock.batch.aggregator

Aggregator that emits errors for all records that have a specific group key.

GroupFilterAggregator() - Constructor for class co.cask.cdap.etl.mock.batch.aggregator.GroupFilterAggregator

GroupFilterAggregator.Config - Class in co.cask.cdap.etl.mock.batch.aggregator

The plugin config

H

has(String) - Method in class co.cask.cdap.etl.mock.common.MockArguments

HydratorTestBase - Class in co.cask.cdap.etl.mock.test

Performs common setup logic

HydratorTestBase() - Constructor for class co.cask.cdap.etl.mock.test.HydratorTestBase

I

IdentityAggregator - Class in co.cask.cdap.etl.mock.batch.aggregator

Identity aggregation for testing.

IdentityAggregator() - Constructor for class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

IdentityTransform - Class in co.cask.cdap.etl.mock.transform

Identity transform for testing.

IdentityTransform() - Constructor for class co.cask.cdap.etl.mock.transform.IdentityTransform

initialize(AlertPublisherContext) - Method in class co.cask.cdap.etl.mock.alert.TMSAlertPublisher

initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator

initialize(TransformContext) - Method in class co.cask.cdap.etl.mock.batch.FilterTransform

initialize(BatchJoinerRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

initialize(TransformContext) - Method in class co.cask.cdap.etl.mock.batch.LookupTransform

initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.MockSink

initialize(BatchRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.MockSource

initialize(SparkExecutionPluginContext) - Method in class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute

initialize(TransformContext) - Method in class co.cask.cdap.etl.mock.transform.ExceptionTransform

initialize(TransformContext) - Method in class co.cask.cdap.etl.mock.transform.FlattenErrorTransform

initialize(TransformContext) - Method in class co.cask.cdap.etl.mock.transform.IdentityTransform

initialize(TransformContext) - Method in class co.cask.cdap.etl.mock.transform.StringValueFilterTransform

INSTANCE - Static variable in class co.cask.cdap.etl.mock.common.NoopMetrics

IntValueFilterTransform - Class in co.cask.cdap.etl.mock.transform

Transform that filters out records whose configured field is a configured value.

IntValueFilterTransform(IntValueFilterTransform.Config) - Constructor for class co.cask.cdap.etl.mock.transform.IntValueFilterTransform

IntValueFilterTransform.Config - Class in co.cask.cdap.etl.mock.transform

Config for the transform.

iterator() - Method in class co.cask.cdap.etl.mock.common.MockArguments

J

joinOn(String, StructuredRecord) - Method in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

joinOn(String, StructuredRecord) - Method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

L

listSecureData(String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

loadPluginClass(String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

loadPluginClass(String) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

LookupTransform<T> - Class in co.cask.cdap.etl.mock.batch

Transform used to test lookup functionality.

LookupTransform(LookupTransform.Config) - Constructor for class co.cask.cdap.etl.mock.batch.LookupTransform

LookupTransform.Config - Class in co.cask.cdap.etl.mock.batch

Config for the source.

M

merge(StructuredRecord, Iterable<JoinElement<StructuredRecord>>) - Method in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

merge(StructuredRecord, Iterable<JoinElement<StructuredRecord>>) - Method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

MockAction - Class in co.cask.cdap.etl.mock.action

Mock sink that writes records to a Table and has a utility method for getting all records written.

MockAction(MockAction.Config) - Constructor for class co.cask.cdap.etl.mock.action.MockAction

MockAction.Config - Class in co.cask.cdap.etl.mock.action

Config for the MockAction

MockActionContext - Class in co.cask.cdap.etl.mock.action

Mock ActionContext for CustomAction tests.

MockActionContext() - Constructor for class co.cask.cdap.etl.mock.action.MockActionContext

MockArguments - Class in co.cask.cdap.etl.mock.common

Mock version of SettableArguments.

MockArguments() - Constructor for class co.cask.cdap.etl.mock.common.MockArguments

MockArguments(Map<String, String>) - Constructor for class co.cask.cdap.etl.mock.common.MockArguments

MockCondition - Class in co.cask.cdap.etl.mock.condition

Mock implementation of Condition in the pipeline.

MockCondition(MockCondition.Config) - Constructor for class co.cask.cdap.etl.mock.condition.MockCondition

MockCondition.Config - Class in co.cask.cdap.etl.mock.condition

Config for the sink.

MockEmitter<T> - Class in co.cask.cdap.etl.mock.common

Mock implementation of Emitter for unit tests.

MockEmitter() - Constructor for class co.cask.cdap.etl.mock.common.MockEmitter

MockExternalSink - Class in co.cask.cdap.etl.mock.batch

Mock sink that writes records to a Table and has a utility method for getting all records written.

MockExternalSink(MockExternalSink.Config) - Constructor for class co.cask.cdap.etl.mock.batch.MockExternalSink

MockExternalSink.Config - Class in co.cask.cdap.etl.mock.batch

Config for the sink.

MockExternalSource - Class in co.cask.cdap.etl.mock.batch

Mock source that can be used to write a list of records in a Table and reads them out in a pipeline run.

MockExternalSource(MockExternalSource.Config) - Constructor for class co.cask.cdap.etl.mock.batch.MockExternalSource

MockExternalSource.Config - Class in co.cask.cdap.etl.mock.batch

Config for the source.

MockJoiner - Class in co.cask.cdap.etl.mock.batch.joiner

Join plugin to perform joins on structured records

MockJoiner(MockJoiner.Config) - Constructor for class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

MockJoiner.Config - Class in co.cask.cdap.etl.mock.batch.joiner

Config for join plugin

MockLookupProvider - Class in co.cask.cdap.etl.mock.common

Mock implementation of LookupProvider used for testing.

MockLookupProvider(Lookup) - Constructor for class co.cask.cdap.etl.mock.common.MockLookupProvider

MockMetrics - Class in co.cask.cdap.etl.mock.common

Mock metrics for unit tests.

MockMetrics() - Constructor for class co.cask.cdap.etl.mock.common.MockMetrics

MockMultiOutputEmitter<E> - Class in co.cask.cdap.etl.mock.common

Mock implementation of MultiOutputEmitter for unit tests.

MockMultiOutputEmitter() - Constructor for class co.cask.cdap.etl.mock.common.MockMultiOutputEmitter

MockPipelineConfigurer - Class in co.cask.cdap.etl.mock.common

Mock test configurer used to test configure pipeline's validation of input schema and setting of output shcema.

MockPipelineConfigurer(Schema, Map<String, Object>) - Constructor for class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

Creates a mock pipeline configurer with a map of plugins to use for validation.

MockPipelineConfigurer(Schema) - Constructor for class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

MockRuntimeDatasetSink - Class in co.cask.cdap.etl.mock.batch

Mock sink that tests creation of datasets during runtime based on if dataset exists or not.

MockRuntimeDatasetSink(MockRuntimeDatasetSink.Config) - Constructor for class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

MockRuntimeDatasetSink.Config - Class in co.cask.cdap.etl.mock.batch

Config for the sink.

MockRuntimeDatasetSource - Class in co.cask.cdap.etl.mock.batch

Mock source that tests creation of datasets during runtime based on if dataset exists or not.

MockRuntimeDatasetSource(MockRuntimeDatasetSource.Config) - Constructor for class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

MockRuntimeDatasetSource.Config - Class in co.cask.cdap.etl.mock.batch

Config for the source.

MockSink - Class in co.cask.cdap.etl.mock.batch

Mock sink that writes records to a Table and has a utility method for getting all records written.

MockSink(MockSink.Config) - Constructor for class co.cask.cdap.etl.mock.batch.MockSink

MockSink - Class in co.cask.cdap.etl.mock.spark.streaming

Mock Sink for Spark streaming test.

MockSink(MockSink.Config) - Constructor for class co.cask.cdap.etl.mock.spark.streaming.MockSink

MockSink.Config - Class in co.cask.cdap.etl.mock.batch

Config for the sink.

MockSink.Config - Class in co.cask.cdap.etl.mock.spark.streaming

Config for the sink.

MockSource - Class in co.cask.cdap.etl.mock.batch

Mock source that can be used to write a list of records in a Table and reads them out in a pipeline run.

MockSource(MockSource.Config) - Constructor for class co.cask.cdap.etl.mock.batch.MockSource

MockSource - Class in co.cask.cdap.etl.mock.spark.streaming

Mock source for spark streaming unit tests.

MockSource(MockSource.Conf) - Constructor for class co.cask.cdap.etl.mock.spark.streaming.MockSource

MockSource.Conf - Class in co.cask.cdap.etl.mock.spark.streaming

Config for mock source.

MockSource.Config - Class in co.cask.cdap.etl.mock.batch

Config for the source.

MockStageMetrics - Class in co.cask.cdap.etl.mock.common

Mock StageMetrics for unit tests

MockStageMetrics(String) - Constructor for class co.cask.cdap.etl.mock.common.MockStageMetrics

MockTransformContext - Class in co.cask.cdap.etl.mock.transform

Mock context for unit tests

MockTransformContext() - Constructor for class co.cask.cdap.etl.mock.transform.MockTransformContext

MockTransformContext(String) - Constructor for class co.cask.cdap.etl.mock.transform.MockTransformContext

MockTransformContext(String, Map<String, String>) - Constructor for class co.cask.cdap.etl.mock.transform.MockTransformContext

MockTransformContext(String, Map<String, String>, LookupProvider) - Constructor for class co.cask.cdap.etl.mock.transform.MockTransformContext

N

NAME - Static variable in class co.cask.cdap.etl.mock.action.FileMoveAction

NAME - Static variable in class co.cask.cdap.etl.mock.alert.NullAlertTransform

NAME - Static variable in class co.cask.cdap.etl.mock.alert.TMSAlertPublisher

NAME - Static variable in class co.cask.cdap.etl.mock.batch.FileDeleteAction

NAME - Static variable in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

NAME - Static variable in class co.cask.cdap.etl.mock.transform.ExceptionTransform

newPluginInstance(String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

newPluginInstance(String) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

NodeStatesAction - Class in co.cask.cdap.etl.mock.batch

Ending action writes the workflow's node states to a Table.

NodeStatesAction(NodeStatesAction.Conf) - Constructor for class co.cask.cdap.etl.mock.batch.NodeStatesAction

NodeStatesAction.Conf - Class in co.cask.cdap.etl.mock.batch

Conf for the token writer.

NoopMetrics - Class in co.cask.cdap.etl.mock.common

No op metrics implementation for tests.

NoopMetrics() - Constructor for class co.cask.cdap.etl.mock.common.NoopMetrics

NullAlertTransform - Class in co.cask.cdap.etl.mock.alert

Checks if a particular field is null, emitting that record as an alert if so.

NullAlertTransform(NullAlertTransform.Conf) - Constructor for class co.cask.cdap.etl.mock.alert.NullAlertTransform

NullAlertTransform.Conf - Class in co.cask.cdap.etl.mock.alert

Config for plugin

NullFieldSplitterTransform - Class in co.cask.cdap.etl.mock.transform

Splitter transform that sends all records that have a null value for a configurable field to one output port and all other records to another port.

NullFieldSplitterTransform(NullFieldSplitterTransform.Config) - Constructor for class co.cask.cdap.etl.mock.transform.NullFieldSplitterTransform

NullFieldSplitterTransform.Config - Class in co.cask.cdap.etl.mock.transform

Config for the transform.

P

pipelineCount(String, int) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

pipelineCount(String, int) - Method in class co.cask.cdap.etl.mock.common.NoopMetrics

pipelineGauge(String, long) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics

pipelineGauge(String, long) - Method in class co.cask.cdap.etl.mock.common.NoopMetrics

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.action.MockAction

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.alert.NullAlertTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.alert.TMSAlertPublisher

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.aggregator.GroupFilterAggregator

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.FilterTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.LookupTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.MockExternalSink

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.MockExternalSource

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.MockSink

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.batch.MockSource

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.condition.MockCondition

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.spark.streaming.MockSink

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.spark.streaming.MockSource

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.spark.Window

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.AllErrorTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.DoubleTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.DropNullTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.ExceptionTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.FilterErrorTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.FlattenErrorTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.IdentityTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.IntValueFilterTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.NullFieldSplitterTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.SleepTransform

PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.StringValueFilterTransform

PLUGIN_NAME - Static variable in class co.cask.cdap.etl.mock.batch.MockExternalSink

PLUGIN_NAME - Static variable in class co.cask.cdap.etl.mock.batch.MockExternalSource

prepareRun(BatchAggregatorContext) - Method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator

prepareRun(BatchSinkContext) - Method in class co.cask.cdap.etl.mock.batch.MockExternalSink

prepareRun(BatchSourceContext) - Method in class co.cask.cdap.etl.mock.batch.MockExternalSource

prepareRun(BatchSinkContext) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

prepareRun(BatchSourceContext) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

prepareRun(BatchSinkContext) - Method in class co.cask.cdap.etl.mock.batch.MockSink

prepareRun(BatchSourceContext) - Method in class co.cask.cdap.etl.mock.batch.MockSource

prepareRun(SparkPluginContext) - Method in class co.cask.cdap.etl.mock.spark.streaming.MockSink

prepareRun(StageSubmitterContext) - Method in class co.cask.cdap.etl.mock.transform.SleepTransform

provide(String, Map<String, String>) - Method in class co.cask.cdap.etl.mock.common.MockLookupProvider

provide(String, Map<String, String>) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext

publish(Iterator<Alert>) - Method in class co.cask.cdap.etl.mock.alert.TMSAlertPublisher

putSecureData(String, String, String, String, Map<String, String>) - Method in class co.cask.cdap.etl.mock.action.MockActionContext

R

readOutput(DataSetManager<Table>, String, String) - Static method in class co.cask.cdap.etl.mock.action.MockAction

Read the value for the specified rowKey and columnKey.

readOutput(String) - Static method in class co.cask.cdap.etl.mock.batch.MockExternalSink

Used to read the records written by this sink.

readOutput(DataSetManager<Table>) - Static method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

Used to read the records written by this sink.

readOutput(DataSetManager<Table>) - Static method in class co.cask.cdap.etl.mock.batch.MockSink

Used to read the records written by this sink.

readOutput(DataSetManager<Table>, String, String) - Static method in class co.cask.cdap.etl.mock.condition.MockCondition

Read the value for the specified rowKey and columnKey.

run(ActionContext) - Method in class co.cask.cdap.etl.mock.action.FileMoveAction

run(ActionContext) - Method in class co.cask.cdap.etl.mock.action.MockAction

run(BatchActionContext) - Method in class co.cask.cdap.etl.mock.batch.FileDeleteAction

run(BatchActionContext) - Method in class co.cask.cdap.etl.mock.batch.NodeStatesAction

run(SparkExecutionPluginContext, JavaRDD<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.spark.streaming.MockSink

S

set(String, String) - Method in class co.cask.cdap.etl.mock.common.MockArguments

setPipelineProperties(Map<String, String>) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

setupBatchArtifacts(ArtifactId, Class<?>) - Static method in class co.cask.cdap.etl.mock.test.HydratorTestBase

setupStreamingArtifacts(ArtifactId, Class<?>) - Static method in class co.cask.cdap.etl.mock.test.HydratorTestBase

SleepTransform - Class in co.cask.cdap.etl.mock.transform

Sleeps for a configurable amount of time before emitting the input.

SleepTransform(SleepTransform.Config) - Constructor for class co.cask.cdap.etl.mock.transform.SleepTransform

SleepTransform.Config - Class in co.cask.cdap.etl.mock.transform

Config for plugin

StringValueFilterCompute - Class in co.cask.cdap.etl.mock.spark.compute

Transform that filters out records whose configured field is a configured value.

StringValueFilterCompute(StringValueFilterCompute.Conf) - Constructor for class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute

StringValueFilterCompute.Conf - Class in co.cask.cdap.etl.mock.spark.compute

Config for the plugin

StringValueFilterTransform - Class in co.cask.cdap.etl.mock.transform

Transform that filters out records whose configured field is a configured value.

StringValueFilterTransform(StringValueFilterTransform.Config) - Constructor for class co.cask.cdap.etl.mock.transform.StringValueFilterTransform

StringValueFilterTransform.Config - Class in co.cask.cdap.etl.mock.transform

Config for the transform.

T

TMSAlertPublisher - Class in co.cask.cdap.etl.mock.alert

Publishes alerts to TMS.

TMSAlertPublisher(TMSAlertPublisher.Conf) - Constructor for class co.cask.cdap.etl.mock.alert.TMSAlertPublisher

TMSAlertPublisher.Conf - Class in co.cask.cdap.etl.mock.alert

Plugin conf.

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.alert.NullAlertTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.FilterTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.LookupTransform

transform(StructuredRecord, Emitter<KeyValue<NullWritable, String>>) - Method in class co.cask.cdap.etl.mock.batch.MockExternalSink

transform(KeyValue<LongWritable, Text>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.MockExternalSource

transform(StructuredRecord, Emitter<KeyValue<byte[], Put>>) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink

transform(KeyValue<byte[], Row>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

transform(StructuredRecord, Emitter<KeyValue<byte[], Put>>) - Method in class co.cask.cdap.etl.mock.batch.MockSink

transform(KeyValue<byte[], Row>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.MockSource

transform(SparkExecutionPluginContext, JavaRDD<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.AllErrorTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.DoubleTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.DropNullTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.ExceptionTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform

transform(ErrorRecord<StructuredRecord>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.FilterErrorTransform

transform(ErrorRecord<StructuredRecord>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.FlattenErrorTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.IdentityTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.IntValueFilterTransform

transform(StructuredRecord, MultiOutputEmitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.NullFieldSplitterTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.SleepTransform

transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.StringValueFilterTransform

U

usePlugin(String, String, String, PluginProperties) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

usePlugin(String, String, String, PluginProperties, PluginSelector) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

usePluginClass(String, String, String, PluginProperties) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

usePluginClass(String, String, String, PluginProperties, PluginSelector) - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer

W

Window - Class in co.cask.cdap.etl.mock.spark

Window plugin.

Window(Window.Conf) - Constructor for class co.cask.cdap.etl.mock.spark.Window

Window.Conf - Class in co.cask.cdap.etl.mock.spark

Config for window plugin.

writeInput(String, Iterable<StructuredRecord>) - Static method in class co.cask.cdap.etl.mock.batch.MockExternalSource

Used to write the input records for the pipeline run.

writeInput(DataSetManager<Table>, Iterable<StructuredRecord>) - Static method in class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource

Used to write the input records for the pipeline run.

writeInput(DataSetManager<Table>, Iterable<StructuredRecord>) - Static method in class co.cask.cdap.etl.mock.batch.MockSource

Used to write the input records for the pipeline run.

writeInput(DataSetManager<Table>, String, StructuredRecord) - Static method in class co.cask.cdap.etl.mock.batch.MockSource

Used to write the input record with specified row key for the pipeline run.

A C D E F G H I J L M N P R S T U W