co.cask.cdap.etl.mock.condition

Class MockCondition

java.lang.Object

co.cask.cdap.etl.api.condition.Condition

co.cask.cdap.etl.mock.condition.MockCondition

All Implemented Interfaces:

PipelineConfigurable

public class MockCondition
extends Condition

Mock implementation of Condition in the pipeline.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MockCondition.Config Config for the sink.

Field Summary

Fields

Modifier and Type	Field and Description
static PluginClass	PLUGIN_CLASS

Fields inherited from class co.cask.cdap.etl.api.condition.Condition

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
MockCondition(MockCondition.Config config)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	apply(ConditionContext context)
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
static ETLPlugin	getPlugin(String name)
static ETLPlugin	getPlugin(String name, String tableName)
static String	readOutput(DataSetManager<Table> tableManager, String rowKey, String columnKey) Read the value for the specified rowKey and columnKey.

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

MockCondition

public MockCondition(MockCondition.Config config)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)
                       throws IllegalArgumentException

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class Condition

Throws:

IllegalArgumentException

apply

public boolean apply(ConditionContext context)
              throws Exception

Specified by:

apply in class Condition

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin(String name)

getPlugin

public static ETLPlugin getPlugin(String name,
                  @Nullable
                  String tableName)

readOutput

public static String readOutput(DataSetManager<Table> tableManager,
                String rowKey,
                String columnKey)
                         throws Exception

Read the value for the specified rowKey and columnKey.

Throws:

Exception