private Map flattenFieldFromJson()

in src/main/java/com/aliyun/odps/kafka/connect/converter/FlattenRecordConverter.java [80:90]

• 10 lines of code
• 3 McCabe index (conditional complexity)

  private Map<String, Object> flattenFieldFromJson(Object sinkRecord)
      throws JsonProcessingException {
    // flatten the json field to mc table schema without embedded format
    if (sinkRecord instanceof HashMap) {
      return (HashMap<String, Object>) sinkRecord;
    }
    if (sinkRecord instanceof String) {
      return JsonHandler.json2Map((String) sinkRecord);
    }
    throw new RuntimeException("unsupported sinkRecord type please check your data format again!");
  }