public final class QJob extends Object
See Mahout-376 working notes for details.
Uses some of Hadoop deprecated api wherever newer api is not available. Hence, @SuppressWarnings("deprecation") for imports (MAHOUT-593).
Modifier and Type | Class and Description |
---|---|
static class |
QJob.QMapper |
Modifier and Type | Field and Description |
---|---|
static String |
OUTPUT_QHAT |
static String |
OUTPUT_RHAT |
static String |
PROP_AROWBLOCK_SIZE |
static String |
PROP_K |
static String |
PROP_OMEGA_SEED |
static String |
PROP_P |
static String |
PROP_SB_PATH |
Modifier and Type | Method and Description |
---|---|
static void |
run(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path[] inputPaths,
org.apache.hadoop.fs.Path sbPath,
org.apache.hadoop.fs.Path outputPath,
int aBlockRows,
int minSplitSize,
int k,
int p,
long seed,
int numReduceTasks) |
public static final String PROP_OMEGA_SEED
public static final String PROP_K
public static final String PROP_P
public static final String PROP_SB_PATH
public static final String PROP_AROWBLOCK_SIZE
public static final String OUTPUT_RHAT
public static final String OUTPUT_QHAT
public static void run(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path[] inputPaths, org.apache.hadoop.fs.Path sbPath, org.apache.hadoop.fs.Path outputPath, int aBlockRows, int minSplitSize, int k, int p, long seed, int numReduceTasks) throws ClassNotFoundException, InterruptedException, IOException
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.