alluxio.worker.block

Class UfsIOManager

java.lang.Object

alluxio.worker.block.UfsIOManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class UfsIOManager
extends Object
implements Closeable

Control UFS IO.

Constructor Summary

Constructors

Constructor and Description
UfsIOManager(UfsManager.UfsClient ufsClient)

Method Summary

Modifier and Type	Method and Description
void	close() Close.
double	getUsedThroughput(com.codahale.metrics.Meter meter) Get used throughput.
CompletableFuture<Integer>	read(ByteBuffer buf, long offset, long len, long blockId, String ufsPath, UfsReadOptions options) Read from ufs.
void	setQuota(String tag, long throughput) Set throughput quota for tag.
void	start() Start schedule thread.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UfsIOManager

public UfsIOManager(UfsManager.UfsClient ufsClient)

Parameters:

ufsClient - ufs client

Method Detail

start

public void start()

Start schedule thread. Main reason is for test

close

public void close()

Close.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

setQuota

public void setQuota(String tag,
                     long throughput)

Set throughput quota for tag.

Parameters:

tag - the client name or tag

throughput - throughput limit in bytes

getUsedThroughput

public double getUsedThroughput(com.codahale.metrics.Meter meter)

Get used throughput.

Parameters:

meter - throughput meter

Returns:

throughput

read

public CompletableFuture<Integer> read(ByteBuffer buf,
                                       long offset,
                                       long len,
                                       long blockId,
                                       String ufsPath,
                                       UfsReadOptions options)

Read from ufs.

Parameters:

buf - bytebuffer

offset - offset in ufs file

len - length to read

blockId - block id

ufsPath - ufs path

options - read ufs options

Returns:

content read

Throws:

ResourceExhaustedRuntimeException - when too many read task happens

OutOfRangeRuntimeException - offset is negative, len is negative, or len > buf remaining

AlluxioRuntimeException - future complete exceptionally when having exception from ufs