[flink] 10/11: [FLINK-12963] [state-processor] Allow providing user defined SavepointWriterOperatorFactory when creating keyed BootstrapTransformations

[tz...@apache.org]

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

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

commit 699c1f89d08dd09d10c98aa42a37ca2182025b36
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Thu Jul 4 12:29:17 2019 +0800

    [FLINK-12963] [state-processor] Allow providing user defined SavepointWriterOperatorFactory when creating keyed BootstrapTransformations
    
    This was exposed for non-partitioned BootstrapTransformations, but not
    for keyed ones. This commit makes the functionality on-par for both
    sides.
---
 .../java/org/apache/flink/state/api/KeyedOperatorTransformation.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/KeyedOperatorTransformation.java b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/KeyedOperatorTransformation.java
index d2cde56..6e42f16 100644
--- a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/KeyedOperatorTransformation.java
+++ b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/KeyedOperatorTransformation.java
@@ -84,7 +84,7 @@ public class KeyedOperatorTransformation<K, T> {
 	 * @param factory A factory returning transformation logic type of the return stream
 	 * @return An {@link BootstrapTransformation} that can be added to a {@link Savepoint}.
 	 */
-	private BootstrapTransformation<T> transform(SavepointWriterOperatorFactory factory) {
+	public BootstrapTransformation<T> transform(SavepointWriterOperatorFactory factory) {
 		return new BootstrapTransformation<>(dataSet, operatorMaxParallelism, factory, keySelector, keyType);
 	}
 }