public class Hadoop2TezFlowConnector extends cascading.flow.FlowConnector
Constructor and Description |
---|
Hadoop2TezFlowConnector() |
Hadoop2TezFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties) |
Hadoop2TezFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties,
cascading.flow.planner.rule.RuleRegistrySet ruleRegistrySet) |
Hadoop2TezFlowConnector(cascading.flow.planner.rule.RuleRegistrySet ruleRegistrySet) |
Modifier and Type | Method and Description |
---|---|
protected cascading.flow.planner.rule.RuleRegistrySet |
createDefaultRuleRegistrySet() |
protected cascading.flow.planner.FlowPlanner |
createFlowPlanner() |
protected java.lang.Class<? extends cascading.scheme.Scheme> |
getDefaultIntermediateSchemeClass() |
public Hadoop2TezFlowConnector()
@ConstructorProperties(value="properties") public Hadoop2TezFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties)
@ConstructorProperties(value="ruleRegistrySet") public Hadoop2TezFlowConnector(cascading.flow.planner.rule.RuleRegistrySet ruleRegistrySet)
@ConstructorProperties(value={"properties","ruleRegistrySet"}) public Hadoop2TezFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties, cascading.flow.planner.rule.RuleRegistrySet ruleRegistrySet)
protected java.lang.Class<? extends cascading.scheme.Scheme> getDefaultIntermediateSchemeClass()
getDefaultIntermediateSchemeClass
in class cascading.flow.FlowConnector
protected cascading.flow.planner.FlowPlanner createFlowPlanner()
createFlowPlanner
in class cascading.flow.FlowConnector
protected cascading.flow.planner.rule.RuleRegistrySet createDefaultRuleRegistrySet()
createDefaultRuleRegistrySet
in class cascading.flow.FlowConnector
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.