alluxio.cli

Class BasicNonByteBufferOperations

java.lang.Object

alluxio.cli.BasicNonByteBufferOperations

All Implemented Interfaces:

Callable<Boolean>

public final class BasicNonByteBufferOperations
extends Object
implements Callable<Boolean>

Basic example of using the FileSystem for writing to and reading from files.

This class is different from BasicOperations in the way writes happen. Over there ByteBuffer is used directly, where as here byte data is done via input/output streams.

This example also let users play around with how to work with files a bit more. The AlluxioStorageType is something that can be set, as well as ability to delete file if exists.

Constructor Summary

Constructors

Constructor and Description
BasicNonByteBufferOperations(AlluxioURI filePath, ReadType readType, WriteType writeType, boolean deleteIfExists, int length, FileSystemContext fsContext, WorkerNetAddress workerNetAddress)

Method Summary

Modifier and Type	Method and Description
Boolean	call()

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicNonByteBufferOperations

public BasicNonByteBufferOperations(AlluxioURI filePath,
                                    ReadType readType,
                                    WriteType writeType,
                                    boolean deleteIfExists,
                                    int length,
                                    FileSystemContext fsContext,
                                    @Nullable
                                    WorkerNetAddress workerNetAddress)

Parameters:

filePath - the path for the files

readType - the ReadType

writeType - the WriteType

deleteIfExists - delete files if they already exist

length - the number of files

fsContext - the FileSystemContext to use for client operations

workerNetAddress - if not null, the worker address the file data will be written into

Method Detail

call

public Boolean call()
             throws Exception

Specified by:

call in interface Callable<Boolean>

Throws:

Exception