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 ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SampleInterval ¶
SampleInterval sets the sampling time period (greater than 1ms) for DoFn metrics sampling. Default value is 200ms.
func SideInputCacheCapacity ¶
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.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.