co.cask.cdap.etl.mock.transform

Class SleepTransform

java.lang.Object

co.cask.cdap.etl.api.Transform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

co.cask.cdap.etl.mock.transform.SleepTransform

All Implemented Interfaces:

Destroyable, PipelineConfigurable, StageLifecycle<TransformContext>, SubmitterLifecycle<StageSubmitterContext>, Transformation<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

public class SleepTransform
extends Transform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Sleeps for a configurable amount of time before emitting the input. This is used to test the time spent metric.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SleepTransform.Config Config for plugin

Field Summary

Fields

Modifier and Type	Field and Description
static PluginClass	PLUGIN_CLASS

Fields inherited from class co.cask.cdap.etl.api.Transform

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
SleepTransform(SleepTransform.Config config)

Method Summary

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
static ETLPlugin	getPlugin(long millis)
void	prepareRun(StageSubmitterContext context)
void	transform(co.cask.cdap.api.data.format.StructuredRecord input, Emitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)

Methods inherited from class co.cask.cdap.etl.api.Transform

destroy, getContext, initialize, onRunFinish

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PLUGIN_CLASS

public static final PluginClass PLUGIN_CLASS

Constructor Detail

SleepTransform

public SleepTransform(SleepTransform.Config config)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)
                       throws IllegalArgumentException

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class Transform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IllegalArgumentException

prepareRun

public void prepareRun(StageSubmitterContext context)
                throws Exception

Specified by:

prepareRun in interface SubmitterLifecycle<StageSubmitterContext>

Overrides:

prepareRun in class Transform<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Throws:

Exception

transform

public void transform(co.cask.cdap.api.data.format.StructuredRecord input,
                      Emitter<co.cask.cdap.api.data.format.StructuredRecord> emitter)
               throws Exception

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin(long millis)