org.apache.tez.runtime.library.processor

Class PreWarmProcessor

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalIOProcessor

org.apache.tez.runtime.library.processor.SimpleProcessor

org.apache.tez.runtime.library.processor.PreWarmProcessor

All Implemented Interfaces:

org.apache.tez.runtime.api.LogicalIOProcessor, org.apache.tez.runtime.api.LogicalIOProcessorFrameworkInterface, org.apache.tez.runtime.api.Processor, org.apache.tez.runtime.api.ProcessorFrameworkInterface

@InterfaceStability.Unstable
@InterfaceAudience.Public
public class PreWarmProcessor
extends SimpleProcessor

Built-in convenience Processor to be used for pre-warming. If this is customized by the user then they need to make sure that the custom class jar is localized for the prewarm vertex and other vertices that need to take advantage of prewarming

Field Summary

Fields inherited from class org.apache.tez.runtime.library.processor.SimpleProcessor

inputs, outputs

Constructor Summary

Constructors

Constructor and Description
PreWarmProcessor(org.apache.tez.runtime.api.ProcessorContext context)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	preWarmTezCode() Pre-warm Tez code.
protected void	preWarmUserCode() Pre-warm user code.
void	run() Users must implement this method to provide the main application logic code

Methods inherited from class org.apache.tez.runtime.library.processor.SimpleProcessor

close, getInputs, getOutputs, handleEvents, initialize, postOp, preOp, run

Methods inherited from class org.apache.tez.runtime.api.AbstractLogicalIOProcessor

getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

PreWarmProcessor

public PreWarmProcessor(org.apache.tez.runtime.api.ProcessorContext context)

Method Detail

run

public void run()
         throws Exception

Description copied from class: SimpleProcessor

Users must implement this method to provide the main application logic code

Specified by:

run in class SimpleProcessor

Throws:

Exception

preWarmTezCode

protected void preWarmTezCode()

Pre-warm Tez code. Users can override this with an empty method to not pre-warm Tez code if they want to.

preWarmUserCode

protected void preWarmUserCode()

Pre-warm user code. Users can override this to pre-warm their own code if they want to.