Package | Description |
---|---|
com.bigdata.service.ndx.pipeline |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPendingSetMasterTask<H extends AbstractPendingSetMasterStats<L,? extends AbstractSubtaskStats>,E,S extends AbstractPendingSetSubtask,L>
Extends the master task to track outstanding asynchronous operations on work
items.
|
class |
AbstractPendingSetSubtask<HS extends AbstractSubtaskStats,M extends AbstractPendingSetMasterTask<? extends AbstractPendingSetMasterStats<L,HS>,E,? extends AbstractPendingSetSubtask,L>,E,L>
Extended to assign chunks of work items to a remote
IAsynchronousClientTask , to track the set of outstanding
asynchronous operations for a specific client task (the "pending set"), and
to close the client task when the sink not assign any more work to that
client. |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractPendingSetMasterTask.addPending(E e,
AbstractPendingSetSubtask sink,
L locator)
Add a work item to the pending set.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.