Index (Hydrator Test Classes 4.0.0 API)

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(StructuredRecord, Iterator<StructuredRecord>, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

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
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.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.realtime - package co.cask.cdap.etl.mock.realtime
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
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.batch.aggregator.FieldCountAggregator
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.spark.streaming.MockSource
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform
configurePipeline(PipelineConfigurer) - Method in class co.cask.cdap.etl.mock.transform.IdentityTransform
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
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.cdap.etl.mock.realtime.StructuredRecordCodec
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
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
DupeFlagger.Config() - Constructor for class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger.Config
DupeFlagger.Config(String, String) - Constructor for class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger.Config

E

emit(T) - Method in class co.cask.cdap.etl.mock.common.MockEmitter
emitError(InvalidEntry<T>) - Method in class co.cask.cdap.etl.mock.common.MockEmitter
ErrorTransform - Class in co.cask.cdap.etl.mock.transform: Transform used to test writing to error datasets.
ErrorTransform() - Constructor for class co.cask.cdap.etl.mock.transform.ErrorTransform
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.
FieldCountAggregator.Config() - Constructor for class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator.Config
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
FieldsPrefixTransform.Config() - Constructor for class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform.Config
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.
FileDeleteAction.Conf() - Constructor for class co.cask.cdap.etl.mock.batch.FileDeleteAction.Conf
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.
FileMoveAction.Conf() - Constructor for class co.cask.cdap.etl.mock.action.FileMoveAction.Conf

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
getArguments() - Method in class co.cask.cdap.etl.mock.action.MockActionContext
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
getErrors() - Method in class co.cask.cdap.etl.mock.common.MockEmitter
getGauge(String) - Method in class co.cask.cdap.etl.mock.common.MockMetrics
getGauge(String) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics
getInstanceCount() - Method in class co.cask.cdap.etl.mock.realtime.MockRealtimeContext
getInstanceId() - Method in class co.cask.cdap.etl.mock.realtime.MockRealtimeContext
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
getMetrics() - Method in class co.cask.cdap.etl.mock.action.MockActionContext
getMetrics() - Method in class co.cask.cdap.etl.mock.realtime.MockRealtimeContext
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
getOutputSchema() - Method in class co.cask.cdap.etl.mock.common.MockPipelineConfigurer
getPipelineCount(String) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics
getPipelineGauge(String) - Method in class co.cask.cdap.etl.mock.common.MockStageMetrics
getPlugin(String, String, String, String) - Static method in class co.cask.cdap.etl.mock.action.MockAction
getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator
getPlugin() - Static method in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator
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.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(Set<String>, String) - Static method in class co.cask.cdap.etl.mock.realtime.LookupSource
getPlugin(File) - Static method in class co.cask.cdap.etl.mock.realtime.MockSink
getPlugin(List<StructuredRecord>) - Static method in class co.cask.cdap.etl.mock.realtime.MockSource
getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute
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.DoubleTransform
getPlugin() - Static method in class co.cask.cdap.etl.mock.transform.ErrorTransform
getPlugin(String, String) - Static method in class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform
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, 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.realtime.MockRealtimeContext
getPluginProperties(String) - Method in class co.cask.cdap.etl.mock.realtime.MockRealtimeContext
getPluginProperties() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
getPluginProperties(String) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
getRecords(File, int, long, TimeUnit) - Static method in class co.cask.cdap.etl.mock.realtime.MockSink: Get the records written out by the writeNum call to write.
getRecords() - Method in class co.cask.cdap.etl.mock.realtime.MockSource.Config
getSecureData(String, String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext
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.realtime.MockRealtimeContext
getStageName() - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
getStream(StreamingContext) - Method in class co.cask.cdap.etl.mock.spark.streaming.MockSource
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<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.batch.aggregator.IdentityAggregator

H

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(BatchRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.aggregator.FieldCountAggregator
initialize(BatchJoinerRuntimeContext) - Method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner
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(RealtimeContext) - Method in class co.cask.cdap.etl.mock.realtime.LookupSource
initialize(RealtimeContext) - Method in class co.cask.cdap.etl.mock.realtime.MockSink
initialize(RealtimeContext) - Method in class co.cask.cdap.etl.mock.realtime.MockSource
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.
IntValueFilterTransform.Config() - Constructor for class co.cask.cdap.etl.mock.transform.IntValueFilterTransform.Config

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.realtime.MockRealtimeContext
loadPluginClass(String) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
LookupSource - Class in co.cask.cdap.etl.mock.realtime: Source used to test lookup functionality.
LookupSource(LookupSource.Config) - Constructor for class co.cask.cdap.etl.mock.realtime.LookupSource
LookupSource.Config - Class in co.cask.cdap.etl.mock.realtime: Config for the source.
LookupSource.Config() - Constructor for class co.cask.cdap.etl.mock.realtime.LookupSource.Config

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
MockAction.Config() - Constructor for class co.cask.cdap.etl.mock.action.MockAction.Config
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
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.
MockExternalSink.Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockExternalSink.Config
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.
MockExternalSource.Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockExternalSource.Config
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
MockJoiner.Config() - Constructor for class co.cask.cdap.etl.mock.batch.joiner.MockJoiner.Config
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
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
MockRealtimeContext - Class in co.cask.cdap.etl.mock.realtime: Mock RealtimeContext for tests.
MockRealtimeContext(Map<String, String>) - Constructor for class co.cask.cdap.etl.mock.realtime.MockRealtimeContext
MockRealtimeContext() - Constructor for class co.cask.cdap.etl.mock.realtime.MockRealtimeContext
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.
MockRuntimeDatasetSink.Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSink.Config
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.
MockRuntimeDatasetSource.Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockRuntimeDatasetSource.Config
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.realtime: Mock sink to keep track of what was written.
MockSink(MockSink.Config) - Constructor for class co.cask.cdap.etl.mock.realtime.MockSink
MockSink.Config - Class in co.cask.cdap.etl.mock.batch: Config for the sink.
MockSink.Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockSink.Config
MockSink.Config - Class in co.cask.cdap.etl.mock.realtime: Config for the sink.
MockSink.Config() - Constructor for class co.cask.cdap.etl.mock.realtime.MockSink.Config
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.realtime: Mock realtime source that emits the records it is configured to emit, then does nothing.
MockSource(MockSource.Config) - Constructor for class co.cask.cdap.etl.mock.realtime.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.Conf() - Constructor for class co.cask.cdap.etl.mock.spark.streaming.MockSource.Conf
MockSource.Config - Class in co.cask.cdap.etl.mock.batch: Config for the source.
MockSource.Config() - Constructor for class co.cask.cdap.etl.mock.batch.MockSource.Config
MockSource.Config - Class in co.cask.cdap.etl.mock.realtime: Config for the source.
MockSource.Config() - Constructor for class co.cask.cdap.etl.mock.realtime.MockSource.Config
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.batch.FileDeleteAction
NAME - Static variable in class co.cask.cdap.etl.mock.batch.joiner.DupeFlagger
newPluginInstance(String) - Method in class co.cask.cdap.etl.mock.action.MockActionContext
newPluginInstance(String) - Method in class co.cask.cdap.etl.mock.realtime.MockRealtimeContext
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.
NodeStatesAction.Conf() - Constructor for class co.cask.cdap.etl.mock.batch.NodeStatesAction.Conf
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

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.batch.aggregator.FieldCountAggregator
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.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.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.realtime.LookupSource
PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.realtime.MockSink
PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.realtime.MockSource
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.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.DoubleTransform
PLUGIN_CLASS - Static variable in class co.cask.cdap.etl.mock.transform.ErrorTransform
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.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.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
poll(Emitter<StructuredRecord>, SourceState) - Method in class co.cask.cdap.etl.mock.realtime.LookupSource
poll(Emitter<StructuredRecord>, SourceState) - Method in class co.cask.cdap.etl.mock.realtime.MockSource
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
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.realtime.MockRealtimeContext
provide(String, Map<String, String>) - Method in class co.cask.cdap.etl.mock.transform.MockTransformContext
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.
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

S

serialize(StructuredRecord, Type, JsonSerializationContext) - Method in class co.cask.cdap.etl.mock.realtime.StructuredRecordCodec
setupBatchArtifacts(ArtifactId, Class<?>) - Static method in class co.cask.cdap.etl.mock.test.HydratorTestBase
setupRealtimeArtifacts(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
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.
StringValueFilterCompute.Conf() - Constructor for class co.cask.cdap.etl.mock.spark.compute.StringValueFilterCompute.Conf
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.
StringValueFilterTransform.Config() - Constructor for class co.cask.cdap.etl.mock.transform.StringValueFilterTransform.Config
StructuredRecordCodec - Class in co.cask.cdap.etl.mock.realtime: Codec for serializing, deserializing StructuredRecord.
StructuredRecordCodec() - Constructor for class co.cask.cdap.etl.mock.realtime.StructuredRecordCodec

T

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.DoubleTransform
transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.ErrorTransform
transform(StructuredRecord, Emitter<StructuredRecord>) - Method in class co.cask.cdap.etl.mock.transform.FieldsPrefixTransform
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, 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.
Window.Conf() - Constructor for class co.cask.cdap.etl.mock.spark.Window.Conf
write(Iterable<StructuredRecord>, DataWriter) - Method in class co.cask.cdap.etl.mock.realtime.MockSink
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.

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