public static Statement sanitize(
      final Statement node,
      final MetaStore metaStore) {
    return sanitize(node, metaStore, true);
  }
@Test
  public void shouldThrowOnColumnNamesUsedForLambdaArguments() {
    // Given:
    final Statement stmt = givenQuery(
        "SELECT TRANSFORM_ARRAY(Col4, Col0 => Col0 + 5) FROM TEST1;");

    final Exception e = assertThrows(
        KsqlException.class,
        () -> AstSanitizer.sanitize(stmt, META_STORE)
    );

    // Then:
    assertThat(e.getMessage(),
        containsString("Lambda function argument can't be a column name: COL0"));

  }