[flink-statefun] 07/10: [FLINK-17875] [core] Add format version 2.0

[tzulitai]

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 <tzuli...@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);
     }