cascading.flow.local.planner

Class LocalPlanner

java.lang.Object

cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>

cascading.flow.local.planner.LocalPlanner

public class LocalPlanner
extends cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>

Nested Class Summary

Nested classes/interfaces inherited from class cascading.flow.planner.FlowPlanner

cascading.flow.planner.FlowPlanner.IdentityElementFactgory, cascading.flow.planner.FlowPlanner.TempTapElementFactory

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PLATFORM_NAME

Fields inherited from class cascading.flow.planner.FlowPlanner

checkpointTapRootPath, defaultAssertionLevel, defaultDebugLevel, defaultProperties, TRACE_PLAN_PATH, TRACE_PLAN_TRANSFORM_PATH, TRACE_STATS_PATH

Constructor Summary

Constructors

Constructor and Description
LocalPlanner()

Method Summary

Methods

Modifier and Type	Method and Description
protected LocalFlow	createFlow(cascading.flow.FlowDef flowDef)
java.util.Properties	getDefaultConfig()
cascading.flow.planner.process.FlowStepFactory<java.util.Properties>	getFlowStepFactory()
cascading.flow.planner.PlannerInfo	getPlannerInfo(java.lang.String registryName)
cascading.flow.planner.PlatformInfo	getPlatformInfo()
protected cascading.tap.Tap	makeTempTap(java.lang.String prefix, java.lang.String name)

Methods inherited from class cascading.flow.planner.FlowPlanner

buildFlow, configRuleRegistryDefaults, createFlowElementGraph, getAssertionLevel, getDebugLevel, getDefaultProperties, getFlowNodeFactory, handleExceptionDuringPlanning, initialize, makeTempTap, resolveAssemblyPlanners, resolveTails, verifyAllTaps, verifyAssembly, verifyCheckpoints, verifyPipeAssemblyEndPoints, verifyResult, verifyResultInternal, verifySourceNotSinks, verifyTaps, verifyTraps

Methods inherited from class java.lang.Object

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

Field Detail

PLATFORM_NAME

public static final java.lang.String PLATFORM_NAME

See Also:

Constant Field Values

Constructor Detail

LocalPlanner

public LocalPlanner()

Method Detail

getDefaultConfig

public java.util.Properties getDefaultConfig()

Specified by:

getDefaultConfig in class cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>

getPlannerInfo

public cascading.flow.planner.PlannerInfo getPlannerInfo(java.lang.String registryName)

Specified by:

getPlannerInfo in class cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>

getPlatformInfo

public cascading.flow.planner.PlatformInfo getPlatformInfo()

Specified by:

getPlatformInfo in class cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>

createFlow

protected LocalFlow createFlow(cascading.flow.FlowDef flowDef)

Specified by:

createFlow in class cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>

getFlowStepFactory

public cascading.flow.planner.process.FlowStepFactory<java.util.Properties> getFlowStepFactory()

Specified by:

getFlowStepFactory in class cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>

makeTempTap

protected cascading.tap.Tap makeTempTap(java.lang.String prefix,
                            java.lang.String name)

Specified by:

makeTempTap in class cascading.flow.planner.FlowPlanner<LocalFlow,java.util.Properties>