in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java [255:258]
private PubSubSourceBuilder(PubSubDeserializationSchema<OUT> deserializationSchema) {
Preconditions.checkNotNull(deserializationSchema);
this.deserializationSchema = deserializationSchema;
}