Toggle navigation
Home
alluxio.client.file.policy.FileWriteLocationPolicy to alluxio.client.block.policy.BlockLocationPolicy
No. of Instances - 8
No. of Commits - 1
No. of Projects - {'alluxio'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update Class Instacne Creation
new LocalFirstAvoidEvictionPolicy(TieredIdentityFactory.fromString("node=node2,rack=rack3",mConf),mConf)
to
new LocalFirstAvoidEvictionPolicy(mConf.getBytes(PropertyKey.USER_BLOCK_AVOID_EVICTION_POLICY_RESERVED_BYTES),TieredIdentityFactory.fromString("node=node2,rack=rack3",mConf),mConf)
Add or Remove Method invocation
policy.getWorkerForNextBlock(workers,Constants.GB)
to
policy.getWorker(options)
locationPolicy.getWorkerForNextBlock(blockWorkers,blockSize)
to
locationPolicy.getWorker(workerOptions)
locationPolicy.getWorkerForNextBlock(blockWorkers,blockSize)
to
locationPolicy.getWorker(workerOptions)
policy.getWorkerForNextBlock(workers,Constants.MB).getHost()
to
policy.getWorker(options).getHost()
policy.getWorkerForNextBlock(workers,Constants.GB).getHost()
to
policy.getWorker(options).getHost()
alluxioConf.<FileWriteLocationPolicy>getClass(PropertyKey.USER_FILE_WRITE_LOCATION_POLICY)
to
PropertyKey.USER_BLOCK_WRITE_LOCATION_POLICY
CommonUtils.createNewClassInstance(PropertyKey.USER_BLOCK_WRITE_LOCATION_POLICY,new Class[]{AlluxioConfiguration.class},new Object[]{alluxioConf})
to
BlockLocationPolicy.Factory.create(alluxioConf.get(PropertyKey.USER_BLOCK_WRITE_LOCATION_POLICY),alluxioConf)