static class BatchLoader.LoadBatchResponse extends Object
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 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) |
Modifier and Type | Method and Description |
---|---|
SegmentWithData |
convert(SegmentHeader header,
SegmentBody body) |
final List<Future<Map<Segment,SegmentWithData>>> sqlSegmentMapFutures
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.
final List<SegmentHeader> cacheSegments
final List<CellRequest> cellRequests
final List<BatchLoader.RollupInfo> rollups
If they do not, we will need to tell the cache manager to remove the pending segments.
final Map<List,SegmentBuilder.SegmentConverter> converterMap
final Map<SegmentHeader,Future<SegmentBody>> futures
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)
public SegmentWithData convert(SegmentHeader header, SegmentBody body)