class JsonColumnSplitRule implements ColumnSplitRule<Row, JsonSubRow> {

    @Override
    public JsonSubRow split(Row row) throws Exception {
        String json = row.getValue(columnIndex - 1);
        Map<String, Object> splitResult = JsonBuilder.readValue(json, Map.class);
        return new JsonSubRow(splitColumn, splitResult);
    }

    public  JsonColumnSplitRule(String splitColumn, SwiftMetaData baseMetadata);

}