public Statement buildStatement(final ParserRuleContext parseTree) {
    return build(Optional.of(getSources(parseTree)), parseTree);
  }
@Test
  public void shouldCreateNormalStream() {
    // Given:
    final SingleStatementContext stmt =
        givenQuery("CREATE STREAM X WITH (kafka_topic='X');");

    // When:
    final CreateStream result = (CreateStream) builder.buildStatement(stmt);

    // Then:
    assertThat(result.isSource(), is(false));
  }