public String anonymize(final ParseTree tree) {
    return build(tree);
  }
@Test
  public void shouldAnonymizeCreateSourceStreamQueryCorrectly() {
    final String output = anon.anonymize(
        "CREATE SOURCE STREAM my_stream (profileId VARCHAR, latitude DOUBLE, longitude DOUBLE)\n"
            + "WITH (kafka_topic='locations', value_format='json');");

    Approvals.verify(output);
  }