Class BatchLoader.LoadBatchResponse

  • Enclosing class:
    BatchLoader

    static class BatchLoader.LoadBatchResponse
    extends java.lang.Object
    Request sent from cache manager to a worker to load segments into the cache, create segments by rolling up, and to wait for segments being loaded via SQL.
    • Field Detail

      • sqlSegmentMapFutures

        final java.util.List<java.util.concurrent.Future<java.util.Map<Segment,​SegmentWithData>>> sqlSegmentMapFutures
        List of segments that are being loaded using SQL.

        Other workers are executing the SQL. When done, they will write a segment body or an error into the respective futures. The thread processing this request will wait on those futures, once all segments have successfully arrived from cache.

      • cacheSegments

        final java.util.List<SegmentHeader> cacheSegments
        List of segments we are trying to load from the cache.
      • cellRequests

        final java.util.List<CellRequest> cellRequests
        List of cell requests that will be satisfied by segments we are trying to load from the cache (or create by rolling up).
      • rollups

        final java.util.List<BatchLoader.RollupInfo> rollups
        List of segments to be created from segments in the cache, provided that the cache segments come through.

        If they do not, we will need to tell the cache manager to remove the pending segments.