public static Statement sanitize(
      final Statement node,
      final MetaStore metaStore) {
    return sanitize(node, metaStore, true);
  }
@Test
  public void shouldThrowOnUnknownSource() {
    // Given:
    final Statement stmt = givenQuery("SELECT * FROM Unknown;");

    // When:
    final Exception e = assertThrows(
        KsqlException.class,
        () -> AstSanitizer.sanitize(stmt, META_STORE)
    );

    // Then:
    assertThat(e.getMessage(), containsString(
        "UNKNOWN does not exist"));
  }