public class Hadoop2TezPlanner extends cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
Modifier and Type | Class and Description |
---|---|
class |
Hadoop2TezPlanner.IntermediateBoundaryElementFactory |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
PLATFORM_NAME |
Constructor and Description |
---|
Hadoop2TezPlanner() |
Modifier and Type | Method and Description |
---|---|
void |
configRuleRegistryDefaults(cascading.flow.planner.rule.RuleRegistry ruleRegistry) |
static void |
copyConfiguration(java.util.Map<java.lang.Object,java.lang.Object> properties,
Configuration configuration) |
static void |
copyProperties(Configuration jobConf,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
static org.apache.tez.dag.api.TezConfiguration |
createConfiguration(java.util.Map<java.lang.Object,java.lang.Object> properties) |
protected Hadoop2TezFlow |
createFlow(cascading.flow.FlowDef flowDef) |
org.apache.tez.dag.api.TezConfiguration |
getDefaultConfig() |
java.net.URI |
getDefaultURIScheme(cascading.tap.Tap tap) |
cascading.flow.planner.process.FlowStepFactory<org.apache.tez.dag.api.TezConfiguration> |
getFlowStepFactory() |
cascading.flow.planner.PlannerInfo |
getPlannerInfo(java.lang.String registryName) |
cascading.flow.planner.PlatformInfo |
getPlatformInfo() |
java.net.URI |
getURIScheme(cascading.tap.Tap tap) |
void |
initialize(cascading.flow.FlowConnector flowConnector,
java.util.Map<java.lang.Object,java.lang.Object> properties) |
protected cascading.tap.Tap |
makeTempTap(java.lang.String prefix,
java.lang.String name) |
buildFlow, createFlowElementGraph, getAssertionLevel, getDebugLevel, getDefaultProperties, getFlowNodeFactory, handleExceptionDuringPlanning, makeTempTap, resolveAssemblyPlanners, resolveTails, verifyAllTaps, verifyAssembly, verifyCheckpoints, verifyPipeAssemblyEndPoints, verifyResult, verifyResultInternal, verifySourceNotSinks, verifyTaps, verifyTraps
public static final java.lang.String PLATFORM_NAME
public Hadoop2TezPlanner()
public static void copyConfiguration(java.util.Map<java.lang.Object,java.lang.Object> properties, Configuration configuration)
public static org.apache.tez.dag.api.TezConfiguration createConfiguration(java.util.Map<java.lang.Object,java.lang.Object> properties)
public static void copyProperties(Configuration jobConf, java.util.Map<java.lang.Object,java.lang.Object> properties)
public cascading.flow.planner.PlannerInfo getPlannerInfo(java.lang.String registryName)
getPlannerInfo
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
public org.apache.tez.dag.api.TezConfiguration getDefaultConfig()
getDefaultConfig
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
public cascading.flow.planner.PlatformInfo getPlatformInfo()
getPlatformInfo
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
public void initialize(cascading.flow.FlowConnector flowConnector, java.util.Map<java.lang.Object,java.lang.Object> properties)
initialize
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
public void configRuleRegistryDefaults(cascading.flow.planner.rule.RuleRegistry ruleRegistry)
configRuleRegistryDefaults
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
protected Hadoop2TezFlow createFlow(cascading.flow.FlowDef flowDef)
createFlow
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
public cascading.flow.planner.process.FlowStepFactory<org.apache.tez.dag.api.TezConfiguration> getFlowStepFactory()
getFlowStepFactory
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
public java.net.URI getDefaultURIScheme(cascading.tap.Tap tap)
public java.net.URI getURIScheme(cascading.tap.Tap tap)
protected cascading.tap.Tap makeTempTap(java.lang.String prefix, java.lang.String name)
makeTempTap
in class cascading.flow.planner.FlowPlanner<Hadoop2TezFlow,org.apache.tez.dag.api.TezConfiguration>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.