Package mondrian.rolap
Class BatchLoader.LoadBatchResponse
- java.lang.Object
-
- mondrian.rolap.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 Summary
Fields Modifier and Type Field Description (package private) java.util.List<SegmentHeader>
cacheSegments
List of segments we are trying to load from the cache.(package private) 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).(package private) java.util.Map<java.util.List,SegmentBuilder.SegmentConverter>
converterMap
(package private) java.util.Map<SegmentHeader,java.util.concurrent.Future<SegmentBody>>
futures
(package private) java.util.List<BatchLoader.RollupInfo>
rollups
List of segments to be created from segments in the cache, provided that the cache segments come through.(package private) java.util.List<java.util.concurrent.Future<java.util.Map<Segment,SegmentWithData>>>
sqlSegmentMapFutures
List of segments that are being loaded using SQL.
-
Constructor Summary
Constructors Constructor Description LoadBatchResponse(java.util.List<CellRequest> cellRequests, java.util.List<SegmentHeader> cacheSegments, java.util.List<BatchLoader.RollupInfo> rollups, java.util.Map<java.util.List,SegmentBuilder.SegmentConverter> converterMap, java.util.List<java.util.concurrent.Future<java.util.Map<Segment,SegmentWithData>>> sqlSegmentMapFutures, java.util.Map<SegmentHeader,java.util.concurrent.Future<SegmentBody>> futures)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SegmentWithData
convert(SegmentHeader header, SegmentBody body)
-
-
-
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.
-
converterMap
final java.util.Map<java.util.List,SegmentBuilder.SegmentConverter> converterMap
-
futures
final java.util.Map<SegmentHeader,java.util.concurrent.Future<SegmentBody>> futures
-
-
Constructor Detail
-
LoadBatchResponse
LoadBatchResponse(java.util.List<CellRequest> cellRequests, java.util.List<SegmentHeader> cacheSegments, java.util.List<BatchLoader.RollupInfo> rollups, java.util.Map<java.util.List,SegmentBuilder.SegmentConverter> converterMap, java.util.List<java.util.concurrent.Future<java.util.Map<Segment,SegmentWithData>>> sqlSegmentMapFutures, java.util.Map<SegmentHeader,java.util.concurrent.Future<SegmentBody>> futures)
-
-
Method Detail
-
convert
public SegmentWithData convert(SegmentHeader header, SegmentBody body)
-
-