|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Serialization.accept(Class)
.
Serialization
interface for use
by BigDecimal
instances.Serialization
interface for use
by byte
arrays (byte[]
).RawComparator
.Partitioner
.Tap
this instance encapsulates.
Tap
class that provides access to the Hadoop Distributed File System.DistributedCache
on read when accessed cluster side.FSInputStream
implementation that can verify a
MessageDigest
and will count the number of bytes read for use in progress status.blocksize
specified by the underlying file system for this resource.
Serialization.getDeserializer(Class)
.
JobClient
managing this Hadoop job.
replication
specified by the underlying file system for
this resource.
RunningJob
managing this Hadoop job.
Serialization.getSerializer(Class)
.
HfsProps
MultiSourceTap
that accepts Hadoop style 'file globing' expressions so
multiple files that match the given pattern may be used as the input sources for a given Flow
.RawComparator
.RawComparator
.Partitioner
.Flow
.Tap
instances with an assembly of Pipe
instances into
an executable HadoopFlow
for execution on an Apache Hadoop cluster.Properties
instance as
default value for the underlying jobs.
FlowProcess
for Hadoop.PlatformTestCase
instance
so that all *PlatformTest classes can be tested against Apache Hadoop.Iterable
object that can store an unlimited number of Tuple
instances by spilling
excess to a temporary disk file.TupleEntryCollector
that writes tuples to the resource managed by
a particular Tap
instance.Tuple
instances available.
Flow
may or may not be required to have set.FileSystem
for accessing remote HTTP and HTTPS data.ObjectSerializer
.Tap
class that provides access to the Local File System via Hadoop.HadoopFlow
subclass that supports custom MapReduce jobs
pre-configured via the JobConf
object.JobConf
and allows it to be executed as a Flow
.CloseableIterator
.Tuple
.
Tuple
instance.Hfs
Tap as the
base path and default Scheme
, and the partition.
Hfs
Tap as the
base path and default Scheme
, and the partition.
Hfs
Tap as the
base path and default Scheme
, and the partition.
Hfs
Tap as the
base path and default Scheme
, and the partition.
Hfs
Tap as the
base path and default Scheme
, and the partition.
RecordReader
instance
via the Iterator
.RawComparator
.Scheme
, which is a flat file consisting of
binary key/value pairs.TupleInputStream
and TupleOutputStream
to substitute Integer values for a class name when writing out nested objects inside a Tuple
.Tap
instance for the give process incoming and outgoing dependencies.
HfsProps
CombineFileInputFormat
for the input format.
CombineFileInputFormat
for the input format.
CombineFileInputFormat
.
CombineFileInputFormat
.
FileSystem
implementations that manage remote resources.Tap
instance for use internally.PartitionTap
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
Hfs
Tap as the
base path and default Scheme
, and the pathTemplate as the Formatter
format String.
HfsProps.TEMPORARY_DIRECTORY
TextLine
.Fields.UNKNOWN
, sinking
Fields.ALL
and using TAB as the default delimiter.
Fields.UNKNOWN
, sinking
Fields.ALL
and using TAB as the default delimiter.
Fields.UNKNOWN
, sinking
Fields.ALL
and using TAB as the default delimiter.
Fields.UNKNOWN
, sinking
Fields.ALL
and using the given delimitedParser instance for parsing.
Fields.UNKNOWN
, sinking
Fields.ALL
and using the given delimitedParser instance for parsing.
Fields.UNKNOWN
, sinking
Fields.ALL
and using the given delimitedParser instance for parsing.
Fields.UNKNOWN
, sinking
Fields.ALL
and using the given delimitedParser instance for parsing.
Fields.UNKNOWN
, sinking
Fields.ALL
and using TAB as the default delimiter.
Scheme
for plain text files.Serialization
interface.FlowConnector
before creating new Flow
instances.SequenceFile
that reads and writes values of the given
writableType
Class
, instead of Tuple
instances used by default in SequenceFile.
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |