s434730/RandomSec
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Jackson deserialization for ColumnSplitOperation

Browse Source
This commit is contained in:
Antonin Delpeuch 2018-10-22 12:05:45 +01:00
parent 332132d720
commit eb49db31e2
1 changed files with 39 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
main/src/com/google/refine/operations/column/ColumnSplitOperation.java
View File

@ -33,6 +33,7 @@ OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
package com.google.refine.operations.column; package com.google.refine.operations.column;
import java.io.IOException;
import java.io.Serializable; import java.io.Serializable;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
@ -41,6 +42,7 @@ import java.util.regex.Pattern;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.json.JSONObject; import org.json.JSONObject;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonInclude; import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonInclude.Include; import com.fasterxml.jackson.annotation.JsonInclude.Include;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
@ -59,7 +61,7 @@ import com.google.refine.model.Project;
import com.google.refine.model.Row; import com.google.refine.model.Row;
import com.google.refine.model.changes.ColumnSplitChange; import com.google.refine.model.changes.ColumnSplitChange;
import com.google.refine.operations.EngineDependentOperation; import com.google.refine.operations.EngineDependentOperation;
import com.google.refine.util.JSONUtilities; import com.google.refine.util.ParsingUtilities;
public class ColumnSplitOperation extends EngineDependentOperation { public class ColumnSplitOperation extends EngineDependentOperation {
final protected String _columnName; final protected String _columnName;
@ -73,28 +75,46 @@ public class ColumnSplitOperation extends EngineDependentOperation {
final protected int[] _fieldLengths; final protected int[] _fieldLengths;
static public AbstractOperation reconstruct(Project project, JSONObject obj) throws Exception { static public AbstractOperation reconstruct(Project project, JSONObject obj) throws IOException {
JSONObject engineConfig = obj.getJSONObject("engineConfig"); return ParsingUtilities.mapper.readValue(obj.toString(), ColumnSplitOperation.class);
String mode = obj.getString("mode"); }
@JsonCreator
public static ColumnSplitOperation deserialize(
@JsonProperty("engineConfig")
EngineConfig engineConfig,
@JsonProperty("columnName")
String columnName,
@JsonProperty("guessCellType")
boolean guessCellType,
@JsonProperty("removeOriginalColumn")
boolean removeOriginalColumn,
@JsonProperty("mode")
String mode,
@JsonProperty("separator")
String separator,
@JsonProperty("regex")
Boolean regex,
@JsonProperty("maxColumns")
Integer maxColumns,
@JsonProperty("fieldLengths")
int[] fieldLengths) {
if ("separator".equals(mode)) { if ("separator".equals(mode)) {
return new ColumnSplitOperation( return new ColumnSplitOperation(
EngineConfig.reconstruct(engineConfig), engineConfig,
obj.getString("columnName"), columnName,
obj.getBoolean("guessCellType"), guessCellType,
obj.getBoolean("removeOriginalColumn"), removeOriginalColumn,
obj.getString("separator"), separator,
obj.getBoolean("regex"), regex,
obj.getInt("maxColumns") maxColumns);
);
} else { } else {
return new ColumnSplitOperation( return new ColumnSplitOperation(
EngineConfig.reconstruct(engineConfig), engineConfig,
obj.getString("columnName"), columnName,
obj.getBoolean("guessCellType"), guessCellType,
obj.getBoolean("removeOriginalColumn"), removeOriginalColumn,
JSONUtilities.getIntArray(obj, "fieldLengths") fieldLengths);
);
} }
} }