Package | Description |
---|---|
org.apache.crunch.io |
Data input and output for Pipelines.
|
Modifier and Type | Method and Description |
---|---|
static <T extends org.apache.hadoop.mapreduce.InputFormat<?,?>> |
FormatBundle.forInput(Class<T> inputFormatClass) |
static <T extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> |
FormatBundle.forOutput(Class<T> inputFormatClass) |
static <T> FormatBundle<T> |
FormatBundle.fromSerialized(String serialized,
Class<T> clazz) |
FormatBundle<K> |
FormatBundle.set(String key,
String value) |
Modifier and Type | Method and Description |
---|---|
static Map<FormatBundle,Map<Integer,List<org.apache.hadoop.fs.Path>>> |
CrunchInputs.getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job) |
Modifier and Type | Method and Description |
---|---|
static void |
CrunchInputs.addInputPath(org.apache.hadoop.mapreduce.Job job,
org.apache.hadoop.fs.Path path,
FormatBundle inputBundle,
int nodeIndex) |
static void |
CrunchOutputs.addNamedOutput(org.apache.hadoop.mapreduce.Job job,
String name,
FormatBundle<? extends org.apache.hadoop.mapreduce.OutputFormat> outputBundle,
Class keyClass,
Class valueClass) |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.