S
- Execution stage typepublic abstract class AbstractBlockFactory<S> extends Object implements BlockFactory<S>
Modifier and Type | Field and Description |
---|---|
static StrConfOption |
CONFIGURATORS
Comma separated list of BulkConfigurators, that are going to be called
to simplify specifying of large number of properties.
|
Constructor and Description |
---|
AbstractBlockFactory() |
Modifier and Type | Method and Description |
---|---|
protected void |
additionalInitConfig(GiraphConfiguration conf)
Additional configuration initialization, other then overriding
class specification.
|
protected String[] |
getConvenienceConfiguratorPackages()
Provide list of strings representing packages where configurators will
be searched for, allowing that full path is not required for
CONFIGURATORS option.
|
protected abstract Class<? extends org.apache.hadoop.io.Writable> |
getEdgeValueClass(GiraphConfiguration conf)
Concrete edge value class application will use.
|
List<String> |
getGcJavaOpts(org.apache.hadoop.conf.Configuration conf)
Get special GC Java options.
|
protected abstract Class<? extends org.apache.hadoop.io.WritableComparable> |
getVertexIDClass(GiraphConfiguration conf)
Concrete vertex id class application will use.
|
protected abstract Class<? extends org.apache.hadoop.io.Writable> |
getVertexValueClass(GiraphConfiguration conf)
Concrete vertex value class application will use.
|
protected Class<?> |
getWorkerContextValueClass(GiraphConfiguration conf)
Concrete worker context value class application will use, if overridden.
|
void |
initConfig(GiraphConfiguration conf)
Based on provided configuration, updates it, such that all necessary
properties are initialized.
|
void |
registerOutputs(GiraphConfiguration conf)
Register outputs to use during the application (vs output at the end of
the application), based on provided configuration.
|
protected boolean |
shouldCreateVertexOnMsgs(GiraphConfiguration conf)
Override if vertices shouldn't be created by default, if message is sent
to a vertex that doesn't exist.
|
protected boolean |
shouldSendOneMessageToAll(GiraphConfiguration conf) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createBlock, createExecutionStage
public static final StrConfOption CONFIGURATORS
public List<String> getGcJavaOpts(org.apache.hadoop.conf.Configuration conf)
BlockFactory
getGcJavaOpts
in interface BlockFactory<S>
public final void initConfig(GiraphConfiguration conf)
BlockFactory
initConfig
in interface BlockFactory<S>
public void registerOutputs(GiraphConfiguration conf)
BlockFactory
registerOutputs
in interface BlockFactory<S>
protected void additionalInitConfig(GiraphConfiguration conf)
protected abstract Class<? extends org.apache.hadoop.io.WritableComparable> getVertexIDClass(GiraphConfiguration conf)
protected abstract Class<? extends org.apache.hadoop.io.Writable> getVertexValueClass(GiraphConfiguration conf)
protected abstract Class<? extends org.apache.hadoop.io.Writable> getEdgeValueClass(GiraphConfiguration conf)
protected Class<?> getWorkerContextValueClass(GiraphConfiguration conf)
protected boolean shouldCreateVertexOnMsgs(GiraphConfiguration conf)
protected boolean shouldSendOneMessageToAll(GiraphConfiguration conf)
protected String[] getConvenienceConfiguratorPackages()
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.