sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSink.java [15:26]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  default String query() {
    return "";
  }

  @Override
  default PTransform<PCollection<Row>, PCollection<Row>> transform() {
    return MakePtransform.from(rows -> {
      if (!query().isEmpty()) {
        rows = rows.apply(SqlTransform.query(query()));
      }
      return rows;
    }, "StandardSqlSink Transform");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSource.java [15:26]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  default String query() {
    return "";
  }

  @Override
  default PTransform<PCollection<Row>, PCollection<Row>> transform() {
    return MakePtransform.from(rows -> {
      if (!query().isEmpty()) {
        rows = rows.apply(SqlTransform.query(query()));
      }
      return rows;
    }, "StandardSqlSink Transform");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -