docs: @Override
      public Stream<? extends Ticket> getTicketsStream() {
          return this.ticketCatalog.findAll()
              .stream()
              .map(t -> {
                  val sql = String.format("select t from %s t", getTicketEntityName(t));
                  val query = (org.hibernate.query.Query<Ticket>) entityManager.createQuery(sql, t.getImplementationClass());
                  query.setFetchSize(STREAM_BATCH_SIZE);
                  query.setLockOptions(LockOptions.NONE);
                  return query;
              })
              .flatMap(org.hibernate.query.Query::stream);
      }