@Override
  public List<ParsedStatement> parse(final String sql) {
    return primaryContext.parse(sql);
  }
@Test
  public void shouldBeAbleToPreparePauseAndResume() {
    // Given:
    setupKsqlEngineWithSharedRuntimeEnabled();
    givenSqlAlreadyExecuted("CREATE STREAM FOO AS SELECT * FROM TEST1;");

    final List<ParsedStatement> parsed = ksqlEngine.parse(
        "PAUSE CSAS_FOO_0;"
            + "RESUME CSAS_FOO_0;");

    // When:
    parsed.forEach(ksqlEngine::prepare);

    // Then: did not throw.
  }