class JsonRowDeserializationSchema implements DeserializationSchema<Row> {

	@Override
	public Row deserialize(byte[] message) throws IOException {
		try {
			final JsonNode root = objectMapper.readTree(message);
			return convertRow(root, (RowTypeInfo) typeInfo);
		} catch (Throwable t) {
			throw new IOException("Failed to deserialize JSON object.", t);
		}
	}

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

}