public Statement buildStatement(final ParserRuleContext parseTree) {
    return build(Optional.of(getSources(parseTree)), parseTree);
  }
@Test
  public void shouldRejectIncorrectlyTypedHeadersColumns() {
    // Given:
    final SingleStatementContext stmt
        = givenQuery("CREATE STREAM INPUT (K BIGINT HEADERS) WITH (kafka_topic='input',value_format='JSON');");

    // When:
    final KsqlException e = assertThrows(KsqlException.class, () -> {
      builder.buildStatement(stmt);
    });

    // Then:
    assertThat(e.getMessage(), is("Invalid type for HEADERS column: expected ARRAY<STRUCT<`KEY` STRING, `VALUE` BYTES>>, got BIGINT"));
  }