com.exalead.mercury.mami.consolidation.v10

Class AdvancedAggregationConfig

java.lang.Object

com.exalead.mercury.mami.consolidation.v10.AdvancedAggregationConfig

All Implemented Interfaces:

com.exalead.util.Checkable, java.io.Serializable

public class AdvancedAggregationConfig
extends java.lang.Object
implements com.exalead.util.Checkable, java.io.Serializable

No documentation for this element.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
int	aggregatedVerticesCacheSize Deprecated.
int	aggregationQueueSize
boolean	countCheckpointAsATask
static int	DEFAULT_AGGREGATED_VERTICES_CACHE_SIZE
static int	DEFAULT_AGGREGATION_QUEUE_SIZE
static boolean	DEFAULT_COUNT_CHECKPOINT_AS_A_TASK
static boolean	DEFAULT_DISABLE_CHECKPOINT_FORWARDING
static int	DEFAULT_FORWARD_QUEUE_SIZE
static int	DEFAULT_IMPACT_DETECTION_RESULT_CACHE_MAX_FILE_SIZE_IN_BYTES
static int	DEFAULT_IMPACT_QUEUE_SIZE
static int	DEFAULT_LOG_COUNT_IMPACTED_VERTICES
static int	DEFAULT_META_COUNT_LOG_THRESHOLD
static long	DEFAULT_PROGRESSION_SAVE_THRESHOLD_IN_M_S
static int	DEFAULT_VERTEX_CACHE_SIZE
boolean	disableCheckpointForwarding
int	forwardQueueSize
int	impactDetectionResultCacheMaxFileSizeInBytes
int	impactQueueSize
int	logCountImpactedVertices
int	metaCountLogThreshold
long	progressionSaveThresholdInMS
int	vertexCacheSize

Constructor Summary

Constructors

Constructor and Description
AdvancedAggregationConfig()
AdvancedAggregationConfig(AdvancedAggregationConfig o) Copy constructor

Method Summary

Modifier and Type	Method and Description
void	check(boolean deep, java.lang.String errorContext) Checks this AdvancedAggregationConfig.
static AdvancedAggregationConfig	fromString(java.lang.String s) String representation of this AdvancedAggregationConfig.
int	getAggregatedVerticesCacheSize() Deprecated.
int	getAggregationQueueSize()
int	getForwardQueueSize()
int	getImpactDetectionResultCacheMaxFileSizeInBytes()
int	getImpactQueueSize()
int	getLogCountImpactedVertices() Possible values: -1: disabled (default value) 0: log all N: log only if the number of vertices impacted is greater than or equals to N
int	getMetaCountLogThreshold() Possible values: -1: disabled (default value) N: log only if the number of values for a meta is greater than or equals to N
long	getProgressionSaveThresholdInMS()
int	getVertexCacheSize()
boolean	isCountCheckpointAsATask()
boolean	isDisableCheckpointForwarding()
AdvancedAggregationConfig	makeCopy() Creates and returns a deep copy of this AdvancedAggregationConfig.
static AdvancedAggregationConfig	readFrom(java.io.InputStream is) Read this AdvancedAggregationConfig from an XML fragment.
void	setAggregatedVerticesCacheSize(int aggregatedVerticesCacheSize) Deprecated.
void	setAggregationQueueSize(int aggregationQueueSize)
void	setCountCheckpointAsATask(boolean countCheckpointAsATask)
void	setDisableCheckpointForwarding(boolean disableCheckpointForwarding)
void	setForwardQueueSize(int forwardQueueSize)
void	setImpactDetectionResultCacheMaxFileSizeInBytes(int impactDetectionResultCacheMaxFileSizeInBytes)
void	setImpactQueueSize(int impactQueueSize)
void	setLogCountImpactedVertices(int logCountImpactedVertices) Possible values: -1: disabled (default value) 0: log all N: log only if the number of vertices impacted is greater than or equals to N
void	setMetaCountLogThreshold(int metaCountLogThreshold) Possible values: -1: disabled (default value) N: log only if the number of values for a meta is greater than or equals to N
void	setProgressionSaveThresholdInMS(long progressionSaveThresholdInMS)
void	setVertexCacheSize(int vertexCacheSize)
java.lang.String	toString() String representation of this AdvancedAggregationConfig.
AdvancedAggregationConfig	withAggregatedVerticesCacheSize(int aggregatedVerticesCacheSize) Deprecated.
AdvancedAggregationConfig	withAggregatedVerticesCacheSize(java.lang.Integer aggregatedVerticesCacheSize) Deprecated.
AdvancedAggregationConfig	withAggregationQueueSize(int aggregationQueueSize)
AdvancedAggregationConfig	withAggregationQueueSize(java.lang.Integer aggregationQueueSize)
AdvancedAggregationConfig	withCountCheckpointAsATask(boolean countCheckpointAsATask)
AdvancedAggregationConfig	withCountCheckpointAsATask(java.lang.Boolean countCheckpointAsATask)
AdvancedAggregationConfig	withDisableCheckpointForwarding(boolean disableCheckpointForwarding)
AdvancedAggregationConfig	withDisableCheckpointForwarding(java.lang.Boolean disableCheckpointForwarding)
AdvancedAggregationConfig	withForwardQueueSize(int forwardQueueSize)
AdvancedAggregationConfig	withForwardQueueSize(java.lang.Integer forwardQueueSize)
AdvancedAggregationConfig	withImpactDetectionResultCacheMaxFileSizeInBytes(int impactDetectionResultCacheMaxFileSizeInBytes)
AdvancedAggregationConfig	withImpactDetectionResultCacheMaxFileSizeInBytes(java.lang.Integer impactDetectionResultCacheMaxFileSizeInBytes)
AdvancedAggregationConfig	withImpactQueueSize(int impactQueueSize)
AdvancedAggregationConfig	withImpactQueueSize(java.lang.Integer impactQueueSize)
AdvancedAggregationConfig	withLogCountImpactedVertices(int logCountImpactedVertices)
AdvancedAggregationConfig	withLogCountImpactedVertices(java.lang.Integer logCountImpactedVertices)
AdvancedAggregationConfig	withMetaCountLogThreshold(int metaCountLogThreshold)
AdvancedAggregationConfig	withMetaCountLogThreshold(java.lang.Integer metaCountLogThreshold)
AdvancedAggregationConfig	withProgressionSaveThresholdInMS(long progressionSaveThresholdInMS)
AdvancedAggregationConfig	withProgressionSaveThresholdInMS(java.lang.Long progressionSaveThresholdInMS)
AdvancedAggregationConfig	withVertexCacheSize(int vertexCacheSize)
AdvancedAggregationConfig	withVertexCacheSize(java.lang.Integer vertexCacheSize)
void	writeTo(java.io.OutputStream os) Write this AdvancedAggregationConfig as an XML fragment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

impactQueueSize

public int impactQueueSize

DEFAULT_IMPACT_QUEUE_SIZE

public static final int DEFAULT_IMPACT_QUEUE_SIZE

See Also:

Constant Field Values

aggregationQueueSize

public int aggregationQueueSize

DEFAULT_AGGREGATION_QUEUE_SIZE

public static final int DEFAULT_AGGREGATION_QUEUE_SIZE

See Also:

Constant Field Values

forwardQueueSize

public int forwardQueueSize

DEFAULT_FORWARD_QUEUE_SIZE

public static final int DEFAULT_FORWARD_QUEUE_SIZE

See Also:

Constant Field Values

aggregatedVerticesCacheSize

@Deprecated
public int aggregatedVerticesCacheSize

Deprecated.

DEFAULT_AGGREGATED_VERTICES_CACHE_SIZE

public static final int DEFAULT_AGGREGATED_VERTICES_CACHE_SIZE

See Also:

Constant Field Values

vertexCacheSize

public int vertexCacheSize

DEFAULT_VERTEX_CACHE_SIZE

public static final int DEFAULT_VERTEX_CACHE_SIZE

See Also:

Constant Field Values

impactDetectionResultCacheMaxFileSizeInBytes

public int impactDetectionResultCacheMaxFileSizeInBytes

DEFAULT_IMPACT_DETECTION_RESULT_CACHE_MAX_FILE_SIZE_IN_BYTES

public static final int DEFAULT_IMPACT_DETECTION_RESULT_CACHE_MAX_FILE_SIZE_IN_BYTES

See Also:

Constant Field Values

logCountImpactedVertices

public int logCountImpactedVertices

DEFAULT_LOG_COUNT_IMPACTED_VERTICES

public static final int DEFAULT_LOG_COUNT_IMPACTED_VERTICES

See Also:

Constant Field Values

metaCountLogThreshold

public int metaCountLogThreshold

DEFAULT_META_COUNT_LOG_THRESHOLD

public static final int DEFAULT_META_COUNT_LOG_THRESHOLD

See Also:

Constant Field Values

disableCheckpointForwarding

public boolean disableCheckpointForwarding

DEFAULT_DISABLE_CHECKPOINT_FORWARDING

public static final boolean DEFAULT_DISABLE_CHECKPOINT_FORWARDING

See Also:

Constant Field Values

countCheckpointAsATask

public boolean countCheckpointAsATask

DEFAULT_COUNT_CHECKPOINT_AS_A_TASK

public static final boolean DEFAULT_COUNT_CHECKPOINT_AS_A_TASK

See Also:

Constant Field Values

progressionSaveThresholdInMS

public long progressionSaveThresholdInMS

DEFAULT_PROGRESSION_SAVE_THRESHOLD_IN_M_S

public static final long DEFAULT_PROGRESSION_SAVE_THRESHOLD_IN_M_S

See Also:

Constant Field Values

Constructor Detail

AdvancedAggregationConfig

public AdvancedAggregationConfig()

AdvancedAggregationConfig

public AdvancedAggregationConfig(AdvancedAggregationConfig o)

Copy constructor

Method Detail

setImpactQueueSize

public void setImpactQueueSize(int impactQueueSize)

getImpactQueueSize

public int getImpactQueueSize()

withImpactQueueSize

public AdvancedAggregationConfig withImpactQueueSize(int impactQueueSize)

withImpactQueueSize

public AdvancedAggregationConfig withImpactQueueSize(java.lang.Integer impactQueueSize)

setAggregationQueueSize

public void setAggregationQueueSize(int aggregationQueueSize)

getAggregationQueueSize

public int getAggregationQueueSize()

withAggregationQueueSize

public AdvancedAggregationConfig withAggregationQueueSize(int aggregationQueueSize)

withAggregationQueueSize

public AdvancedAggregationConfig withAggregationQueueSize(java.lang.Integer aggregationQueueSize)

setForwardQueueSize

public void setForwardQueueSize(int forwardQueueSize)

getForwardQueueSize

public int getForwardQueueSize()

withForwardQueueSize

public AdvancedAggregationConfig withForwardQueueSize(int forwardQueueSize)

withForwardQueueSize

public AdvancedAggregationConfig withForwardQueueSize(java.lang.Integer forwardQueueSize)

setAggregatedVerticesCacheSize

@Deprecated
public void setAggregatedVerticesCacheSize(int aggregatedVerticesCacheSize)

Deprecated.

Deprecated since V6R2016xR4, a dedup on impact detection results is now performed before running the aggregation

getAggregatedVerticesCacheSize

@Deprecated
public int getAggregatedVerticesCacheSize()

Deprecated.

Deprecated since V6R2016xR4, a dedup on impact detection results is now performed before running the aggregation

withAggregatedVerticesCacheSize

@Deprecated
public AdvancedAggregationConfig withAggregatedVerticesCacheSize(int aggregatedVerticesCacheSize)

Deprecated.

withAggregatedVerticesCacheSize

@Deprecated
public AdvancedAggregationConfig withAggregatedVerticesCacheSize(java.lang.Integer aggregatedVerticesCacheSize)

Deprecated.

setVertexCacheSize

public void setVertexCacheSize(int vertexCacheSize)

getVertexCacheSize

public int getVertexCacheSize()

withVertexCacheSize

public AdvancedAggregationConfig withVertexCacheSize(int vertexCacheSize)

withVertexCacheSize

public AdvancedAggregationConfig withVertexCacheSize(java.lang.Integer vertexCacheSize)

setImpactDetectionResultCacheMaxFileSizeInBytes

public void setImpactDetectionResultCacheMaxFileSizeInBytes(int impactDetectionResultCacheMaxFileSizeInBytes)

getImpactDetectionResultCacheMaxFileSizeInBytes

public int getImpactDetectionResultCacheMaxFileSizeInBytes()

withImpactDetectionResultCacheMaxFileSizeInBytes

public AdvancedAggregationConfig withImpactDetectionResultCacheMaxFileSizeInBytes(int impactDetectionResultCacheMaxFileSizeInBytes)

withImpactDetectionResultCacheMaxFileSizeInBytes

public AdvancedAggregationConfig withImpactDetectionResultCacheMaxFileSizeInBytes(java.lang.Integer impactDetectionResultCacheMaxFileSizeInBytes)

setLogCountImpactedVertices

public void setLogCountImpactedVertices(int logCountImpactedVertices)

Possible values:

• -1: disabled (default value)
• 0: log all
• N: log only if the number of vertices impacted is greater than or equals to N

getLogCountImpactedVertices

public int getLogCountImpactedVertices()

Possible values:

• -1: disabled (default value)
• 0: log all
• N: log only if the number of vertices impacted is greater than or equals to N

withLogCountImpactedVertices

public AdvancedAggregationConfig withLogCountImpactedVertices(int logCountImpactedVertices)

withLogCountImpactedVertices

public AdvancedAggregationConfig withLogCountImpactedVertices(java.lang.Integer logCountImpactedVertices)

setMetaCountLogThreshold

public void setMetaCountLogThreshold(int metaCountLogThreshold)

Possible values:

• -1: disabled (default value)
• N: log only if the number of values for a meta is greater than or equals to N

getMetaCountLogThreshold

public int getMetaCountLogThreshold()

Possible values:

• -1: disabled (default value)
• N: log only if the number of values for a meta is greater than or equals to N

withMetaCountLogThreshold

public AdvancedAggregationConfig withMetaCountLogThreshold(int metaCountLogThreshold)

withMetaCountLogThreshold

public AdvancedAggregationConfig withMetaCountLogThreshold(java.lang.Integer metaCountLogThreshold)

setDisableCheckpointForwarding

public void setDisableCheckpointForwarding(boolean disableCheckpointForwarding)

isDisableCheckpointForwarding

public boolean isDisableCheckpointForwarding()

withDisableCheckpointForwarding

public AdvancedAggregationConfig withDisableCheckpointForwarding(boolean disableCheckpointForwarding)

withDisableCheckpointForwarding

public AdvancedAggregationConfig withDisableCheckpointForwarding(java.lang.Boolean disableCheckpointForwarding)

setCountCheckpointAsATask

public void setCountCheckpointAsATask(boolean countCheckpointAsATask)

isCountCheckpointAsATask

public boolean isCountCheckpointAsATask()

withCountCheckpointAsATask

public AdvancedAggregationConfig withCountCheckpointAsATask(boolean countCheckpointAsATask)

withCountCheckpointAsATask

public AdvancedAggregationConfig withCountCheckpointAsATask(java.lang.Boolean countCheckpointAsATask)

setProgressionSaveThresholdInMS

public void setProgressionSaveThresholdInMS(long progressionSaveThresholdInMS)

getProgressionSaveThresholdInMS

public long getProgressionSaveThresholdInMS()

withProgressionSaveThresholdInMS

public AdvancedAggregationConfig withProgressionSaveThresholdInMS(long progressionSaveThresholdInMS)

withProgressionSaveThresholdInMS

public AdvancedAggregationConfig withProgressionSaveThresholdInMS(java.lang.Long progressionSaveThresholdInMS)

makeCopy

public AdvancedAggregationConfig makeCopy()

Creates and returns a deep copy of this AdvancedAggregationConfig.

readFrom

public static AdvancedAggregationConfig readFrom(java.io.InputStream is)
                                          throws javax.xml.bind.JAXBException

Read this AdvancedAggregationConfig from an XML fragment.

Throws:

javax.xml.bind.JAXBException

writeTo

public void writeTo(java.io.OutputStream os)
             throws javax.xml.bind.JAXBException,
                    java.io.IOException

Write this AdvancedAggregationConfig as an XML fragment

Throws:

javax.xml.bind.JAXBException

java.io.IOException

fromString

public static AdvancedAggregationConfig fromString(java.lang.String s)
                                            throws javax.xml.bind.JAXBException,
                                                   java.io.UnsupportedEncodingException

String representation of this AdvancedAggregationConfig.

Throws:

javax.xml.bind.JAXBException

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

String representation of this AdvancedAggregationConfig.

Overrides:

toString in class java.lang.Object

check

public void check(boolean deep,
                  java.lang.String errorContext)
           throws com.exalead.util.TypedException

Checks this AdvancedAggregationConfig.

Specified by:

check in interface com.exalead.util.Checkable

Throws:

com.exalead.util.TypedException