@Override
  public List<ParsedStatement> parse(final String sql) {
    return primaryContext.parse(sql);
  }
@Test
  public void shouldHandleCommandsSpreadOverMultipleLines() {
    setupKsqlEngineWithSharedRuntimeEnabled();
    final String runScriptContent = "CREATE STREAM S1 \n"
        + "(COL1 BIGINT, COL2 VARCHAR)\n"
        + " WITH \n"
        + "(KAFKA_TOPIC = 's1_topic', VALUE_FORMAT = 'JSON', KEY_FORMAT = 'KAFKA');\n";

    final List<?> parsedStatements = ksqlEngine.parse(runScriptContent);

    assertThat(parsedStatements, hasSize(1));
  }