|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.property.Props cascading.flow.FlowProps
public class FlowProps
Class FlowProps is a fluent helper class for setting Flow
specific properties through
a FlowConnector
.
AppProps
,
CascadeProps
,
FlowConnectorProps
Field Summary | |
---|---|
static String |
DEFAULT_ELEMENT_COMPARATOR
|
static String |
JOB_POLLING_INTERVAL
|
static String |
MAX_CONCURRENT_STEPS
|
static String |
PRESERVE_TEMPORARY_FILES
|
static String |
STOP_JOBS_ON_EXIT
|
Constructor Summary | |
---|---|
FlowProps()
|
Method Summary | |
---|---|
protected void |
addPropertiesTo(Properties properties)
|
String |
getDefaultTupleElementComparator()
|
int |
getJobPollingInterval()
|
int |
getMaxConcurrentSteps()
|
boolean |
isPreserveTemporaryFiles()
|
boolean |
isStopJobsOnExit()
|
static void |
setDefaultTupleElementComparator(Map<Object,Object> properties,
String className)
Sets a default Comparator to be used if no Comparator can be found for the class via the
Comparison interface. |
FlowProps |
setDefaultTupleElementComparator(String defaultTupleElementComparator)
|
FlowProps |
setJobPollingInterval(int jobPollingInterval)
|
static void |
setJobPollingInterval(Map<Object,Object> properties,
long interval)
Property jobPollingInterval will set the time to wait between polling the remote server for the status of a job. |
FlowProps |
setMaxConcurrentSteps(int maxConcurrentSteps)
|
static void |
setMaxConcurrentSteps(Map<Object,Object> properties,
int numConcurrentSteps)
Method setMaxConcurrentSteps sets the maximum number of steps that a Flow can run concurrently. |
FlowProps |
setPreserveTemporaryFiles(boolean preserveTemporaryFiles)
|
static void |
setPreserveTemporaryFiles(Map<Object,Object> properties,
boolean preserveTemporaryFiles)
Property preserveTemporaryFiles forces the Flow instance to keep any temporary intermediate data sets. |
FlowProps |
setStopJobsOnExit(boolean stopJobsOnExit)
|
static void |
setStopJobsOnExit(Map<Object,Object> properties,
boolean stopJobsOnExit)
Property stopJobsOnExit will tell the Flow to add a JVM shutdown hook that will kill all running processes if the underlying computing system supports it. |
Methods inherited from class cascading.property.Props |
---|
buildProperties, buildProperties, buildProperties, buildProperties, setProperties, setProperties |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String DEFAULT_ELEMENT_COMPARATOR
public static final String PRESERVE_TEMPORARY_FILES
public static final String JOB_POLLING_INTERVAL
public static final String MAX_CONCURRENT_STEPS
public static final String STOP_JOBS_ON_EXIT
Constructor Detail |
---|
public FlowProps()
Method Detail |
---|
public static void setDefaultTupleElementComparator(Map<Object,Object> properties, String className)
Comparator
to be used if no Comparator can be found for the class via the
Comparison
interface.
In the case of Hadoop, if the Comparator instance also implements Configurable
, the
Configurable
will be called.
In local mode, only the default constructor will be called for the comparator.
properties
- className
- public static void setPreserveTemporaryFiles(Map<Object,Object> properties, boolean preserveTemporaryFiles)
false
.
properties
- of type MappreserveTemporaryFiles
- of type booleanpublic static void setJobPollingInterval(Map<Object,Object> properties, long interval)
properties
- of type Mapinterval
- of type longpublic static void setMaxConcurrentSteps(Map<Object,Object> properties, int numConcurrentSteps)
properties
- of type Mappublic static void setStopJobsOnExit(Map<Object,Object> properties, boolean stopJobsOnExit)
true
.
properties
- of type MapstopJobsOnExit
- of type booleanpublic String getDefaultTupleElementComparator()
public FlowProps setDefaultTupleElementComparator(String defaultTupleElementComparator)
public boolean isPreserveTemporaryFiles()
public FlowProps setPreserveTemporaryFiles(boolean preserveTemporaryFiles)
public int getJobPollingInterval()
public FlowProps setJobPollingInterval(int jobPollingInterval)
public int getMaxConcurrentSteps()
public FlowProps setMaxConcurrentSteps(int maxConcurrentSteps)
public boolean isStopJobsOnExit()
public FlowProps setStopJobsOnExit(boolean stopJobsOnExit)
protected void addPropertiesTo(Properties properties)
addPropertiesTo
in class Props
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |