sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java [63:75]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        .build();
  }

  @Override
  public StandardSink getSink() {
    return new StandardSink() {
      @Override
      public Schema nativeSchema() {
        return SCHEMA;
      }

      @Override
      public PTransform<PCollection<Row>, PCollection<Row>> transform() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/KafkaProvider.java [42:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        .build();
  }

  @Override
  public StandardSink getSink() {
    // Beam does not support null keys (https://issues.apache.org/jira/browse/BEAM-12008)
    // So generate a random float and convert it to a string to get random routing for unkeyed
    // messages (all messages with empty keys route to the same partition).
    //
    // Beam does not support RAND() and cannot generate a random key using SQL.
    return new StandardSink() {
      @Override
      public Schema nativeSchema() {
        return SCHEMA;
      }

      @Override
      public PTransform<PCollection<Row>, PCollection<Row>> transform() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -