co.cask.cdap.etl.mock.batch.joiner

Class MockJoiner

java.lang.Object

co.cask.cdap.etl.api.batch.MultiInputBatchConfigurable<BatchJoinerContext>

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

co.cask.cdap.etl.mock.batch.joiner.MockJoiner

All Implemented Interfaces:

Destroyable, Joiner<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>, MultiInputPipelineConfigurable, StageLifecycle<BatchJoinerRuntimeContext>, SubmitterLifecycle<BatchJoinerContext>

public class MockJoiner
extends BatchJoiner<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Join plugin to perform joins on structured records

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MockJoiner.Config Config for join plugin

Field Summary

Fields

Modifier and Type	Field and Description
static PluginClass	PLUGIN_CLASS

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

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
MockJoiner(MockJoiner.Config config)

Method Summary

Modifier and Type	Method and Description
void	configurePipeline(MultiInputPipelineConfigurer pipelineConfigurer)
JoinConfig	getJoinConfig()
static ETLPlugin	getPlugin(String joinKeys, String requiredInputs, String selectedFields)
void	initialize(BatchJoinerRuntimeContext context)
co.cask.cdap.api.data.format.StructuredRecord	joinOn(String stageName, co.cask.cdap.api.data.format.StructuredRecord record)
co.cask.cdap.api.data.format.StructuredRecord	merge(co.cask.cdap.api.data.format.StructuredRecord joinKey, Iterable<JoinElement<co.cask.cdap.api.data.format.StructuredRecord>> joinRow)

Methods inherited from class co.cask.cdap.etl.api.batch.BatchJoiner

destroy, prepareRun

Methods inherited from class co.cask.cdap.etl.api.batch.MultiInputBatchConfigurable

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

MockJoiner

public MockJoiner(MockJoiner.Config config)

Method Detail

configurePipeline

public void configurePipeline(MultiInputPipelineConfigurer pipelineConfigurer)

Specified by:

configurePipeline in interface MultiInputPipelineConfigurable

Overrides:

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

initialize

public void initialize(BatchJoinerRuntimeContext context)
                throws Exception

Specified by:

initialize in interface StageLifecycle<BatchJoinerRuntimeContext>

Overrides:

initialize in class BatchJoiner<co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord,co.cask.cdap.api.data.format.StructuredRecord>

Throws:

Exception

joinOn

public co.cask.cdap.api.data.format.StructuredRecord joinOn(String stageName,
                                                            co.cask.cdap.api.data.format.StructuredRecord record)
                                                     throws Exception

Throws:

Exception

getJoinConfig

public JoinConfig getJoinConfig()

merge

public co.cask.cdap.api.data.format.StructuredRecord merge(co.cask.cdap.api.data.format.StructuredRecord joinKey,
                                                           Iterable<JoinElement<co.cask.cdap.api.data.format.StructuredRecord>> joinRow)

getPlugin

public static ETLPlugin getPlugin(String joinKeys,
                                  String requiredInputs,
                                  String selectedFields)