public DropSourceCommand create(final DropStream statement) {
    return create(
        statement.getName(),
        statement.getIfExists(),
        statement.isDeleteTopic(),
        DataSourceType.KSTREAM
    );
  }
@Test
  public void shouldCreateCommandForDropStream() {
    // Given:
    final DropStream ddlStatement = new DropStream(SOME_NAME, true, true);

    // When:
    final DdlCommand result = dropSourceFactory.create(ddlStatement);

    // Then:
    assertThat(result, instanceOf(DropSourceCommand.class));
  }