@Override
	public byte[] serialize(Row row) {
		if (node == null) {
			node = mapper.createObjectNode();
		}

		try {
			convertRow(node, (RowTypeInfo) typeInfo, row);
			return mapper.writeValueAsBytes(node);
		} catch (Throwable t) {
			throw new RuntimeException("Could not serialize row '" + row + "'. " +
				"Make sure that the schema matches the input.", t);
		}
	}
Creates a JSON serialization schema for the given JSON schema.

@param jsonSchema JSON schema describing the result type

@see <a href="http://json-schema.org/">http://json-schema.org/</a>
kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/serialization/DTJsonRowSerializationSchema.java