You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2020/05/28 11:41:50 UTC
[flink-statefun] 07/10: [FLINK-17875] [core] Add format version 2.0
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-statefun.git
commit 3c8e1f46aa14ec6f4da3ddabd2234f5260f5c09a
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Thu May 28 14:59:58 2020 +0800
[FLINK-17875] [core] Add format version 2.0
---
.../apache/flink/statefun/flink/core/jsonmodule/FormatVersion.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FormatVersion.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FormatVersion.java
index 8f01a33..debb28c 100644
--- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FormatVersion.java
+++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FormatVersion.java
@@ -19,7 +19,8 @@
package org.apache.flink.statefun.flink.core.jsonmodule;
enum FormatVersion {
- v1_0("1.0");
+ v1_0("1.0"),
+ v2_0("2.0");
private String versionStr;
@@ -36,6 +37,8 @@ enum FormatVersion {
switch (versionStr) {
case "1.0":
return v1_0;
+ case "2.0":
+ return v2_0;
default:
throw new IllegalArgumentException("Unrecognized format version: " + versionStr);
}