class JsonRowSerializationSchema implements SerializationSchema<Row> {

	@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);
		}
	}

	public  JsonRowSerializationSchema(TypeInformation<Row> typeInfo);
	public  JsonRowSerializationSchema(String jsonSchema);

}