This project has retired. For details please refer to its Attic page.
Uses of Interface org.apache.crunch.SourceTarget (Apache Crunch 0.9.0 API)
Overview  Package  Class   Use  Tree  Deprecated  Index 
 PREV   NEXT FRAMES    NO FRAMES    

Uses of Interface
org.apache.crunch.SourceTarget

Packages that use SourceTarget
org.apache.crunch Client-facing API and core abstractions. 
org.apache.crunch.impl.dist   
org.apache.crunch.impl.dist.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 SourceTarget in org.apache.crunch
 

Subinterfaces of SourceTarget in org.apache.crunch
 interface TableSourceTarget<K,V>
          An interface for classes that implement both the TableSource and the Target interfaces.
 

Methods in org.apache.crunch that return SourceTarget
<T> SourceTarget<T>
Target.asSourceTarget(PType<T> ptype)
          Attempt to create the SourceTarget type that corresponds to this Target for the given PType, if possible.
 SourceTarget<T> SourceTarget.conf(String key, String value)
          Adds the given key-value pair to the Configuration instance(s) that are used to read and write this SourceTarget<T>.
 

Methods in org.apache.crunch that return types with arguments of type SourceTarget
 Set<SourceTarget<?>> ReadableData.getSourceTargets()
           
 Set<SourceTarget<?>> ParallelDoOptions.getSourceTargets()
           
 Set<SourceTarget<?>> GroupingOptions.getSourceTargets()
           
 

Methods in org.apache.crunch with parameters of type SourceTarget
 GroupingOptions.Builder GroupingOptions.Builder.sourceTarget(SourceTarget<?> st)
          Deprecated. 
 ParallelDoOptions.Builder ParallelDoOptions.Builder.sourceTargets(SourceTarget<?>... sourceTargets)
           
 GroupingOptions.Builder GroupingOptions.Builder.sourceTargets(SourceTarget<?>... st)
           
 

Method parameters in org.apache.crunch with type arguments of type SourceTarget
 ParallelDoOptions.Builder ParallelDoOptions.Builder.sourceTargets(Collection<SourceTarget<?>> sourceTargets)
           
 GroupingOptions.Builder GroupingOptions.Builder.sourceTargets(Collection<SourceTarget<?>> st)
           
 

Uses of SourceTarget in org.apache.crunch.impl.dist
 

Methods in org.apache.crunch.impl.dist that return SourceTarget
<T> SourceTarget<T>
DistributedPipeline.createIntermediateOutput(PType<T> ptype)
           
 

Uses of SourceTarget in org.apache.crunch.impl.dist.collect
 

Fields in org.apache.crunch.impl.dist.collect declared as SourceTarget
protected  SourceTarget<S> PCollectionImpl.materializedAt
           
 

Methods in org.apache.crunch.impl.dist.collect that return SourceTarget
 SourceTarget<S> PCollectionImpl.getMaterializedAt()
           
 

Methods in org.apache.crunch.impl.dist.collect that return types with arguments of type SourceTarget
 Set<SourceTarget<?>> PCollectionImpl.getTargetDependencies()
           
 Set<SourceTarget<?>> BaseGroupedTable.getTargetDependencies()
           
 

Methods in org.apache.crunch.impl.dist.collect with parameters of type SourceTarget
 void PCollectionImpl.materializeAt(SourceTarget<S> sourceTarget)
           
 

Uses of SourceTarget in org.apache.crunch.io
 

Subinterfaces of SourceTarget in org.apache.crunch.io
 interface ReadableSourceTarget<T>
          An interface that indicates that a SourceTarget instance can be read into the local client.
 

Methods in org.apache.crunch.io that return SourceTarget
static
<T> SourceTarget<T>
At.avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType)
          Creates a SourceTarget<T> instance from the Avro file(s) at the given Path.
static
<T extends org.apache.avro.specific.SpecificRecord>
SourceTarget<T>
At.avroFile(org.apache.hadoop.fs.Path path, Class<T> avroClass)
          Creates a SourceTarget<T> instance from the Avro file(s) at the given Path.
static
<T> SourceTarget<T>
At.avroFile(String pathName, AvroType<T> avroType)
          Creates a SourceTarget<T> instance from the Avro file(s) at the given path name.
static
<T extends org.apache.avro.specific.SpecificRecord>
SourceTarget<T>
At.avroFile(String pathName, Class<T> avroClass)
          Creates a SourceTarget<T> instance from the Avro file(s) at the given path name.
static
<T extends org.apache.hadoop.io.Writable>
SourceTarget<T>
At.sequenceFile(org.apache.hadoop.fs.Path path, Class<T> valueClass)
          Creates a SourceTarget<T> instance from the SequenceFile(s) at the given Path from the value field of each key-value pair in the SequenceFile(s).
static
<T> SourceTarget<T>
At.sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
          Creates a SourceTarget<T> instance from the SequenceFile(s) at the given Path from the value field of each key-value pair in the SequenceFile(s).
static
<T extends org.apache.hadoop.io.Writable>
SourceTarget<T>
At.sequenceFile(String pathName, Class<T> valueClass)
          Creates a SourceTarget<T> instance from the SequenceFile(s) at the given path name from the value field of each key-value pair in the SequenceFile(s).
static
<T> SourceTarget<T>
At.sequenceFile(String pathName, PType<T> ptype)
          Creates a SourceTarget<T> instance from the SequenceFile(s) at the given path name from the value field of each key-value pair in the SequenceFile(s).
static SourceTarget<String> At.textFile(org.apache.hadoop.fs.Path path)
          Creates a SourceTarget<String> instance for the text file(s) at the given Path.
static
<T> SourceTarget<T>
At.textFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
          Creates a SourceTarget<T> instance for the text file(s) at the given Path using the provided PType<T> to convert the input text.
static SourceTarget<String> At.textFile(String pathName)
          Creates a SourceTarget<String> instance for the text file(s) at the given path name.
static
<T> SourceTarget<T>
At.textFile(String pathName, PType<T> ptype)
          Creates a SourceTarget<T> instance for the text file(s) at the given path name using the provided PType<T> to convert the input text.
 

Uses of SourceTarget in org.apache.crunch.io.avro
 

Classes in org.apache.crunch.io.avro that implement SourceTarget
 class AvroFileSourceTarget<T>
           
 

Methods in org.apache.crunch.io.avro that return SourceTarget
<T> SourceTarget<T>
AvroFileTarget.asSourceTarget(PType<T> ptype)
           
 

Uses of SourceTarget in org.apache.crunch.io.avro.trevni
 

Classes in org.apache.crunch.io.avro.trevni that implement SourceTarget
 class TrevniKeySourceTarget<T>
           
 

Methods in org.apache.crunch.io.avro.trevni that return SourceTarget
<T> SourceTarget<T>
TrevniKeyTarget.asSourceTarget(PType<T> ptype)
           
 

Uses of SourceTarget in org.apache.crunch.io.hbase
 

Classes in org.apache.crunch.io.hbase that implement SourceTarget
 class HBaseSourceTarget
           
 

Methods in org.apache.crunch.io.hbase that return SourceTarget
<T> SourceTarget<T>
HBaseTarget.asSourceTarget(PType<T> ptype)
           
 SourceTarget<Pair<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>> HBaseSourceTarget.conf(String key, String value)
           
 

Methods in org.apache.crunch.io.hbase that return types with arguments of type SourceTarget
 Set<SourceTarget<?>> HBaseData.getSourceTargets()
           
 

Constructors in org.apache.crunch.io.hbase with parameters of type SourceTarget
HBaseData(String table, String scanAsString, SourceTarget<?> parent)
           
 

Uses of SourceTarget in org.apache.crunch.io.impl
 

Classes in org.apache.crunch.io.impl that implement SourceTarget
 class ReadableSourcePathTargetImpl<T>
           
 class ReadableSourceTargetImpl<T>
           
 class SourcePathTargetImpl<T>
           
 class TableSourcePathTargetImpl<K,V>
           
 class TableSourceTargetImpl<K,V>
           
 

Methods in org.apache.crunch.io.impl that return SourceTarget
<T> SourceTarget<T>
FileTargetImpl.asSourceTarget(PType<T> ptype)
           
 

Methods in org.apache.crunch.io.impl that return types with arguments of type SourceTarget
 Set<SourceTarget<?>> ReadableDataImpl.getSourceTargets()
           
 

Methods in org.apache.crunch.io.impl with parameters of type SourceTarget
 ReadableData<T> ReadableDataImpl.setParent(SourceTarget<?> parent)
           
 

Uses of SourceTarget in org.apache.crunch.io.parquet
 

Classes in org.apache.crunch.io.parquet that implement SourceTarget
 class AvroParquetFileSourceTarget<T extends IndexedRecord>
           
 

Methods in org.apache.crunch.io.parquet that return SourceTarget
<T> SourceTarget<T>
AvroParquetFileTarget.asSourceTarget(PType<T> ptype)
           
 

Uses of SourceTarget in org.apache.crunch.io.seq
 

Classes in org.apache.crunch.io.seq that implement SourceTarget
 class SeqFileSourceTarget<T>
           
 class SeqFileTableSourceTarget<K,V>
           
 

Methods in org.apache.crunch.io.seq that return SourceTarget
<T> SourceTarget<T>
SeqFileTarget.asSourceTarget(PType<T> ptype)
           
 

Uses of SourceTarget in org.apache.crunch.io.text
 

Classes in org.apache.crunch.io.text that implement SourceTarget
 class TextFileSourceTarget<T>
           
 class TextFileTableSourceTarget<K,V>
          A TableSource and SourceTarget implementation that uses the KeyValueTextInputFormat and TextOutputFormat to support reading and writing text files as PTable instances using a tab separator for the keys and the values.
 

Methods in org.apache.crunch.io.text that return SourceTarget
<T> SourceTarget<T>
TextFileTarget.asSourceTarget(PType<T> ptype)
           
 

Uses of SourceTarget in org.apache.crunch.util
 

Methods in org.apache.crunch.util that return types with arguments of type SourceTarget
 Set<SourceTarget<?>> UnionReadableData.getSourceTargets()
           
 Set<SourceTarget<?>> DelegatingReadableData.getSourceTargets()
           
 

Overview  Package  Class   Use  Tree  Deprecated  Index 
 PREV   NEXT FRAMES    NO FRAMES    
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.