Modifier and Type | Field and Description |
---|---|
DataSet |
MR_dataset.dataset |
DataSet |
MR_dataset.dataset |
Modifier and Type | Method and Description |
---|---|
static DataSet |
Plan.binarySource(int source_num,
String file)
The source physical operator for binary files
|
static DataSet |
Plan.binarySource(int source_num,
String file)
The source physical operator for binary files
|
static DataSet |
Plan.binarySource(String file)
The source physical operator for binary files
|
static DataSet |
Plan.binarySource(String file)
The source physical operator for binary files
|
DataSet |
MR_dataset.dataset() |
DataSet |
MR_dataset.dataset() |
abstract DataSet |
Evaluator.eval(Tree e,
Environment env,
String counter)
Evaluate a MRQL physical plan and print tracing info
|
abstract DataSet |
Evaluator.eval(Tree e,
Environment env,
String counter)
Evaluate a MRQL physical plan and print tracing info
|
static DataSet |
Plan.fileCache(Bag s)
The cache operator that dumps a bag into an HDFS file
|
static DataSet |
Plan.fileCache(Bag s)
The cache operator that dumps a bag into an HDFS file
|
static DataSet |
Plan.generator(int source_num,
long min,
long max,
long split_length)
splits the range min..max into multiple ranges, one for each mapper
|
static DataSet |
Plan.generator(int source_num,
long min,
long max,
long split_length)
splits the range min..max into multiple ranges, one for each mapper
|
static DataSet |
Plan.generator(long min,
long max,
long split_length)
splits the range min..max into multiple ranges, one for each mapper
|
static DataSet |
Plan.generator(long min,
long max,
long split_length)
splits the range min..max into multiple ranges, one for each mapper
|
static DataSet |
Plan.merge(DataSet x,
DataSet y)
the DataSet union physical operator
|
static DataSet |
Plan.merge(DataSet x,
DataSet y)
the DataSet union physical operator
|
static DataSet |
Plan.parsedSource(Class<? extends Parser> parser,
String file,
Trees args)
The source physical operator for parsing text files
|
static DataSet |
Plan.parsedSource(Class<? extends Parser> parser,
String file,
Trees args)
The source physical operator for parsing text files
|
static DataSet |
Plan.parsedSource(int source_num,
Class<? extends Parser> parser,
String file,
Trees args)
The source physical operator for parsing text files
|
static DataSet |
Plan.parsedSource(int source_num,
Class<? extends Parser> parser,
String file,
Trees args)
The source physical operator for parsing text files
|
Modifier and Type | Method and Description |
---|---|
abstract Bag |
Evaluator.collect(DataSet x)
collect all data from a persistent dataset into a Bag
|
static Bag |
Plan.collect(DataSet x)
The collect physical operator
|
abstract Bag |
Evaluator.collect(DataSet x)
collect all data from a persistent dataset into a Bag
|
static Bag |
Plan.collect(DataSet x)
The collect physical operator
|
Bag |
MRQLFileInputFormat.collect(DataSet x,
boolean strip)
materialize the entire dataset into a Bag
|
static Bag |
Plan.collect(DataSet x,
boolean strip)
The collect physical operator
|
Bag |
MRQLFileInputFormat.collect(DataSet x,
boolean strip)
materialize the entire dataset into a Bag
|
static Bag |
Plan.collect(DataSet x,
boolean strip)
The collect physical operator
|
void |
DataSet.merge(DataSet ds)
merge this DataSet with the given DataSet
|
void |
DataSet.merge(DataSet ds)
merge this DataSet with the given DataSet
|
static DataSet |
Plan.merge(DataSet x,
DataSet y)
the DataSet union physical operator
|
static DataSet |
Plan.merge(DataSet x,
DataSet y)
the DataSet union physical operator
|
static long |
Plan.size(DataSet s)
return the data set size in bytes
|
static long |
Plan.size(DataSet s)
return the data set size in bytes
|
Constructor and Description |
---|
MR_dataset(DataSet d) |
MR_dataset(DataSet d) |
Copyright © 2013 The Apache Software Foundation. All rights reserved.