Examples of cascading.flow.tez.Hadoop2TezFlow

cascading.flow.tez.Hadoop2TezFlow

Class HadoopFlow is the Apache Hadoop specific implementation of a {@link cascading.flow.Flow}.

HadoopFlow must be created through a {@link cascading.flow.hadoop.HadoopFlowConnector} instance.

If classpath paths are provided on the {@link cascading.flow.FlowDef}, the Hadoop distributed cache mechanism will be used to augment the remote classpath.

Any path elements that are relative will be uploaded to HDFS, and the HDFS URI will be used on the JobConf. Note all paths are added as "files" to the JobConf, not archives, so they aren't needlessly uncompressed cluster side. @see cascading.flow.hadoop.HadoopFlowConnector

    }


  @Override
  protected Hadoop2TezFlow createFlow( FlowDef flowDef )
    {
    return new Hadoop2TezFlow( getPlatformInfo(), getDefaultProperties(), getDefaultConfig(), flowDef );
    }

Related Classes of cascading.flow.tez.Hadoop2TezFlow

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.