org.apache.tez.dag.library.vertexmanager

Class ShuffleVertexManager.ShuffleVertexManagerConfigBuilder

java.lang.Object

org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager.ShuffleVertexManagerConfigBuilder

Enclosing class:

ShuffleVertexManager

public static final class ShuffleVertexManager.ShuffleVertexManagerConfigBuilder
extends Object

Helper class to configure ShuffleVertexManager

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.tez.dag.api.VertexManagerPluginDescriptor	build()
ShuffleVertexManager.ShuffleVertexManagerConfigBuilder	setAutoReduceParallelism(boolean enabled)
ShuffleVertexManager.ShuffleVertexManagerConfigBuilder	setDesiredTaskInputSize(long desiredTaskInputSize)
ShuffleVertexManager.ShuffleVertexManagerConfigBuilder	setMinTaskParallelism(int minTaskParallelism)
ShuffleVertexManager.ShuffleVertexManagerConfigBuilder	setSlowStartMaxSrcCompletionFraction(float maxFraction)
ShuffleVertexManager.ShuffleVertexManagerConfigBuilder	setSlowStartMinSrcCompletionFraction(float minFraction)

Methods inherited from class java.lang.Object

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

Method Detail

setAutoReduceParallelism

public ShuffleVertexManager.ShuffleVertexManagerConfigBuilder setAutoReduceParallelism(boolean enabled)

setSlowStartMinSrcCompletionFraction

public ShuffleVertexManager.ShuffleVertexManagerConfigBuilder setSlowStartMinSrcCompletionFraction(float minFraction)

setSlowStartMaxSrcCompletionFraction

public ShuffleVertexManager.ShuffleVertexManagerConfigBuilder setSlowStartMaxSrcCompletionFraction(float maxFraction)

setDesiredTaskInputSize

public ShuffleVertexManager.ShuffleVertexManagerConfigBuilder setDesiredTaskInputSize(long desiredTaskInputSize)

setMinTaskParallelism

public ShuffleVertexManager.ShuffleVertexManagerConfigBuilder setMinTaskParallelism(int minTaskParallelism)

build

public org.apache.tez.dag.api.VertexManagerPluginDescriptor build()