BootstrapTransformationConfig.java

BootstrapTransformation<TestConfig> getConfigTransformation(ExecutionEnvironment executionEnvironment) {
        TestConfig testConfig = new TestConfig();
        testConfig.setKey("global");
        testConfig.setThresholdValue(10);

        DataSet<TestConfig> configDataSet = executionEnvironment.fromElements(testConfig);
        return OperatorTransformation
                .bootstrapWith(configDataSet)
                .keyBy(TestConfig::getKey)
                .transform(new ConfigBootstrapper());
    }