[beam] branch master updated: [BEAM-10994] Add hotKeyLoggingEnabled to the Java DataflowPipelineOptions (#12983)

[lcwik]

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 6e6dd20  [BEAM-10994] Add hotKeyLoggingEnabled to the Java 
DataflowPipelineOptions (#12983)
6e6dd20 is described below

commit 6e6dd203b058dcea2102e3dc224382b603db21e0
Author: Sam sam <rohde.sam...@gmail.com>
AuthorDate: Thu Oct 1 15:21:26 2020 -0700

    [BEAM-10994] Add hotKeyLoggingEnabled to the Java DataflowPipelineOptions 
(#12983)
    
    * Add hotKeyLoggingEnabled to the Java DataflowPipelineOptions
    
    This will ultimately control whether or not the literal hot key content
    is logged to Cloud Logging.
    
    * getHotKeyLoggingEnabled -> isHotKeyLoggingEnabled
    
    Co-authored-by: Lukasz Cwik <lc...@google.com>
    
    * Update 
runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptionsTest.java
    
    Co-authored-by: Lukasz Cwik <lc...@google.com>
---
 .../beam/runners/dataflow/options/DataflowPipelineOptions.java     | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.java
 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.java
index 308e874..69cfb0a 100644
--- 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.java
+++ 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.java
@@ -197,4 +197,11 @@ public interface DataflowPipelineOptions
           .toString();
     }
   }
+
+  /** If enabled then the literal key will be logged to Cloud Logging if a hot 
key is detected. */
+  @Description(
+      "If enabled then the literal key will be logged to Cloud Logging if a 
hot key is detected.")
+  boolean isHotKeyLoggingEnabled();
+
+  void setHotKeyLoggingEnabled(boolean value);
 }