Package cz.drg.pregrouper.process.fileRead

Class PrepareTempInputs

java.lang.Object
cz.drg.pregrouper.process.fileRead.PrepareTempInputs
public class PrepareTempInputs extends Object
Prepares temporary input files for processing, including loading data batches and prefetching data for parallel workers.

  • Constructor Details

    • PrepareTempInputs

      public PrepareTempInputs​(int batchSize, Integer parallelWorkerCount)

  • Method Details

    • prepareShardManager

      public void prepareShardManager()

    • readBatch

      public List<LoadedDataBatch> readBatch()

    • hasNextBatch

      public boolean hasNextBatch()

    • reset

      public void reset​(PgpPrepareInputCsvFiles.InputRowCount inputFilesRowCounts)

    • close

      public void close()

    • deleteUsedPartialInputs

      public void deleteUsedPartialInputs()