|Constructor and Description|
|Modifier and Type||Method and Description|
Create a transform executor for the specified pipeline.
public <KEY_OUT,VAL_OUT> PipeTransformExecutor<T> create(PipelinePhase pipeline, OutputWriter<KEY_OUT,VAL_OUT> outputWriter) throws Exception
pipeline- the pipeline to create a transform executor for
outputWriter- writes output records to the mapreduce context
InstantiationException- if there was an error instantiating a plugin
Exception- if there was an error initializing a plugin
Copyright © 2018 Cask Data, Inc.. All rights reserved.