code: def test_json_row_serialization_deserialization_schema(self):
      jvm = get_gateway().jvm
      jsons = [
          '{"svt":"2020-02-24T12:58:09.209+0800"}',
          '{"svt":"2020-02-24T12:58:09.209+0800", '
          '"ops":{"id":"281708d0-4092-4c21-9233-931950b6eccf"},"ids":[1, 2, 3]}',
          '{"svt":"2020-02-24T12:58:09.209+0800"}',
      ]
      expected_jsons = [
          '{"svt":"2020-02-24T12:58:09.209+0800","ops":null,"ids":null}',
          '{"svt":"2020-02-24T12:58:09.209+0800",'
          '"ops":{"id":"281708d0-4092-4c21-9233-931950b6eccf"},'
          '"ids":[1,2,3]}',
          '{"svt":"2020-02-24T12:58:09.209+0800","ops":null,"ids":null}',
      ]
  
      row_schema = Types.ROW_NAMED(
          ["svt", "ops", "ids"],
          [
              Types.STRING(),
              Types.ROW_NAMED(["id"], [Types.STRING()]),
              Types.PRIMITIVE_ARRAY(Types.INT()),
          ],
      )
  
      json_row_serialization_schema = (
          JsonRowSerializationSchema.builder()
          .with_type_info(row_schema)
          .build()
      )
      json_row_deserialization_schema = (
          JsonRowDeserializationSchema.builder()
          .type_info(row_schema)
          .build()
      )
      json_row_serialization_schema._j_serialization_schema.open(
          jvm.org.apache.flink.connector.testutils.formats.DummyInitializationContext()
      )
      json_row_deserialization_schema._j_deserialization_schema.open(
          jvm.org.apache.flink.connector.testutils.formats.DummyInitializationContext()
      )
  
      for i in range(len(jsons)):
          j_row = json_row_deserialization_schema._j_deserialization_schema.deserialize(
              bytes(jsons[i], encoding="utf-8")
          )
          result = str(
              json_row_serialization_schema._j_serialization_schema.serialize(
                  j_row
              ),
              encoding="utf-8",
          )
          self.assertEqual(expected_jsons[i], result)
  
imports: from pyflink.common import Types
  from pyflink.datastream.formats.json import JsonRowSerializationSchema, JsonRowDeserializationSchema
  from pyflink.java_gateway import get_gateway
  from pyflink.testing.test_case_utils import PyFlinkTestCase
label_desc: Use image node_id 1 for calling the JsonSerializationSchemaTests obj's underlying member method code with example usage: obj.test_json_row_serialization_deserialization_schema() without return types