Uses of Class
org.apache.crunch.impl.spark.ByteArray

Packages that use ByteArray

Package	Description
org.apache.crunch.impl.spark
org.apache.crunch.impl.spark.collect
org.apache.crunch.impl.spark.fn
org.apache.crunch.impl.spark.serde

Uses of ByteArray in org.apache.crunch.impl.spark

Subclasses of ByteArray in org.apache.crunch.impl.spark

Modifier and Type	Class and Description
class	IntByteArray

Methods in org.apache.crunch.impl.spark with parameters of type ByteArray

Modifier and Type	Method and Description
int	SparkComparator.compare(ByteArray s1, ByteArray s2)
int	ByteArray.compareTo(ByteArray other)

Constructors in org.apache.crunch.impl.spark with parameters of type ByteArray

Constructor and Description
IntByteArray(int partition, ByteArray delegate)

Uses of ByteArray in org.apache.crunch.impl.spark.collect

Methods in org.apache.crunch.impl.spark.collect that return types with arguments of type ByteArray

Modifier and Type	Method and Description
scala.Tuple2<ByteArray,List<byte[]>>	ToByteArrayFunction.call(scala.Tuple2<IntByteArray,List<byte[]>> t)

Uses of ByteArray in org.apache.crunch.impl.spark.fn

Methods in org.apache.crunch.impl.spark.fn that return types with arguments of type ByteArray

Modifier and Type	Method and Description
Iterable<scala.Tuple2<ByteArray,List<byte[]>>>	ReduceGroupingFunction.call(Iterator<scala.Tuple2<ByteArray,List<byte[]>>> iter)
scala.Tuple2<ByteArray,byte[]>	MapOutputFunction.call(Pair<K,V> p)

Method parameters in org.apache.crunch.impl.spark.fn with type arguments of type ByteArray

Modifier and Type	Method and Description
Iterable<scala.Tuple2<ByteArray,List<byte[]>>>	ReduceGroupingFunction.call(Iterator<scala.Tuple2<ByteArray,List<byte[]>>> iter)
Pair<K,Iterable<V>>	ReduceInputFunction.call(scala.Tuple2<ByteArray,Iterable<byte[]>> kv)

Uses of ByteArray in org.apache.crunch.impl.spark.serde

Methods in org.apache.crunch.impl.spark.serde that return ByteArray

Modifier and Type	Method and Description
ByteArray	SerDe.toBytes(T obj)
ByteArray	AvroSerDe.toBytes(T obj)
ByteArray	WritableSerDe.toBytes(org.apache.hadoop.io.Writable obj)