Package | Description |
---|---|
org.apache.crunch |
Client-facing API and core abstractions.
|
org.apache.crunch.contrib.text | |
org.apache.crunch.fn |
Commonly used functions for manipulating collections.
|
org.apache.crunch.lib |
Joining, sorting, aggregating, and other commonly used functionality.
|
org.apache.crunch.types |
Common functionality for business object serialization.
|
org.apache.crunch.types.avro |
Business object serialization using Apache Avro.
|
org.apache.crunch.types.writable |
Business object serialization using Hadoop's Writables framework.
|
org.apache.crunch.util |
An assorted set of utilities.
|
Modifier and Type | Class and Description |
---|---|
static class |
Tuple4.Collect<V1,V2,V3,V4> |
Modifier and Type | Method and Description |
---|---|
static <A,B,C,D> Tuple4<A,B,C,D> |
Tuple4.of(A a,
B b,
C c,
D d) |
Modifier and Type | Method and Description |
---|---|
static <A,B,C,D> Extractor<Tuple4<A,B,C,D>> |
Extractors.xquad(TokenizerFactory scannerFactory,
Extractor<A> a,
Extractor<B> b,
Extractor<C> c,
Extractor<D> d)
Returns an Extractor for quads of the given types that uses the given
TokenizerFactory
for parsing the sub-fields. |
Modifier and Type | Method and Description |
---|---|
static <V1,V2,V3,V4> |
Aggregators.quadAggregator(Aggregator<V1> a1,
Aggregator<V2> a2,
Aggregator<V3> a3,
Aggregator<V4> a4)
Apply separate aggregators to each component of a
Tuple4 . |
Modifier and Type | Method and Description |
---|---|
static <V1,V2,V3,V4> |
Sort.sortQuads(PCollection<Tuple4<V1,V2,V3,V4>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of Tuple4 s using the specified column
ordering. |
Modifier and Type | Method and Description |
---|---|
static <V1,V2,V3,V4> |
Sort.sortQuads(PCollection<Tuple4<V1,V2,V3,V4>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of Tuple4 s using the specified column
ordering. |
Modifier and Type | Field and Description |
---|---|
static TupleFactory<Tuple4> |
TupleFactory.TUPLE4 |
Modifier and Type | Method and Description |
---|---|
<V1,V2,V3,V4> |
PTypeFamily.quads(PType<V1> p1,
PType<V2> p2,
PType<V3> p3,
PType<V4> p4) |
Modifier and Type | Method and Description |
---|---|
<V1,V2,V3,V4> |
AvroTypeFamily.quads(PType<V1> p1,
PType<V2> p2,
PType<V3> p3,
PType<V4> p4) |
static <V1,V2,V3,V4> |
Avros.quads(PType<V1> p1,
PType<V2> p2,
PType<V3> p3,
PType<V4> p4) |
Modifier and Type | Method and Description |
---|---|
<V1,V2,V3,V4> |
WritableTypeFamily.quads(PType<V1> p1,
PType<V2> p2,
PType<V3> p3,
PType<V4> p4) |
static <V1,V2,V3,V4> |
Writables.quads(PType<V1> p1,
PType<V2> p2,
PType<V3> p3,
PType<V4> p4) |
Modifier and Type | Method and Description |
---|---|
Iterator<Tuple4<A,B,C,D>> |
Tuples.QuadIterable.iterator() |
Copyright © 2016 The Apache Software Foundation. All rights reserved.