[beam] branch spark-runner_structured-streaming updated: Add setEnableSparkMetricSinks() method

[aromanenko]

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 d14a29a  Add setEnableSparkMetricSinks() method
d14a29a is described below

commit d14a29ade55bebf476867eefd0283b9a66af00aa
Author: Alexey Romanenko <aromanenko....@gmail.com>
AuthorDate: Mon Jul 8 18:02:34 2019 +0200

    Add setEnableSparkMetricSinks() method
---
 .../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);
 }