class DeserializationSchemaWrapper implements PubSubDeserializationSchema<T> {

	@Override
	public T deserialize(PubsubMessage pubsubMessage) throws Exception {
		return deserializationSchema.deserialize(pubsubMessage.getData().toByteArray());
	}

	  DeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema);

}