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

A

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

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.realtime - package co.cask.cdap.etl.mock.realtime

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.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.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.transform.IdentityTransform

D

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

E

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

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

G

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, 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) - Static method in class co.cask.cdap.etl.mock.batch.MockSink

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

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() - Static method in class co.cask.cdap.etl.mock.transform.DoubleTransform

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

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

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

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(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

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

L

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

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

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.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

N

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

P

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.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.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.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.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.MockSink

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

R

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.MockSink

Used to read the records written by this sink.

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

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.MockSink

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

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.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

W

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.MockSource

Used to write the input records for the pipeline run.

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