Package | Description |
---|---|
org.apache.hadoop.io |
Generic i/o code for use when reading and writing data to the network,
to databases, and to files.
|
org.apache.hadoop.mapred.join | |
org.apache.hadoop.mapreduce.lib.join | |
org.apache.hadoop.mapreduce.lib.partition | |
org.apache.hadoop.record |
(DEPRECATED) Hadoop record I/O contains classes and a record description language
translator for simplifying serialization and deserialization of records in a
language-neutral manner.
|
Modifier and Type | Method and Description |
---|---|
static WritableComparator |
WritableComparator.get(Class<? extends WritableComparable> c)
For backwards compatibility.
|
static WritableComparator |
WritableComparator.get(Class<? extends WritableComparable> c,
Configuration conf)
Get a comparator for a
WritableComparable implementation. |
Modifier and Type | Method and Description |
---|---|
static void |
WritableComparator.define(Class c,
WritableComparator comparator)
Register an optimized comparator for a
WritableComparable
implementation. |
Modifier and Type | Field and Description |
---|---|
protected Class<? extends WritableComparator> |
Parser.Node.cmpcl |
Modifier and Type | Method and Description |
---|---|
protected WritableComparator |
CompositeRecordReader.getComparator()
Return comparator defining the ordering for RecordReaders in this
composite.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Parser.Node.setKeyComparator(Class<? extends WritableComparator> cmpcl) |
Constructor and Description |
---|
CompositeRecordReader(int id,
int capacity,
Class<? extends WritableComparator> cmpcl)
Create a RecordReader with capacity children to position
id in the parent reader.
|
JoinRecordReader(int id,
JobConf conf,
int capacity,
Class<? extends WritableComparator> cmpcl) |
MultiFilterRecordReader(int id,
JobConf conf,
int capacity,
Class<? extends WritableComparator> cmpcl) |
Modifier and Type | Field and Description |
---|---|
protected WritableComparator |
WrappedRecordReader.cmp |
Modifier and Type | Field and Description |
---|---|
protected Class<? extends WritableComparator> |
Parser.Node.cmpcl |
Modifier and Type | Method and Description |
---|---|
protected WritableComparator |
CompositeRecordReader.getComparator()
Return comparator defining the ordering for RecordReaders in this
composite.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Parser.Node.setKeyComparator(Class<? extends WritableComparator> cmpcl) |
Constructor and Description |
---|
CompositeRecordReader(int id,
int capacity,
Class<? extends WritableComparator> cmpcl)
Create a RecordReader with capacity children to position
id in the parent reader.
|
JoinRecordReader(int id,
Configuration conf,
int capacity,
Class<? extends WritableComparator> cmpcl) |
MultiFilterRecordReader(int id,
Configuration conf,
int capacity,
Class<? extends WritableComparator> cmpcl) |
Modifier and Type | Class and Description |
---|---|
class |
KeyFieldBasedComparator<K,V>
This comparator implementation provides a subset of the features provided
by the Unix/GNU Sort.
|
Modifier and Type | Class and Description |
---|---|
class |
RecordComparator
Deprecated.
Replaced by Avro.
|
Copyright © 2020 Apache Software Foundation. All rights reserved.