[flink] 05/24: [FLINK-XXXXX] Add the internal IS_PYTHON method

[kkloudas]

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

kkloudas pushed a commit to branch executors
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 892a2ac785dc15ede49ba2198720aa423544f1af
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Mon Nov 4 15:00:34 2019 +0100

    [FLINK-XXXXX] Add the internal IS_PYTHON method
---
 .../org/apache/flink/client/cli/ExecutionConfigAccessor.java  |  5 +++++
 .../java/org/apache/flink/configuration/PipelineOptions.java  | 11 +++++++++++
 2 files changed, 16 insertions(+)

diff --git 
a/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
 
b/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
index c7f8e55..5bb524d 100644
--- 
a/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
+++ 
b/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
@@ -65,6 +65,7 @@ public class ExecutionConfigAccessor {
                        
configuration.setInteger(CoreOptions.DEFAULT_PARALLELISM, 
options.getParallelism());
                }
 
+               configuration.setBoolean(PipelineOptions.Internal.IS_PYTHON, 
options.isPython());
                configuration.setBoolean(ExecutionOptions.ATTACHED, 
!options.getDetachedMode());
                configuration.setBoolean(ExecutionOptions.SHUTDOWN_IF_ATTACHED, 
options.isShutdownOnAttachedExit());
 
@@ -128,4 +129,8 @@ public class ExecutionConfigAccessor {
        public boolean isShutdownOnAttachedExit() {
                return 
configuration.getBoolean(ExecutionOptions.SHUTDOWN_IF_ATTACHED);
        }
+
+       public boolean isPython() {
+               return 
configuration.getBoolean(PipelineOptions.Internal.IS_PYTHON);
+       }
 }
diff --git 
a/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java 
b/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
index 6b2c21d..39fcc06 100644
--- 
a/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
+++ 
b/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
@@ -50,4 +50,15 @@ public class PipelineOptions {
                                        .asList()
                                        .noDefaultValue()
                                        .withDescription("A semicolon-separated 
list of the classpaths to package with the job jars to be sent to the cluster. 
These have to be valid URLs.");
+
+       /**
+        * Configuration options that are **NOT** supposed to be set by the 
user but by the system.
+        */
+       public static class Internal {
+
+               public static final ConfigOption<Boolean> IS_PYTHON =
+                       key("$internal.pipeline.python")
+                                       .booleanType().defaultValue(false)
+                                       .withDescription("Indicates if the 
pipeline is written in Python.");
+       }
 }