co.cask.cdap.etl.mock.batch

Class NodeStatesAction

java.lang.Object

co.cask.cdap.etl.api.batch.PostAction

co.cask.cdap.etl.mock.batch.NodeStatesAction

All Implemented Interfaces:

PipelineConfigurable

public class NodeStatesAction
extends PostAction

Ending action writes the workflow's node states to a Table.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NodeStatesAction.Conf Conf for the token writer.

Field Summary

Fields inherited from class co.cask.cdap.etl.api.batch.PostAction

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
NodeStatesAction(NodeStatesAction.Conf conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
static ETLPlugin	getPlugin(String tableName)
void	run(BatchActionContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeStatesAction

public NodeStatesAction(NodeStatesAction.Conf conf)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class PostAction

run

public void run(BatchActionContext context)
         throws Exception

Specified by:

run in class PostAction

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin(String tableName)