|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of InputSplit in org.apache.hadoop.mapred |
---|
Subclasses of InputSplit in org.apache.hadoop.mapred | |
---|---|
class |
FileSplit
A section of an input file. |
class |
MultiFileSplit
A sub-collection of input files. |
Uses of InputSplit in org.apache.hadoop.mapred.lib |
---|
Methods in org.apache.hadoop.mapred.lib with parameters of type InputSplit | |
---|---|
RecordReader<K,V> |
CombineFileInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
|
Uses of InputSplit in org.apache.hadoop.mapreduce |
---|
Methods in org.apache.hadoop.mapreduce that return InputSplit | |
---|---|
InputSplit |
MapContext.getInputSplit()
Get the input split for this map. |
Methods in org.apache.hadoop.mapreduce that return types with arguments of type InputSplit | |
---|---|
abstract List<InputSplit> |
InputFormat.getSplits(JobContext context)
Logically split the set of input files for the job. |
Methods in org.apache.hadoop.mapreduce with parameters of type InputSplit | |
---|---|
abstract RecordReader<K,V> |
InputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
Create a record reader for a given split. |
abstract void |
RecordReader.initialize(InputSplit split,
TaskAttemptContext context)
Called once at initialization. |
Uses of InputSplit in org.apache.hadoop.mapreduce.lib.db |
---|
Methods in org.apache.hadoop.mapreduce.lib.db that return types with arguments of type InputSplit | |
---|---|
List<InputSplit> |
DBInputFormat.getSplits(JobContext job)
Logically split the set of input files for the job. |
List<InputSplit> |
DataDrivenDBInputFormat.getSplits(JobContext job)
Logically split the set of input files for the job. |
List<InputSplit> |
TextSplitter.split(Configuration conf,
ResultSet results,
String colName)
This method needs to determine the splits between two user-provided strings. |
List<InputSplit> |
DBSplitter.split(Configuration conf,
ResultSet results,
String colName)
Given a ResultSet containing one record (and already advanced to that record) with two columns (a low value, and a high value, both of the same type), determine a set of splits that span the given values. |
List<InputSplit> |
IntegerSplitter.split(Configuration conf,
ResultSet results,
String colName)
|
List<InputSplit> |
DateSplitter.split(Configuration conf,
ResultSet results,
String colName)
|
List<InputSplit> |
FloatSplitter.split(Configuration conf,
ResultSet results,
String colName)
|
List<InputSplit> |
BigDecimalSplitter.split(Configuration conf,
ResultSet results,
String colName)
|
List<InputSplit> |
BooleanSplitter.split(Configuration conf,
ResultSet results,
String colName)
|
Methods in org.apache.hadoop.mapreduce.lib.db with parameters of type InputSplit | |
---|---|
RecordReader<LongWritable,T> |
DBInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
Create a record reader for a given split. |
void |
DBRecordReader.initialize(InputSplit split,
TaskAttemptContext context)
|
Uses of InputSplit in org.apache.hadoop.mapreduce.lib.input |
---|
Subclasses of InputSplit in org.apache.hadoop.mapreduce.lib.input | |
---|---|
class |
CombineFileSplit
A sub-collection of input files. |
Methods in org.apache.hadoop.mapreduce.lib.input that return types with arguments of type InputSplit | |
---|---|
List<InputSplit> |
FileInputFormat.getSplits(JobContext job)
Generate the list of files and make them into FileSplits. |
List<InputSplit> |
CombineFileInputFormat.getSplits(JobContext job)
|
List<InputSplit> |
NLineInputFormat.getSplits(JobContext job)
Logically splits the set of input files for the job, splits N lines of the input as one split. |
Uses of InputSplit in org.apache.hadoop.mapreduce.lib.join |
---|
Subclasses of InputSplit in org.apache.hadoop.mapreduce.lib.join | |
---|---|
class |
CompositeInputSplit
This InputSplit contains a set of child InputSplits. |
Methods in org.apache.hadoop.mapreduce.lib.join that return InputSplit | |
---|---|
InputSplit |
CompositeInputSplit.get(int i)
Get ith child InputSplit. |
Methods in org.apache.hadoop.mapreduce.lib.join that return types with arguments of type InputSplit | |
---|---|
List<InputSplit> |
CompositeInputFormat.getSplits(JobContext job)
Build a CompositeInputSplit from the child InputFormats by assigning the ith split from each child to the ith composite split. |
Methods in org.apache.hadoop.mapreduce.lib.join with parameters of type InputSplit | |
---|---|
void |
CompositeInputSplit.add(InputSplit s)
Add an InputSplit to this collection. |
abstract ComposableRecordReader<K,V> |
ComposableInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context)
|
RecordReader<K,TupleWritable> |
CompositeInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext taskContext)
Construct a CompositeRecordReader for the children of this InputFormat as defined in the init expression. |
void |
MultiFilterRecordReader.initialize(InputSplit split,
TaskAttemptContext context)
|
void |
CompositeRecordReader.initialize(InputSplit split,
TaskAttemptContext context)
|
void |
WrappedRecordReader.initialize(InputSplit split,
TaskAttemptContext context)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |