Uses of Class
org.apache.crunch.io.FormatBundle

Packages that use FormatBundle

Package	Description
org.apache.crunch.io	Data input and output for Pipelines.
org.apache.crunch.kafka.inputformat
org.apache.crunch.types.avro	Business object serialization using Apache Avro.

Uses of FormatBundle in org.apache.crunch.io

Fields in org.apache.crunch.io declared as FormatBundle

Modifier and Type	Field and Description
FormatBundle<org.apache.hadoop.mapreduce.OutputFormat<K,V>>	CrunchOutputs.OutputConfig.bundle

Methods in org.apache.crunch.io that return FormatBundle

Modifier and Type	Method and Description
static <T extends org.apache.hadoop.mapreduce.InputFormat<?,?>> FormatBundle<T>	FormatBundle.forInput(Class<T> inputFormatClass)
static <T extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> FormatBundle<T>	FormatBundle.forOutput(Class<T> outputFormatClass)
static <T> FormatBundle<T>	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

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)

Methods in org.apache.crunch.io with parameters of type FormatBundle

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	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)

Constructors in org.apache.crunch.io with parameters of type FormatBundle

Constructor and Description
OutputConfig(FormatBundle<org.apache.hadoop.mapreduce.OutputFormat<K,V>> bundle, Class<K> keyClass, Class<V> valueClass)

Uses of FormatBundle in org.apache.crunch.kafka.inputformat

Methods in org.apache.crunch.kafka.inputformat with parameters of type FormatBundle

Modifier and Type	Method and Description
static void	KafkaInputFormat.writeConnectionPropertiesToBundle(Properties connectionProperties, FormatBundle bundle) Writes the Kafka connection properties to the bundle.
static void	KafkaInputFormat.writeOffsetsToBundle(Map<org.apache.kafka.common.TopicPartition,Pair<Long,Long>> offsets, FormatBundle bundle) Writes the start and end offsets for the provided topic partitions to the bundle.

Uses of FormatBundle in org.apache.crunch.types.avro

Methods in org.apache.crunch.types.avro with parameters of type FormatBundle

Modifier and Type	Method and Description
void	AvroMode.configure(FormatBundle bundle) Populates the bundle with mode specific settings for the specific FormatBundle.