static PubSubSerializationSchema dataOnly()

in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSerializationSchema.java [24:39]

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

  static <T> PubSubSerializationSchema<T> dataOnly(SerializationSchema<T> schema) {
    return new PubSubSerializationSchema<T>() {

      @Override
      public void open(SerializationSchema.InitializationContext context) throws Exception {
        schema.open(context);
      }

      @Override
      public PubsubMessage serialize(T value) {
        return PubsubMessage.newBuilder()
            .setData(ByteString.copyFrom(schema.serialize(value)))
            .build();
      }
    };
  }