in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java [166:168]
private PubSubCollector(SourceContext<OUT> ctx) { this.ctx = ctx; }