class DeserializationSchemaWrapper implements PubSubDeserializationSchema<T> {

	@Override
	public TypeInformation<T> getProducedType() {
		return deserializationSchema.getProducedType();
	}

	  DeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema);

}