CrunchInputs (Apache Crunch 0.3.0-incubating API)

This project has retired. For details please refer to its Attic page.

Overview

Package

Class

Use

Tree

Deprecated

Index

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.crunch.impl.mr.run
Class CrunchInputs

java.lang.Object
  org.apache.crunch.impl.mr.run.CrunchInputs

public class CrunchInputs
extends Object
extends Object

Constructor Summary

CrunchInputs()


Method Summary

static void addInputPath(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path path, InputBundle inputBundle, int nodeIndex)


static Map<InputBundle,Map<Integer,List<org.apache.hadoop.fs.Path>>> getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job)


Methods inherited from class java.lang.Object

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

Constructor Summary
`CrunchInputs()`

Method Summary
`static void`	`addInputPath(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path path, InputBundle inputBundle, int nodeIndex)`
`static Map<InputBundle,Map<Integer,List<org.apache.hadoop.fs.Path>>>`	`getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job)`

Methods inherited from class java.lang.Object
`equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Constructor Detail

CrunchInputs

public CrunchInputs()

Method Detail

addInputPath

public static void addInputPath(org.apache.hadoop.mapreduce.Job job,
                                org.apache.hadoop.fs.Path path,
                                InputBundle inputBundle,
                                int nodeIndex)

getFormatNodeMap

public static Map<InputBundle,Map<Integer,List<org.apache.hadoop.fs.Path>>> getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job)