public class DataPartitionerLocal extends DataPartitioner
| Constructor and Description |
|---|
DataPartitionerLocal(ParForProgramBlock.PartitionFormat dpf,
int par)
DataPartitionerLocal constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
writeBinaryBlockSequenceFileToHDFS(org.apache.hadoop.mapred.JobConf job,
String dir,
String lpdir,
boolean threadsafe) |
void |
writeBinaryCellSequenceFileToHDFS(org.apache.hadoop.mapred.JobConf job,
String dir,
String lpdir) |
void |
writeTextCellFileToHDFS(org.apache.hadoop.mapred.JobConf job,
String dir,
String lpdir) |
createPartitionedMatrixObject, createPartitionedMatrixObject, createPartitionedMatrixObject, createReuseMatrixBlock, disableBinaryCellpublic DataPartitionerLocal(ParForProgramBlock.PartitionFormat dpf, int par)
dpf - data partitionformatpar - -1 for serial otherwise number of threads, can be ignored by implementationpublic void writeBinaryBlockSequenceFileToHDFS(org.apache.hadoop.mapred.JobConf job,
String dir,
String lpdir,
boolean threadsafe)
throws IOException
IOExceptionpublic void writeBinaryCellSequenceFileToHDFS(org.apache.hadoop.mapred.JobConf job,
String dir,
String lpdir)
throws IOException
IOExceptionpublic void writeTextCellFileToHDFS(org.apache.hadoop.mapred.JobConf job,
String dir,
String lpdir)
throws IOException
IOExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.