Index (Hydrator Test Classes 3.5.3 API)

A C D E F G H I J 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.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.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.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(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

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

G

getJoinConfig() - Method in class co.cask.cdap.etl.mock.batch.joiner.MockJoiner
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, 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
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
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
getSlideInterval() - Method in class co.cask.cdap.etl.mock.spark.Window
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
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.MockJoiner

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

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

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

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

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 W