org.apache.beam.sdk.options

Class SdkHarnessOptions.DefaultMaxCacheMemoryUsageMb

java.lang.Object

org.apache.beam.sdk.options.SdkHarnessOptions.DefaultMaxCacheMemoryUsageMb

All Implemented Interfaces:

SdkHarnessOptions.MaxCacheMemoryUsageMb

Enclosing interface:

SdkHarnessOptions

public static class SdkHarnessOptions.DefaultMaxCacheMemoryUsageMb
extends java.lang.Object
implements SdkHarnessOptions.MaxCacheMemoryUsageMb

The default implementation which detects how much memory to use for a process wide cache.

If the Runtime provides a maximum amount of memory (typically specified with -Xmx JVM argument), then maxCacheMemoryUsagePercent will be used to compute the upper bound as a percentage of the maximum amount of memory. Otherwise 100 is returned.

Constructor Summary

Constructors

Constructor and Description
DefaultMaxCacheMemoryUsageMb()

Method Summary

Modifier and Type	Method and Description
int	getMaxCacheMemoryUsage(PipelineOptions options)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMaxCacheMemoryUsageMb

public DefaultMaxCacheMemoryUsageMb()

Method Detail

getMaxCacheMemoryUsage

public int getMaxCacheMemoryUsage(PipelineOptions options)

Specified by:

getMaxCacheMemoryUsage in interface SdkHarnessOptions.MaxCacheMemoryUsageMb