mondrian.rolap

Class BatchLoader.LoadBatchResponse

java.lang.Object

mondrian.rolap.BatchLoader.LoadBatchResponse

Enclosing class:

BatchLoader

static class BatchLoader.LoadBatchResponse
extends 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 and Description
(package private) List<SegmentHeader>	cacheSegments List of segments we are trying to load from the cache.
(package private) 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) Map<List,SegmentBuilder.SegmentConverter>	converterMap
(package private) Map<SegmentHeader,Future<SegmentBody>>	futures
(package private) List<BatchLoader.RollupInfo>	rollups List of segments to be created from segments in the cache, provided that the cache segments come through.
(package private) List<Future<Map<Segment,SegmentWithData>>>	sqlSegmentMapFutures List of segments that are being loaded using SQL.

Constructor Summary

Constructors

Constructor and Description
LoadBatchResponse(List<CellRequest> cellRequests, List<SegmentHeader> cacheSegments, List<BatchLoader.RollupInfo> rollups, Map<List,SegmentBuilder.SegmentConverter> converterMap, List<Future<Map<Segment,SegmentWithData>>> sqlSegmentMapFutures, Map<SegmentHeader,Future<SegmentBody>> futures)

Method Summary

Modifier and Type	Method and Description
SegmentWithData	convert(SegmentHeader header, SegmentBody body)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

sqlSegmentMapFutures

final List<Future<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 List<SegmentHeader> cacheSegments

List of segments we are trying to load from the cache.

cellRequests

final 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 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 Map<List,SegmentBuilder.SegmentConverter> converterMap

futures

final Map<SegmentHeader,Future<SegmentBody>> futures

Constructor Detail

LoadBatchResponse

LoadBatchResponse(List<CellRequest> cellRequests,
                  List<SegmentHeader> cacheSegments,
                  List<BatchLoader.RollupInfo> rollups,
                  Map<List,SegmentBuilder.SegmentConverter> converterMap,
                  List<Future<Map<Segment,SegmentWithData>>> sqlSegmentMapFutures,
                  Map<SegmentHeader,Future<SegmentBody>> futures)

Method Detail

convert

public SegmentWithData convert(SegmentHeader header,
                               SegmentBody body)