|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
| Packages that use ReadableData | |
|---|---|
| org.apache.crunch | Client-facing API and core abstractions. |
| org.apache.crunch.impl.dist.collect | |
| org.apache.crunch.impl.mem.collect | |
| org.apache.crunch.impl.mr.collect | |
| org.apache.crunch.io | Data input and output for Pipelines. |
| org.apache.crunch.io.avro | |
| org.apache.crunch.io.avro.trevni | |
| org.apache.crunch.io.hbase | |
| org.apache.crunch.io.impl | |
| org.apache.crunch.io.parquet | |
| org.apache.crunch.io.seq | |
| org.apache.crunch.io.text | |
| org.apache.crunch.util | An assorted set of utilities. |
| Uses of ReadableData in org.apache.crunch |
|---|
| Methods in org.apache.crunch that return ReadableData | |
|---|---|
ReadableData<S> |
PCollection.asReadable(boolean materialize)
|
| Uses of ReadableData in org.apache.crunch.impl.dist.collect |
|---|
| Methods in org.apache.crunch.impl.dist.collect that return ReadableData | |
|---|---|
ReadableData<S> |
PCollectionImpl.asReadable(boolean materialize)
|
protected abstract ReadableData<S> |
PCollectionImpl.getReadableDataInternal()
|
protected ReadableData<Pair<K,V>> |
BaseUnionTable.getReadableDataInternal()
|
protected ReadableData<S> |
BaseUnionCollection.getReadableDataInternal()
|
protected ReadableData<Pair<K,V>> |
BaseInputTable.getReadableDataInternal()
|
protected ReadableData<S> |
BaseInputCollection.getReadableDataInternal()
|
protected ReadableData<Pair<K,Iterable<V>>> |
BaseGroupedTable.getReadableDataInternal()
|
protected ReadableData<Pair<K,V>> |
BaseDoTable.getReadableDataInternal()
|
protected ReadableData<S> |
BaseDoCollection.getReadableDataInternal()
|
protected ReadableData<S> |
PCollectionImpl.materializedData()
|
| Uses of ReadableData in org.apache.crunch.impl.mem.collect |
|---|
| Methods in org.apache.crunch.impl.mem.collect that return ReadableData | |
|---|---|
ReadableData<S> |
MemCollection.asReadable(boolean materialize)
|
| Uses of ReadableData in org.apache.crunch.impl.mr.collect |
|---|
| Methods in org.apache.crunch.impl.mr.collect that return ReadableData | |
|---|---|
protected ReadableData<S> |
InputCollection.getReadableDataInternal()
|
| Uses of ReadableData in org.apache.crunch.io |
|---|
| Methods in org.apache.crunch.io that return ReadableData | |
|---|---|
ReadableData<T> |
ReadableSource.asReadable()
|
| Uses of ReadableData in org.apache.crunch.io.avro |
|---|
| Classes in org.apache.crunch.io.avro that implement ReadableData | |
|---|---|
class |
AvroReadableData<T>
|
| Methods in org.apache.crunch.io.avro that return ReadableData | |
|---|---|
ReadableData<T> |
AvroFileSource.asReadable()
|
| Uses of ReadableData in org.apache.crunch.io.avro.trevni |
|---|
| Classes in org.apache.crunch.io.avro.trevni that implement ReadableData | |
|---|---|
class |
TrevniReadableData<T>
|
| Methods in org.apache.crunch.io.avro.trevni that return ReadableData | |
|---|---|
ReadableData<T> |
TrevniKeySource.asReadable()
|
| Uses of ReadableData in org.apache.crunch.io.hbase |
|---|
| Classes in org.apache.crunch.io.hbase that implement ReadableData | |
|---|---|
class |
HBaseData
|
class |
HFileReadableData
|
| Methods in org.apache.crunch.io.hbase that return ReadableData | |
|---|---|
ReadableData<org.apache.hadoop.hbase.KeyValue> |
HFileSource.asReadable()
|
ReadableData<Pair<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>> |
HBaseSourceTarget.asReadable()
|
| Uses of ReadableData in org.apache.crunch.io.impl |
|---|
| Classes in org.apache.crunch.io.impl that implement ReadableData | |
|---|---|
class |
ReadableDataImpl<T>
|
| Methods in org.apache.crunch.io.impl that return ReadableData | |
|---|---|
ReadableData<T> |
ReadableSourceTargetImpl.asReadable()
|
ReadableData<T> |
ReadableSourcePathTargetImpl.asReadable()
|
ReadableData<T> |
ReadableDataImpl.setParent(SourceTarget<?> parent)
|
| Uses of ReadableData in org.apache.crunch.io.parquet |
|---|
| Classes in org.apache.crunch.io.parquet that implement ReadableData | |
|---|---|
class |
AvroParquetReadableData<T>
|
| Methods in org.apache.crunch.io.parquet that return ReadableData | |
|---|---|
ReadableData<T> |
AvroParquetFileSource.asReadable()
|
| Uses of ReadableData in org.apache.crunch.io.seq |
|---|
| Classes in org.apache.crunch.io.seq that implement ReadableData | |
|---|---|
class |
SeqFileReadableData<T>
|
| Methods in org.apache.crunch.io.seq that return ReadableData | |
|---|---|
ReadableData<Pair<K,V>> |
SeqFileTableSource.asReadable()
|
ReadableData<T> |
SeqFileSource.asReadable()
|
| Uses of ReadableData in org.apache.crunch.io.text |
|---|
| Classes in org.apache.crunch.io.text that implement ReadableData | |
|---|---|
class |
TextReadableData<T>
|
| Methods in org.apache.crunch.io.text that return ReadableData | |
|---|---|
ReadableData<Pair<K,V>> |
TextFileTableSource.asReadable()
|
ReadableData<T> |
TextFileSource.asReadable()
|
ReadableData<T> |
NLineFileSource.asReadable()
|
| Uses of ReadableData in org.apache.crunch.util |
|---|
| Classes in org.apache.crunch.util that implement ReadableData | |
|---|---|
class |
DelegatingReadableData<S,T>
Implements the ReadableData<T> interface by delegating to an ReadableData<S> instance
and passing its contents through a DoFn<S, T>. |
class |
UnionReadableData<T>
|
| Constructors in org.apache.crunch.util with parameters of type ReadableData | |
|---|---|
DelegatingReadableData(ReadableData<S> delegate,
DoFn<S,T> fn)
|
|
| Constructor parameters in org.apache.crunch.util with type arguments of type ReadableData | |
|---|---|
UnionReadableData(List<ReadableData<T>> data)
|
|
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||