Package 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 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	Description
DefaultMaxCacheMemoryUsageMb()

Method Summary

Modifier and Type	Method	Description
int	getMaxCacheMemoryUsage(PipelineOptions options)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultMaxCacheMemoryUsageMb

public DefaultMaxCacheMemoryUsageMb()

Method Details

getMaxCacheMemoryUsage

public int getMaxCacheMemoryUsage(PipelineOptions options)

Specified by:

getMaxCacheMemoryUsage in interface SdkHarnessOptions.MaxCacheMemoryUsageMb