static PubSubDeserializationSchema dataOnly()

in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubDeserializationSchema.java [26:43]

• 16 lines of code
• 1 McCabe index (conditional complexity)

  static <T> PubSubDeserializationSchema<T> dataOnly(DeserializationSchema<T> schema) {
    return new PubSubDeserializationSchema<T>() {
      @Override
      public void open(DeserializationSchema.InitializationContext context) throws Exception {
        schema.open(context);
      }

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

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