harnessopts

Documentation

Overview

Package harnessopts defines user-facing entrypoints into Beam hooks affecting the SDK harness. Call these functions at any time before submitting your pipeline to a runner, for that pipeline's workers to be affected.

Index

• func SampleInterval(samplePeriod time.Duration) error
• func SideInputCacheCapacity(capacity int64) error

Functions

func SampleInterval

func SampleInterval(samplePeriod time.Duration) error

SampleInterval sets the sampling time period (greater than 1ms) for DoFn metrics sampling. Default value is 200ms.

func SideInputCacheCapacity

func SideInputCacheCapacity(capacity int64) error

SideInputCacheCapacity accepts a desired capacity for the side input cache. A non-zero positive integer enables the cache (the capacity of the cache is 0 by default.) Cache use also requires runner support.