Package | Description |
---|---|
org.apache.crunch |
Client-facing API and core abstractions.
|
org.apache.crunch.impl.spark.fn | |
org.apache.crunch.kafka | |
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<?,?,?,?> |
KafkaSource.getConverter() |
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 © 2017 The Apache Software Foundation. All rights reserved.