public DdlCommandResult execute(
      final String sql,
      final DdlCommand ddlCommand,
      final boolean withQuery,
      final Set<SourceName> withQuerySources
  ) {
    return execute(sql, ddlCommand, withQuery, withQuerySources, false);
  }
@Test
  public void shouldAddNormalStreamWhenNoTypeIsSpecified() {
    // Given:
    final CreateStreamCommand cmd = buildCreateStream(
        SourceName.of("t1"),
        SCHEMA,
        false,
        null
    );

    // When:
    cmdExec.execute(SQL_TEXT, cmd, true, NO_QUERY_SOURCES);

    // Then:
    final KsqlStream ksqlTable = (KsqlStream) metaStore.getSource(SourceName.of("t1"));
    assertThat(ksqlTable.isSource(), is(false));
  }