Toggle navigation
Home
alluxio.master.MasterRegistry.Value<alluxio.master.file.FileSystemMaster> to alluxio.master.file.FileSystemMaster
No. of Instances - 2
No. of Commits - 1
No. of Projects - {'alluxio'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update Class Instacne Creation
new HeartbeatThread(HeartbeatContext.MASTER_CHECKPOINT_SCHEDULING,new CheckpointSchedulingExecutor(this,mFileSystemMaster.get()),Configuration.getInt(PropertyKey.MASTER_LINEAGE_CHECKPOINT_INTERVAL_MS))
to
new HeartbeatThread(HeartbeatContext.MASTER_CHECKPOINT_SCHEDULING,new CheckpointSchedulingExecutor(this,mFileSystemMaster),Configuration.getInt(PropertyKey.MASTER_LINEAGE_CHECKPOINT_INTERVAL_MS))
new HeartbeatThread(HeartbeatContext.MASTER_FILE_RECOMPUTATION,new RecomputeExecutor(new RecomputePlanner(mLineageStore,mFileSystemMaster.get()),mFileSystemMaster.get()),Configuration.getInt(PropertyKey.MASTER_LINEAGE_RECOMPUTE_INTERVAL_MS))
to
new HeartbeatThread(HeartbeatContext.MASTER_FILE_RECOMPUTATION,new RecomputeExecutor(new RecomputePlanner(mLineageStore,mFileSystemMaster),mFileSystemMaster),Configuration.getInt(PropertyKey.MASTER_LINEAGE_RECOMPUTE_INTERVAL_MS))
Add or Remove Method invocation
mFileSystemMaster.get().getFileId(inputFile)
to
mFileSystemMaster.getFileId(inputFile)
mFileSystemMaster.get().createFile(outputFile,options)
to
mFileSystemMaster.createFile(outputFile,options)
mFileSystemMaster.get().getFileInfo(fileId)
to
mFileSystemMaster.getFileInfo(fileId)
mFileSystemMaster.get()
to
mFileSystemMaster
mFileSystemMaster.get().getLostFiles().contains(fileId)
to
mFileSystemMaster.getLostFiles().contains(fileId)
mFileSystemMaster.get().getPath(inputFileId).toString()
to
mFileSystemMaster.getPath(inputFileId).toString()
mFileSystemMaster.get().getPath(outputFileId).toString()
to
mFileSystemMaster.getPath(outputFileId).toString()
mFileSystemMaster.get()
to
mFileSystemMaster
mFileSystemMaster.get()
to
mFileSystemMaster
mFileSystemMaster.get()
to
mFileSystemMaster
mFileSystemMaster.get()
to
mFileSystemMaster
mFileSystemMaster.get()
to
mFileSystemMaster