@Transactional(readOnly = true, isolation = Isolation.READ_COMMITTED)
    public void generateFile() {
        try (Stream<MyEntity> supplier = myRepo.getDataStream()) {
            writeOntoFile(ApplicationConstants.REPORT_DIRECTORY, supplier);
        } catch (IOException ex) {
            log.error("Error occurred while generating file", ex);
        }
    }

private <T extends HasId<?>> void writeOntoFile(final String reportDirectory,
                                                     Stream<T> dataStreamSupplier) throws IOException {

        final String blobName = blobName(reportDirectory);

        try (ICSVWriter writer = blobStorageService.getCsvWriterBlobOutputStream(storageContainer, blobName)) {
            log.info("Writing to {} using beantoCsv mapping", reportDirectory);
            StatefulBeanToCsv<T> beanToCsv = new StatefulBeanToCsvBuilder<T>(writer).build();
            final int[] flushCounter = new int[1];
            dataStreamSupplier.forEach(dataRecord -> {
                writeCSV(reportDirectory, dataRecord, beanToCsv);
                flushCounter[0]++;
                if (flushCounter[0] % CLEAR_INTERVAL == 0) {
                    entityManager.clear();
                    entityManagerFactory.getCache().evict(MyEntity.class);
                    try {
                        writer.flush();
                    } catch (IOException ioe) {
                        log.error("Unable to flush the writing stream");
                        throw new RuntimeException(ioe);
                    }
                }
            });
            log.info("Data written in  With Azure Blob file {}", blobName);

        } catch (RuntimeException re) {
            log.error("Error occurred while processing report {}", reportDirectory, re);
            throw re;
        }

 @Query("select e from MyEntity e JOIN FETCH e.uuid JOIN FETCH e.sourceTable")
   @QueryHints(value = {
            @QueryHint(name = HINT_FETCH_SIZE, value = ApplicationConstants.DATA_FETCH_SIZE),
            @QueryHint(name = HINT_CACHEABLE, value = "false"),
            @QueryHint(name = HINT_READONLY, value = "true")
    })
    Stream<MyEntity> getDataStream();