@Override
  public void validate(final Analysis analysis) {
    failPersistentQueryOnWindowedTable(analysis);
    QueryValidatorUtil.validateNoUserColumnsWithSameNameAsPseudoColumns(analysis);
  }
@Test
  public void shouldThrowOnPersistentPushQueryOnWindowedTable() {
    // Given:
    givenPersistentQuery();
    givenSourceTable();
    givenWindowedSource();

    // When:
    final Exception e = assertThrows(
        KsqlException.class,
        () -> validator.validate(analysis)
    );

    // Then:
    assertThat(e.getMessage(), containsString("KSQL does not support persistent queries on windowed tables."));
  }