public interface DistributedCallableContext
DistributedCallable.init(DistributedCallableContext)
.Modifier and Type | Method and Description |
---|---|
NodeAllocationPlan |
ensureInitialNodeAllocation()
Returns the initial node allocation of the job.
|
NodeAllocationState.AssignmentState |
getAssignmentState()
Returns the assignment state for this callable.
|
FileClient |
getFileClient()
Returns the file client to be used within this context
|
<T> T |
getLocalSessionAttribute(AttributeScope scope,
SessionAttribute<T> attribute)
Looks up the value of a session attribute.
|
<T> void |
setLocalSessionAttribute(AttributeScope scope,
SessionAttribute<T> attribute,
T value)
Sets the value of a session attribute.
|
NodeAllocationPlan ensureInitialNodeAllocation()
NodeAllocationState.AssignmentState getAssignmentState()
<T> T getLocalSessionAttribute(AttributeScope scope, SessionAttribute<T> attribute)
T
- the type of the attributescope
- a session qualifier to provide uniqueness. attributes are keyed by
scope plus attribute type.attribute
- the attribute<T> void setLocalSessionAttribute(AttributeScope scope, SessionAttribute<T> attribute, T value)
T
- the type of the attributescope
- a session qualifier to provide uniqueness. attributes are keyed by
scope plus attribute type.attribute
- the attributevalue
- the value of the attributeFileClient getFileClient()
Copyright © 2016 Actian Corporation. All rights reserved.