| Package | Description |
|---|---|
| org.apache.crunch |
Client-facing API and core abstractions.
|
| org.apache.crunch.impl.spark.fn | |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
Converter<?,?,?,?> |
Source.getConverter()
Returns the
Converter used for mapping the inputs from this instance
into PCollection or PTable values. |
Converter<?,?,?,?> |
Target.getConverter(PType<?> ptype)
Returns the
Converter to use for mapping from the output PCollection
into the output values expected by this instance. |
| Constructor and Description |
|---|
InputConverterFunction(Converter<K,V,S,?> converter) |
OutputConverterFunction(Converter<K,V,S,?> converter) |
| Modifier and Type | Method and Description |
|---|---|
Converter |
PType.getConverter() |
Converter |
PGroupedTableType.getConverter() |
abstract Converter |
PGroupedTableType.getGroupingConverter() |
| Modifier and Type | Method and Description |
|---|---|
Converter |
AvroType.getConverter() |
| Modifier and Type | Method and Description |
|---|---|
Converter |
WritableType.getConverter() |
Copyright © 2016 The Apache Software Foundation. All rights reserved.