All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type |
Method |
Description |
void |
addTmpParforFunction(String fname) |
|
MatrixObject |
allocateGPUMatrixObject(String varName,
long numRows,
long numCols) |
Allocates the GPUObject for a given LOPS Variable (eg.
|
void |
cleanupCacheableData(CacheableData<?> mo) |
|
void |
cleanupDataObject(Data dat) |
|
boolean |
containsVariable(String name) |
|
boolean |
containsVariable(CPOperand operand) |
|
static CacheableData<?> |
createCacheableData(CacheBlock cb) |
|
static FrameObject |
createFrameObject(FrameBlock fb) |
|
static FrameObject |
createFrameObject(DataCharacteristics dc) |
|
static MatrixObject |
createMatrixObject(MatrixBlock mb) |
|
static MatrixObject |
createMatrixObject(DataCharacteristics dc) |
|
CacheableData<?> |
getCacheableData(String varname) |
|
CacheableData<?> |
getCacheableData(CPOperand input) |
|
DataCharacteristics |
getDataCharacteristics(String varname) |
|
Pair<MatrixObject,Boolean> |
getDenseMatrixOutputForGPUInstruction(String varName,
long numRows,
long numCols) |
Allocates a dense matrix on the GPU (for output)
|
Pair<MatrixObject,Boolean> |
getDenseMatrixOutputForGPUInstruction(String varName,
long numRows,
long numCols,
boolean initialize) |
|
FrameBlock |
getFrameInput(String varName) |
Pins a frame variable into memory and returns the internal frame block.
|
FrameObject |
getFrameObject(String varname) |
|
FrameObject |
getFrameObject(CPOperand input) |
|
GPUContext |
getGPUContext(int index) |
Get the i-th GPUContext
|
List<GPUContext> |
getGPUContexts() |
Gets the list of GPUContexts
|
long |
getGPUDensePointerAddress(MatrixObject obj) |
|
CSRPointer |
getGPUSparsePointerAddress(MatrixObject obj) |
|
Lineage |
getLineage() |
|
LineageItem |
getLineageItem(String varname) |
|
LineageItem |
getLineageItem(CPOperand input) |
|
ListObject |
getListObject(String name) |
|
ListObject |
getListObject(CPOperand input) |
|
MatrixBlock |
getMatrixInput(String varName) |
Pins a matrix variable into memory and returns the internal matrix block.
|
MatrixBlock |
getMatrixInput(CPOperand input) |
|
MatrixObject |
getMatrixInputForGPUInstruction(String varName,
String opcode) |
|
List<MatrixBlock> |
getMatrixInputs(CPOperand[] inputs) |
|
List<MatrixBlock> |
getMatrixInputs(CPOperand[] inputs,
boolean includeList) |
|
MatrixLineagePair |
getMatrixLineagePair(String varname) |
|
MatrixLineagePair |
getMatrixLineagePair(CPOperand cpo) |
|
MatrixObject |
getMatrixObject(String varname) |
|
MatrixObject |
getMatrixObject(CPOperand input) |
|
MetaData |
getMetaData(String varname) |
|
int |
getNumGPUContexts() |
Gets the number of GPUContexts
|
LineageItem |
getOrCreateLineageItem(CPOperand input) |
|
Program |
getProgram() |
|
ScalarObject |
getScalarInput(String name,
Types.ValueType vt,
boolean isLiteral) |
|
ScalarObject |
getScalarInput(CPOperand input) |
|
List<ScalarObject> |
getScalarInputs(CPOperand[] inputs) |
|
SEALClient |
getSealClient() |
|
Pair<MatrixObject,Boolean> |
getSparseMatrixOutputForGPUInstruction(String varName,
long numRows,
long numCols,
long nnz) |
Allocates a sparse matrix in CSR format on the GPU.
|
Pair<MatrixObject,Boolean> |
getSparseMatrixOutputForGPUInstruction(String varName,
long numRows,
long numCols,
long nnz,
boolean initialize) |
|
TensorBlock |
getTensorInput(String varName) |
Pins a matrix variable into memory and returns the internal matrix block.
|
TensorObject |
getTensorObject(String varname) |
|
long |
getTID() |
|
Set<String> |
getTmpParforFunctions() |
|
Data |
getVariable(String name) |
|
Data |
getVariable(CPOperand operand) |
|
LocalVariableMap |
getVariables() |
|
ArrayList<String> |
getVarList() |
NOTE: No order guaranteed, so keep same list for pin and unpin.
|
ArrayList<String> |
getVarListPartitioned() |
NOTE: No order guaranteed, so keep same list for pin and unpin.
|
boolean |
isAutoCreateVars() |
|
boolean |
isFederated(CPOperand input) |
|
boolean |
isFederated(CPOperand input,
FTypes.FType type) |
|
boolean |
isFrameObject(String varname) |
|
boolean |
isMatrixObject(String varname) |
|
void |
maintainLineageDebuggerInfo(Instruction inst) |
|
boolean[] |
pinVariables(List<String> varList) |
Pin a given list of variables i.e., set the "clean up" state in
corresponding matrix objects, so that the cached data inside these
objects is not cleared and the corresponding HDFS files are not
deleted (through rmvar instructions).
|
void |
releaseCacheableData(String varname) |
|
void |
releaseFrameInput(String varName) |
Unpins a currently pinned frame variable.
|
void |
releaseMatrixInput(String varName) |
Unpins a currently pinned matrix variable and update fine-grained statistics.
|
void |
releaseMatrixInput(String... varNames) |
|
void |
releaseMatrixInputForGPUInstruction(String varName) |
|
void |
releaseMatrixInputs(CPOperand[] inputs) |
|
void |
releaseMatrixInputs(CPOperand[] inputs,
boolean includeList) |
|
void |
releaseMatrixOutputForGPUInstruction(String varName) |
|
void |
releaseTensorInput(String varName) |
|
void |
releaseTensorInput(String... varNames) |
|
Data |
removeVariable(String name) |
|
void |
setAutoCreateVars(boolean flag) |
|
void |
setFrameOutput(String varName,
FrameBlock outputData) |
|
void |
setGPUContexts(List<GPUContext> gpuContexts) |
Sets the list of GPUContexts
|
void |
setLineage(Lineage lineage) |
|
void |
setMatrixOutput(String varName,
MatrixBlock outputData) |
|
void |
setMatrixOutput(String varName,
MatrixBlock outputData,
MatrixObject.UpdateType flag) |
|
void |
setMatrixOutputAndLineage(String varName,
MatrixBlock outputData,
LineageItem li) |
|
void |
setMetaData(String varName,
long nrows,
long ncols) |
|
void |
setMetaData(String fname,
MetaData md) |
|
void |
setProgram(Program prog) |
|
void |
setScalarOutput(String varName,
ScalarObject so) |
|
void |
setSealClient(SEALClient seal_client) |
|
void |
setTensorOutput(String varName,
TensorBlock outputData) |
|
void |
setTID(long tid) |
|
void |
setVariable(String name,
Data val) |
|
void |
setVariables(LocalVariableMap vars) |
|
String |
toString() |
|
void |
traceLineage(Instruction inst) |
|
void |
unpinVariables(List<String> varList,
boolean[] varsState) |
Unpin the a given list of variables by setting their "cleanup" status
to the values specified by varsStats .
|