public class LocalPlanner extends FlowPlanner<LocalFlow,Properties>
FlowPlanner.TempTapElementFactory
Modifier and Type | Field and Description |
---|---|
static String |
PLATFORM_NAME |
checkpointTapRootPath, defaultAssertionLevel, defaultDebugLevel, defaultProperties, TRACE_PLAN_PATH, TRACE_PLAN_TRANSFORM_PATH, TRACE_STATS_PATH
Constructor and Description |
---|
LocalPlanner() |
Modifier and Type | Method and Description |
---|---|
protected LocalFlow |
createFlow(FlowDef flowDef) |
Properties |
getDefaultConfig() |
FlowStepFactory<Properties> |
getFlowStepFactory() |
PlannerInfo |
getPlannerInfo(String registryName) |
PlatformInfo |
getPlatformInfo() |
protected Tap |
makeTempTap(String prefix,
String name) |
buildFlow, configRuleRegistryDefaults, createFlowElementGraph, getAssertionLevel, getDebugLevel, getDefaultProperties, getFlowNodeFactory, handleExceptionDuringPlanning, initialize, makeTempTap, resolveAssemblyPlanners, resolveTails, verifyAllTaps, verifyAssembly, verifyCheckpoints, verifyPipeAssemblyEndPoints, verifyResult, verifyResultInternal, verifySourceNotSinks, verifyTaps, verifyTraps
public static final String PLATFORM_NAME
public LocalPlanner()
public Properties getDefaultConfig()
getDefaultConfig
in class FlowPlanner<LocalFlow,Properties>
public PlannerInfo getPlannerInfo(String registryName)
getPlannerInfo
in class FlowPlanner<LocalFlow,Properties>
public PlatformInfo getPlatformInfo()
getPlatformInfo
in class FlowPlanner<LocalFlow,Properties>
protected LocalFlow createFlow(FlowDef flowDef)
createFlow
in class FlowPlanner<LocalFlow,Properties>
public FlowStepFactory<Properties> getFlowStepFactory()
getFlowStepFactory
in class FlowPlanner<LocalFlow,Properties>
protected Tap makeTempTap(String prefix, String name)
makeTempTap
in class FlowPlanner<LocalFlow,Properties>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.