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 |
Tuple3.Collect<V1,V2,V3> |
Modifier and Type | Method and Description |
---|---|
static <A,B,C> Tuple3<A,B,C> |
Tuple3.of(A a,
B b,
C c) |
Modifier and Type | Method and Description |
---|---|
static <A,B,C> Extractor<Tuple3<A,B,C>> |
Extractors.xtriple(TokenizerFactory scannerFactory,
Extractor<A> a,
Extractor<B> b,
Extractor<C> c)
Returns an Extractor for triples of the given types that uses the given
TokenizerFactory
for parsing the sub-fields. |
Modifier and Type | Method and Description |
---|---|
static <V1,V2,V3> Aggregator<Tuple3<V1,V2,V3>> |
Aggregators.tripAggregator(Aggregator<V1> a1,
Aggregator<V2> a2,
Aggregator<V3> a3)
Apply separate aggregators to each component of a
Tuple3 . |
Modifier and Type | Method and Description |
---|---|
static <T> PCollection<Tuple3<T,T,T>> |
Set.comm(PCollection<T> coll1,
PCollection<T> coll2)
Find the elements that are common to two sets, like the Unix
comm utility. |
static <V1,V2,V3> PCollection<Tuple3<V1,V2,V3>> |
Sort.sortTriples(PCollection<Tuple3<V1,V2,V3>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of Tuple3 s using the specified column
ordering. |
Modifier and Type | Method and Description |
---|---|
static <V1,V2,V3> PCollection<Tuple3<V1,V2,V3>> |
Sort.sortTriples(PCollection<Tuple3<V1,V2,V3>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of Tuple3 s using the specified column
ordering. |
Modifier and Type | Field and Description |
---|---|
static TupleFactory<Tuple3> |
TupleFactory.TUPLE3 |
Modifier and Type | Method and Description |
---|---|
<V1,V2,V3> PType<Tuple3<V1,V2,V3>> |
PTypeFamily.triples(PType<V1> p1,
PType<V2> p2,
PType<V3> p3) |
Modifier and Type | Method and Description |
---|---|
<V1,V2,V3> PType<Tuple3<V1,V2,V3>> |
AvroTypeFamily.triples(PType<V1> p1,
PType<V2> p2,
PType<V3> p3) |
static <V1,V2,V3> AvroType<Tuple3<V1,V2,V3>> |
Avros.triples(PType<V1> p1,
PType<V2> p2,
PType<V3> p3) |
Modifier and Type | Method and Description |
---|---|
<V1,V2,V3> PType<Tuple3<V1,V2,V3>> |
WritableTypeFamily.triples(PType<V1> p1,
PType<V2> p2,
PType<V3> p3) |
static <V1,V2,V3> WritableType<Tuple3<V1,V2,V3>,TupleWritable> |
Writables.triples(PType<V1> p1,
PType<V2> p2,
PType<V3> p3) |
Modifier and Type | Method and Description |
---|---|
Iterator<Tuple3<A,B,C>> |
Tuples.TripIterable.iterator() |
Copyright © 2016 The Apache Software Foundation. All rights reserved.