| Package | Description | 
|---|---|
| org.apache.crunch | Client-facing API and core abstractions. | 
| org.apache.crunch.impl.dist.collect | |
| org.apache.crunch.io | Data input and output for Pipelines. | 
| org.apache.crunch.kafka | |
| org.apache.crunch.util | An assorted set of utilities. | 
| Modifier and Type | Method and Description | 
|---|---|
| ReadableData<S> | PCollection. asReadable(boolean materialize) | 
| Modifier and Type | Method and Description | 
|---|---|
| ReadableData<S> | PCollectionImpl. asReadable(boolean materialize) | 
| Modifier and Type | Method and Description | 
|---|---|
| ReadableData<T> | ReadableSource. asReadable() | 
| Modifier and Type | Method and Description | 
|---|---|
| ReadableData<Pair<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>> | KafkaSource. asReadable() | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | DelegatingReadableData<S,T>Implements the  ReadableData<T>interface by delegating to anReadableData<S>instance
 and passing its contents through aDoFn<S, T>. | 
| class  | UnionReadableData<T> | 
| Constructor and Description | 
|---|
| DelegatingReadableData(ReadableData<S> delegate,
                      DoFn<S,T> fn) | 
| Constructor and Description | 
|---|
| UnionReadableData(List<ReadableData<T>> data) | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.