|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.property.Props cascading.tuple.collect.SpillableProps
public class SpillableProps
Class SpillableProps is a fluent interface for building properties to be passed to a
FlowConnector
before creating new Flow
instances.
SpillableTupleList
,
SpillableTupleMap
Field Summary | |
---|---|
static int |
defaultListThreshold
|
static int |
defaultMapInitialCapacity
|
static float |
defaultMapLoadFactor
|
static int |
defaultMapThreshold
|
static String |
LIST_THRESHOLD
Number of tuples to hold in memory before spilling them to disk. |
static String |
MAP_CAPACITY
The initial hash map capacity. |
static String |
MAP_LOADFACTOR
The initial hash map load factor. |
static String |
MAP_THRESHOLD
The total number of tuple values (not keys) to attempt to keep in memory. |
static String |
SPILL_CODECS
A comma delimited list of possible codecs to try. |
static String |
SPILL_COMPRESS
Whether to enable compress of the spills or not, on by default. |
Constructor Summary | |
---|---|
SpillableProps()
|
Method Summary | |
---|---|
SpillableProps |
addCodec(String codec)
|
SpillableProps |
addCodecs(List<String> codecs)
|
protected void |
addPropertiesTo(Properties properties)
|
List<String> |
getCodecs()
|
int |
getListSpillThreshold()
|
int |
getMapInitialCapacity()
|
float |
getMapLoadFactor()
|
int |
getMapSpillThreshold()
|
boolean |
isCompressSpill()
|
SpillableProps |
setCodecs(List<String> codecs)
|
SpillableProps |
setCompressSpill(boolean compressSpill)
|
SpillableProps |
setListSpillThreshold(int listSpillThreshold)
|
SpillableProps |
setMapInitialCapacity(int mapInitialCapacity)
|
SpillableProps |
setMapLoadFactor(float mapLoadFactor)
|
SpillableProps |
setMapSpillThreshold(int mapSpillThreshold)
|
static SpillableProps |
spillableProps()
|
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 SPILL_COMPRESS
Boolean.parseBoolean(String)
,
Constant Field Valuespublic static final String SPILL_CODECS
public static final String LIST_THRESHOLD
public static final String MAP_THRESHOLD
public static final String MAP_CAPACITY
HashMap
,
Constant Field Valuespublic static final String MAP_LOADFACTOR
HashMap
,
Constant Field Valuespublic static final int defaultListThreshold
public static final int defaultMapThreshold
public static final int defaultMapInitialCapacity
public static final float defaultMapLoadFactor
Constructor Detail |
---|
public SpillableProps()
Method Detail |
---|
public static SpillableProps spillableProps()
public boolean isCompressSpill()
public SpillableProps setCompressSpill(boolean compressSpill)
public List<String> getCodecs()
public SpillableProps setCodecs(List<String> codecs)
public SpillableProps addCodecs(List<String> codecs)
public SpillableProps addCodec(String codec)
public int getListSpillThreshold()
public SpillableProps setListSpillThreshold(int listSpillThreshold)
public int getMapSpillThreshold()
public SpillableProps setMapSpillThreshold(int mapSpillThreshold)
public int getMapInitialCapacity()
public SpillableProps setMapInitialCapacity(int mapInitialCapacity)
public float getMapLoadFactor()
public SpillableProps setMapLoadFactor(float mapLoadFactor)
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 |