This is an automated email from the ASF dual-hosted git repository. aromanenko pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/spark-runner_structured-streaming by this push: new 239bc93 Add setEnableSparkMetricSinks() 239bc93 is described below commit 239bc93f09a095bd40a861150c0030bebf1fe6f1 Author: Alexey Romanenko <aromanenko....@gmail.com> AuthorDate: Mon Jul 8 11:55:47 2019 +0200 Add setEnableSparkMetricSinks() --- .../structuredstreaming/SparkStructuredStreamingPipelineOptions.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineOptions.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineOptions.java index 27743bd..bbf89f6 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineOptions.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineOptions.java @@ -30,4 +30,6 @@ public interface SparkStructuredStreamingPipelineOptions extends SparkCommonPipe @Description("Enable/disable sending aggregator values to Spark's metric sinks") @Default.Boolean(true) Boolean getEnableSparkMetricSinks(); + + void setEnableSparkMetricSinks(Boolean enableSparkMetricSinks); }