Skip to content

Instantly share code, notes, and snippets.

@KKcorps
Created September 18, 2019 14:44
Show Gist options
  • Save KKcorps/34782f047d3225b96da24c42134ad9d4 to your computer and use it in GitHub Desktop.
Save KKcorps/34782f047d3225b96da24c42134ad9d4 to your computer and use it in GitHub Desktop.
BootstrapTransformation<TestConfig> getConfigTransformation(ExecutionEnvironment executionEnvironment){
TestConfig testConfig = new TestConfig();
testConfig.setKey("global");
testConfig.setThresholdValue(10);
DataSet<TestConfig> configDataSet = executionEnvironment.fromElements(testConfig);
BootstrapTransformation<TestConfig> transformation = OperatorTransformation
.bootstrapWith(configDataSet)
.keyBy(TestConfig::getKey)
.transform(new ConfigBootstrapper());
return transformation;
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment