public static SimpleFunction<String, Row> getJsonStringToRowFunction(Schema beamSchema) {
    return new JsonToRowFn<String>(beamSchema) {
      @Override
      public Row apply(String jsonString) {
        return RowJsonUtils.jsonToRow(objectMapper, jsonString);
      }
    };
  }
@Test
  public void testGetJsonStringToRowFunction() {
    for (TestCase<? extends RowEncodable> caze : testCases) {
      Row expected = caze.row;
      Row actual =
          JsonUtils.getJsonStringToRowFunction(expected.getSchema()).apply(caze.jsonString);
      assertEquals(caze.userT.toString(), expected, actual);
    }
  }