[flink] branch master updated: [FLINK-16625][utils] Extract BootstrapTools#getEnvironmentVariables to ConfigurationUtils#getPrefixedKeyValuePairs

[tison]

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

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


The following commit(s) were added to refs/heads/master by this push:
 new f80c384  [FLINK-16625][utils] Extract 
BootstrapTools#getEnvironmentVariables to 
ConfigurationUtils#getPrefixedKeyValuePairs
f80c384 is described below

commit f80c3847d854e0d6a62577cd1e998b57b67fc9f6
Author: Canbin Zheng 
AuthorDate: Wed Mar 25 14:35:48 2020 +0800

[FLINK-16625][utils] Extract BootstrapTools#getEnvironmentVariables to 
ConfigurationUtils#getPrefixedKeyValuePairs

This closes #11458 .
---
 .../flink/configuration/ConfigurationUtils.java  | 15 +++
 .../flink/configuration/ConfigurationUtilsTest.java  | 20 +++-
 .../parameters/AbstractKubernetesParameters.java | 10 --
 .../parameters/KubernetesJobManagerParameters.java   |  3 ++-
 .../runtime/clusterframework/BootstrapTools.java | 18 --
 .../runtime/clusterframework/BootstrapToolsTest.java |  5 +++--
 .../org/apache/flink/yarn/YarnClusterDescriptor.java |  3 ++-
 7 files changed, 41 insertions(+), 33 deletions(-)

diff --git 
a/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
 
b/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
index 745d474..9eda0e4 100755
--- 
a/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
+++ 
b/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
@@ -219,6 +219,21 @@ public class ConfigurationUtils {
return configs;
}
 
+   /**
+* Extract and parse Flink configuration properties with a given name 
prefix and
+* return the result as a Map.
+*/
+   public static Map getPrefixedKeyValuePairs(String 
prefix, Configuration configuration) {
+   Map result  = new HashMap<>();
+   for (Map.Entry entry: 
configuration.toMap().entrySet()) {
+   if (entry.getKey().startsWith(prefix) && 
entry.getKey().length() > prefix.length()) {
+   String key = 
entry.getKey().substring(prefix.length());
+   result.put(key, entry.getValue());
+   }
+   }
+   return result;
+   }
+
// Make sure that we cannot instantiate this class
private ConfigurationUtils() {
}
diff --git 
a/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationUtilsTest.java
 
b/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationUtilsTest.java
index fa9345a..be5d340 100644
--- 
a/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationUtilsTest.java
+++ 
b/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationUtilsTest.java
@@ -55,7 +55,7 @@ public class ConfigurationUtilsTest extends TestLogger {
}
 
@Test
-   public void testHideSensitiveValues() {
+   public void testHideSensitiveValues() {
final Map keyValuePairs = new HashMap<>();
keyValuePairs.put("foobar", "barfoo");
final String secretKey1 = "secret.key";
@@ -74,4 +74,22 @@ public class ConfigurationUtilsTest extends TestLogger {
assertThat(hiddenSensitiveValues, 
is(equalTo(expectedKeyValuePairs)));
}
 
+   @Test
+   public void testGetPrefixedKeyValuePairs() {
+   final String prefix = "test.prefix.";
+   final Map expectedKeyValuePairs = new 
HashMap() {
+   {
+   put("k1", "v1");
+   put("k2", "v2");
+   }
+   };
+
+   final Configuration configuration =  new Configuration();
+   expectedKeyValuePairs.forEach((k, v) -> 
configuration.setString(prefix + k, v));
+
+   final Map resultKeyValuePairs = 
ConfigurationUtils.getPrefixedKeyValuePairs(prefix, configuration);
+
+   assertThat(resultKeyValuePairs, 
is(equalTo(expectedKeyValuePairs)));
+   }
+
 }
diff --git 
a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/parameters/AbstractKubernetesParameters.java
 
b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/parameters/AbstractKubernetesParameters.java
index 8e7c443..4e0916a 100644
--- 
a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/parameters/AbstractKubernetesParameters.java
+++ 
b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/parameters/AbstractKubernetesParameters.java
@@ -22,7 +22,6 @@ import org.apache.flink.client.cli.CliFrontend;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.kubernetes.configuration.KubernetesConfigOptions;
 import org.apache.flink.kubernetes.utils.Cons

[flink] branch master updated (bb4ec22 -> f4b68c4)

[tison]

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

tison pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from bb4ec22  [FLINK-16712][task] Refactor StreamTask to construct final 
fields
 add f4b68c4  [FLINK-15640][k8s] Support to set labels for jobmanager and 
taskmanager pod

No new revisions were added by this update.

Summary of changes:
 .../generated/kubernetes_config_configuration.html | 12 +++
 .../configuration/KubernetesConfigOptions.java | 14 +
 .../parameters/AbstractKubernetesParameters.java   |  3 ++-
 .../parameters/KubernetesJobManagerParameters.java |  8 +---
 .../KubernetesTaskManagerParameters.java   |  6 +-
 .../flink/kubernetes/utils/KubernetesUtils.java|  3 ++-
 .../flink/kubernetes/KubernetesTestBase.java   |  6 ++
 .../kubeclient/KubernetesJobManagerTestBase.java   |  8 
 .../kubeclient/KubernetesTaskManagerTestBase.java  |  9 +
 .../decorators/ExternalServiceDecoratorTest.java   |  1 +
 .../decorators/InitJobManagerDecoratorTest.java|  1 +
 .../decorators/InitTaskManagerDecoratorTest.java   |  1 +
 .../decorators/InternalServiceDecoratorTest.java   |  1 +
 .../factory/KubernetesJobManagerFactoryTest.java   |  6 --
 .../factory/KubernetesTaskManagerFactoryTest.java  |  2 +-
 .../KubernetesJobManagerParametersTest.java| 21 
 .../KubernetesTaskManagerParametersTest.java   | 23 ++
 17 files changed, 108 insertions(+), 17 deletions(-)

[flink] branch master updated (d38a010 -> bb4ec22)

[zhijiang]

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

zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from d38a010  [FLINK-15579][table-planner-blink] Fix UpsertStreamTableSink 
support and add tests
 add bb4ec22  [FLINK-16712][task] Refactor StreamTask to construct final 
fields

No new revisions were added by this update.

Summary of changes:
 .../flink/state/api/output/BoundedStreamTask.java  |  2 +-
 .../runtime/tasks/AbstractTwoInputStreamTask.java  |  2 +-
 .../runtime/tasks/MultipleInputStreamTask.java |  2 +-
 .../runtime/tasks/OneInputStreamTask.java  |  4 +-
 .../runtime/tasks/SourceReaderStreamTask.java  |  2 +-
 .../streaming/runtime/tasks/SourceStreamTask.java  |  4 +-
 .../runtime/tasks/StreamIterationHead.java |  2 +-
 .../runtime/tasks/StreamIterationTail.java |  2 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  | 68 +-
 .../runtime/tasks/TwoInputStreamTask.java  |  2 +-
 .../runtime/tasks/LocalStateForwardingTest.java|  2 +-
 .../MultipleInputStreamTaskTestHarnessBuilder.java |  4 +-
 .../tasks/OneInputStreamTaskTestHarness.java   | 10 ++--
 .../tasks/StreamTaskExecutionDecorationTest.java   |  2 +-
 .../tasks/StreamTaskMailboxTestHarnessBuilder.java |  6 +-
 .../tasks/StreamTaskSelectiveReadingTest.java  |  2 +-
 .../runtime/tasks/StreamTaskTerminationTest.java   |  2 +-
 .../streaming/runtime/tasks/StreamTaskTest.java| 19 +++---
 .../runtime/tasks/StreamTaskTestHarness.java   | 18 +++---
 .../runtime/tasks/SynchronousCheckpointITCase.java |  2 +-
 .../runtime/tasks/SynchronousCheckpointTest.java   |  6 +-
 .../tasks/TaskCheckpointingBehaviourTest.java  |  2 +-
 .../tasks/TwoInputStreamTaskTestHarness.java   |  6 +-
 .../flink/streaming/util/MockStreamTask.java   |  2 +-
 .../streaming/util/MockStreamTaskBuilder.java  |  2 +-
 .../codegen/agg/batch/BatchAggTestBase.scala   |  5 +-
 .../jobmaster/JobMasterStopWithSavepointIT.java|  6 +-
 27 files changed, 91 insertions(+), 95 deletions(-)

[flink] branch master updated (1827e4d -> d38a010)

[lzljs3620320]

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

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 1827e4d  [FLINK-16170][elasticsearch] Fix SearchTemplateRequest 
ClassNotFoundException when using flink-sql-connector-elasticsearch7
 add 5642479  [FLINK-15579][table-planner-blink] UpsertStreamTableSink 
should work on batch mode
 add d38a010  [FLINK-15579][table-planner-blink] Fix UpsertStreamTableSink 
support and add tests

No new revisions were added by this update.

Summary of changes:
 .../java/io/jdbc/JDBCUpsertTableSinkITCase.java| 40 ++
 .../plan/nodes/physical/batch/BatchExecSink.scala  | 21 --
 .../nodes/physical/stream/StreamExecSink.scala | 13 +---
 .../planner/plan/utils/UpdatingPlanChecker.scala   | 42 +++
 .../runtime/batch/table/TableSinkITCase.scala  | 87 +-
 5 files changed, 168 insertions(+), 35 deletions(-)

[flink-statefun] 01/02: [hotfix] Make namespace in State Bootstrap example to match GreetStatefulFunction

[tzulitai]

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

tzulitai pushed a commit to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git

commit 31c851eab04f11ec21253e7a00d0530df057a945
Author: Igal Shilman 
AuthorDate: Tue Mar 24 21:55:03 2020 +0100

[hotfix] Make namespace in State Bootstrap example to match 
GreetStatefulFunction

This example creates a savepoint for the Greeter example, but it uses
the wrong namespace.

This closes #71.
---
 .../state/processor/example/GreetStatefulFunctionBootstrapExample.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/example/GreetStatefulFunctionBootstrapExample.java
 
b/statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/example/GreetStatefulFunctionBootstrapExample.java
index d5c7680..dabd236 100644
--- 
a/statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/example/GreetStatefulFunctionBootstrapExample.java
+++ 
b/statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/example/GreetStatefulFunctionBootstrapExample.java
@@ -43,7 +43,7 @@ import org.apache.flink.statefun.sdk.state.PersistedValue;
  */
 public class GreetStatefulFunctionBootstrapExample {
 
-  private static final FunctionType GREETER_FUNCTION_TYPE = new 
FunctionType("foo.bar", "greeter");
+  private static final FunctionType GREETER_FUNCTION_TYPE = new 
FunctionType("apache", "greeter");
 
   public static void main(String[] args) throws Exception {
 final ParameterTool params = ParameterTool.fromArgs(args);

[flink-statefun] branch release-2.0 updated (5f7714b -> 61d6609)

[tzulitai]

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

tzulitai pushed a change to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.


from 5f7714b  [hotfix] [legal] Update missing entries in distribution jar 
NOTICE file
 new 31c851e  [hotfix] Make namespace in State Bootstrap example to match 
GreetStatefulFunction
 new 61d6609  [FLINK-16752] Add a repackage goal to ridesharing example

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../statefun-ridesharing-example-simulator/pom.xml| 8 
 .../processor/example/GreetStatefulFunctionBootstrapExample.java  | 2 +-
 2 files changed, 9 insertions(+), 1 deletion(-)

[flink-statefun] 02/02: [FLINK-16752] Add a repackage goal to ridesharing example

[tzulitai]

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

tzulitai pushed a commit to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git

commit 61d660971a0049af97f17993c50cd7ca9e7b1c40
Author: Igal Shilman 
AuthorDate: Tue Mar 24 19:51:19 2020 +0100

[FLINK-16752] Add a repackage goal to ridesharing example

Changing the maven parent from spring-boot to statefun-parent
had missed a default configuration of the spring-boot-maven-plugin
that triggers the repackage goal.

This closes #70.
---
 .../statefun-ridesharing-example-simulator/pom.xml| 8 
 1 file changed, 8 insertions(+)

diff --git 
a/statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-simulator/pom.xml
 
b/statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-simulator/pom.xml
index 7197cd8..c312108 100644
--- 
a/statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-simulator/pom.xml
+++ 
b/statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-simulator/pom.xml
@@ -121,6 +121,14 @@ under the License.
 
 org.springframework.boot
 spring-boot-maven-plugin
+
+
+package
+
+repackage
+
+
+
 
 
 

[flink-statefun] branch master updated (cfcc123 -> 67b75eb)

[tzulitai]

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

tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.


from cfcc123  [hotfix] [legal] Update missing entries in distribution jar 
NOTICE file
 add a63d0f4  [hotfix] Make namespace in State Bootstrap example to match 
GreetStatefulFunction
 add 67b75eb  [FLINK-16752] Add a repackage goal to ridesharing example

No new revisions were added by this update.

Summary of changes:
 .../statefun-ridesharing-example-simulator/pom.xml| 8 
 .../processor/example/GreetStatefulFunctionBootstrapExample.java  | 2 +-
 2 files changed, 9 insertions(+), 1 deletion(-)

[flink] branch release-1.10 updated: [FLINK-16759][hive] HiveModuleTest failed to compile on release-1.10

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.10 by this push:
 new 572717d  [FLINK-16759][hive] HiveModuleTest failed to compile on 
release-1.10
572717d is described below

commit 572717dbc35369d29441c2ad4eb0ba73aa803ee0
Author: Jingsong Lee 
AuthorDate: Wed Mar 25 11:02:39 2020 +0800

[FLINK-16759][hive] HiveModuleTest failed to compile on release-1.10


This closes #11503
---
 .../test/java/org/apache/flink/table/module/hive/HiveModuleTest.java| 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
 
b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
index 04cf165..2939f64 100644
--- 
a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
+++ 
b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
@@ -155,7 +155,7 @@ public class HiveModuleTest {
TableEnvironment tableEnv = 
HiveTestUtils.createTableEnvWithBlinkPlannerBatchMode();
 
tableEnv.unloadModule("core");
-   tableEnv.loadModule("hive", new HiveModule());
+   tableEnv.loadModule("hive", new 
HiveModule(HiveShimLoader.getHiveVersion()));
 
List results = 
TableUtils.collectToList(tableEnv.sqlQuery("select 
str_to_map('a:1,b:2,c:3',',',':')"));
 

[flink] branch master updated: [FLINK-16170][elasticsearch] Fix SearchTemplateRequest ClassNotFoundException when using flink-sql-connector-elasticsearch7

[jark]

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

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


The following commit(s) were added to refs/heads/master by this push:
 new 1827e4d  [FLINK-16170][elasticsearch] Fix SearchTemplateRequest 
ClassNotFoundException when using flink-sql-connector-elasticsearch7
1827e4d is described below

commit 1827e4dddfbac75a533ff2aea2f3e690777a3e5e
Author: Leonard Xu 
AuthorDate: Wed Mar 25 10:13:41 2020 +0800

[FLINK-16170][elasticsearch] Fix SearchTemplateRequest 
ClassNotFoundException when using flink-sql-connector-elasticsearch7

We shouldn't `exclude org.elasticsearch:elasticsearch-geo` and 
`org.elasticsearch.plugin:lang-mustache-client` when shading.

This closes #11396
---
 .../flink-sql-connector-elasticsearch7/pom.xml | 16 +++---
 flink-connectors/pom.xml   |  1 +
 .../flink-sql-client-test/pom.xml  | 13 +
 flink-end-to-end-tests/run-nightly-tests.sh|  6 ++-
 .../test-scripts/elasticsearch-common.sh   |  2 +-
 .../test-scripts/test_sql_client.sh| 61 +++---
 tools/travis/splits/split_misc.sh  |  6 ++-
 7 files changed, 74 insertions(+), 31 deletions(-)

diff --git a/flink-connectors/flink-sql-connector-elasticsearch7/pom.xml 
b/flink-connectors/flink-sql-connector-elasticsearch7/pom.xml
index 0f2da3f..d1e289d 100644
--- a/flink-connectors/flink-sql-connector-elasticsearch7/pom.xml
+++ b/flink-connectors/flink-sql-connector-elasticsearch7/pom.xml
@@ -63,14 +63,10 @@ under the License.



-   
com.carrotsearch:hppc

com.tdunning:t-digest

joda-time:joda-time

net.sf.jopt-simple:jopt-simple

org.elasticsearch:jna
-   
org.elasticsearch:elasticsearch-geo
-   
org.elasticsearch.plugin:lang-mustache-client
-   
com.github.spullara.mustache.java:compiler

org.hdrhistogram:HdrHistogram

org.yaml:snakeyaml

@@ -136,13 +132,17 @@ under the License.

org.apache.flink.elasticsearch7.shaded.org.elasticsearch


-   
org.apache.logging
-   
org.apache.flink.elasticsearch7.shaded.org.apache.logging
-   
-   

com.fasterxml.jackson

org.apache.flink.elasticsearch7.shaded.com.fasterxml.jackson

+   
+   
com.carrotsearch.hppc
+   
org.apache.flink.elasticsearch7.shaded.com.carrotsearch.hppc
+   
+   
+   
com.github.mustachejava
+   
org.apache.flink.elasticsearch7.shaded.com.github.mustachejava
+   



diff --git a/flink-connectors/pom.xml b/flink-connectors/pom.xml
index 1e92a10..296bf89 100644
--- a/flink-connectors/pom.xml
+++ b/flink-connectors/pom.xml
@@ -94,6 +94,7 @@ under the License.

  

[flink] branch release-1.8 updated (60d9b96 -> be4cb1a)

[trohrmann]

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

trohrmann pushed a change to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 60d9b96  [FLINK-11193][State] Fix Rockdb timer service factory 
configuration option to be settable per job
 add be4cb1a  [FLINK-16707] Fix potential memory leak of rest server when 
using session/standalone cluster for version 1.8

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/rest/FileUploadHandler.java  | 11 +++
 .../flink/runtime/rest/FileUploadHandlerTest.java  | 34 ++
 2 files changed, 45 insertions(+)

[flink-web] 02/02: Regenerate page

[rmetzger]

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

rmetzger pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 0980cd665712bbe6d28e8ecdaabe543855904a6c
Author: Robert Metzger 
AuthorDate: Tue Mar 24 15:42:37 2020 +0100

Regenerate page

this closes #315
---
 content/blog/feed.xml  | 209 +++--
 content/blog/index.html|   8 +-
 content/blog/page10/index.html |   2 +-
 content/blog/page11/index.html |   2 +-
 content/blog/page2/index.html  |   2 +-
 content/blog/page3/index.html  |   2 +-
 content/blog/page4/index.html  |   2 +-
 content/blog/page5/index.html  |   2 +-
 content/blog/page6/index.html  |   2 +-
 content/blog/page7/index.html  |   2 +-
 content/blog/page8/index.html  |   2 +-
 content/blog/page9/index.html  |   2 +-
 content/index.html |   2 +-
 .../{02/26 => 03/24}/demo-fraud-detection-2.html   |   2 +-
 content/zh/index.html  |   2 +-
 15 files changed, 212 insertions(+), 31 deletions(-)

diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 2ae389a..803c8fb 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,201 @@
 https://flink.apache.org/blog/feed.xml"; rel="self" 
type="application/rss+xml" />
 
 
+Advanced Flink Application Patterns Vol.2: Dynamic Updates of 
Application Logic
+
In the first
 article of the series, we gave a high-level description of the 
objectives and required functionality of a Fraud Detection engine. We also 
described how to make data partitioning in Apache Flink customizable based on 
modifiable rules instead of using a hardcoded 
KeysExtractor implementation.
+
+
We intentionally omitted details of how the applied rules are 
initialized and what possibilities exist for updating them at runtime. In this 
post, we will address exactly these details. You will learn how the approach to 
data partitioning described in Part
 1 can be applied in combination with a dynamic configuration. These 
two patterns, when used together, can eliminate the nee [...]
+
+
Rules Broadcasting
+
+
Let’s first have a look at the previously-defined;
 data-processing pipeline:
+
+
DataStream<Alert> alerts =
+transactions
+.process(new DynamicKeyFunction())
+.keyBy((keyed) -> keyed.getKey());< [...]
+.process(new DynamicAlertFunction())
+
+
DynamicKeyFunction provides dynamic data 
partitioning while DynamicAlertFunction is responsible 
for executing the main logic of processing transactions and sending alert 
messages according to defined rules.
+
+
Vol.1 of this series simplified the use case and assumed that the 
applied set of rules is pre-initialized and accessible via the 
List<Rules> within 
DynamicKeyFunction.
+
+
public class DynamicKeyFunction
+extends ProcessFunction<Transaction, Keyed<Transaction, /* Simplified */
+  List<Rule> rules = /* Rules 
that are initialized somehow.*/