@Override
  public KsqlQueryType getQueryType() {
    return KsqlQueryType.PUSH;
  }
@Test
  public void shouldReturnPushQueryTypeByDefault() {
    assertThat(query.getQueryType(), is(KsqlQueryType.PUSH));
  }