|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use FormatBundle | |
---|---|
org.apache.crunch.io | Data input and output for Pipelines. |
org.apache.crunch.types.avro | Business object serialization using Apache Avro. |
Uses of FormatBundle in org.apache.crunch.io |
---|
Methods in org.apache.crunch.io that return FormatBundle | ||
---|---|---|
static
|
FormatBundle.forInput(Class<T> inputFormatClass)
|
|
static
|
FormatBundle.forOutput(Class<T> outputFormatClass)
|
|
static
|
FormatBundle.fromSerialized(String serialized,
org.apache.hadoop.conf.Configuration conf)
|
|
FormatBundle<K> |
FormatBundle.set(String key,
String value)
|
Methods in org.apache.crunch.io that return types with arguments of type FormatBundle | |
---|---|
static Map<FormatBundle,Map<Integer,List<org.apache.hadoop.fs.Path>>> |
CrunchInputs.getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job)
|
Methods in org.apache.crunch.io with parameters of type FormatBundle | |
---|---|
static void |
CrunchInputs.addInputPath(org.apache.hadoop.mapreduce.Job job,
org.apache.hadoop.fs.Path path,
FormatBundle inputBundle,
int nodeIndex)
|
static void |
CrunchInputs.addInputPaths(org.apache.hadoop.mapreduce.Job job,
Collection<org.apache.hadoop.fs.Path> paths,
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)
|
Uses of FormatBundle in org.apache.crunch.types.avro |
---|
Methods in org.apache.crunch.types.avro with parameters of type FormatBundle | |
---|---|
void |
AvroMode.configure(FormatBundle bundle)
Populates the bundle with mode specific settings for the specific FormatBundle . |
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |