| Package | Description |
|---|---|
| alluxio.client.block | |
| alluxio.client.block.stream | |
| alluxio.client.file | |
| alluxio.client.file.options |
| Modifier and Type | Method and Description |
|---|---|
static BlockStoreClient |
BlockStoreClient.create(FileSystemContext context)
Creates an Alluxio block store with default local hostname.
|
| Modifier and Type | Method and Description |
|---|---|
static BlockInStream |
BlockInStream.create(FileSystemContext context,
BlockInfo info,
WorkerNetAddress dataSource,
BlockInStream.BlockInStreamSource dataSourceType,
InStreamOptions options)
Creates a
BlockInStream. |
static BlockWorkerDataWriter |
BlockWorkerDataWriter.create(FileSystemContext context,
long blockId,
long blockSize,
OutStreamOptions options)
Creates an instance of
BlockWorkerDataWriter. |
static DataWriter |
DataWriter.Factory.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options) |
static LocalFileDataWriter |
LocalFileDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long blockId,
long blockSize,
OutStreamOptions options)
Creates an instance of
LocalFileDataWriter. |
static UfsFallbackLocalFileDataWriter |
UfsFallbackLocalFileDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long blockId,
long blockSize,
OutStreamOptions options) |
static GrpcDataWriter |
GrpcDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long id,
long length,
RequestType type,
OutStreamOptions options) |
static UnderFileSystemFileOutStream |
UnderFileSystemFileOutStream.create(FileSystemContext context,
WorkerNetAddress address,
OutStreamOptions options)
Creates an instance of
UnderFileSystemFileOutStream that writes to a UFS file. |
static BufferCachingGrpcDataReader |
BufferCachingGrpcDataReader.create(FileSystemContext context,
WorkerNetAddress address,
ReadRequest readRequest)
Creates an instance of
BufferCachingGrpcDataReader for block reads. |
static BlockInStream |
BlockInStream.createRemoteBlockInStream(FileSystemContext context,
long blockId,
WorkerNetAddress address,
BlockInStream.BlockInStreamSource blockSource,
long blockSize,
Protocol.OpenUfsBlockOptions ufsOptions)
Creates a
BlockInStream to read from a specific remote server. |
static BlockOutStream |
BlockOutStream.createReplicatedBlockOutStream(FileSystemContext context,
long blockId,
long blockSize,
java.util.List<WorkerNetAddress> workerNetAddresses,
OutStreamOptions options)
Creates a new remote block output stream.
|
| Constructor and Description |
|---|
Factory(FileSystemContext context,
WorkerNetAddress address,
long blockId,
long localReaderChunkSize,
InStreamOptions options)
Creates an instance of
LocalFileDataReader.Factory. |
Factory(FileSystemContext context,
WorkerNetAddress address,
ReadRequest.Builder readRequestBuilder)
Creates an instance of
GrpcDataReader.Factory for block reads. |
Factory(FileSystemContext context,
WorkerNetAddress address,
ReadRequest.Builder readRequestBuilder,
long blockSize)
Creates an instance of
SharedGrpcDataReader.Factory for block reads. |
| Modifier and Type | Field and Description |
|---|---|
protected FileSystemContext |
BaseFileSystem.mFsContext |
| Modifier and Type | Method and Description |
|---|---|
static FileSystemContext |
FileSystemContext.create()
Creates a
FileSystemContext with an empty subject, default config
and a null local block worker. |
static FileSystemContext |
FileSystemContext.create(AlluxioConfiguration conf)
Creates a
FileSystemContext with an empty subject
and a null local block worker. |
static FileSystemContext |
FileSystemContext.create(AlluxioConfiguration conf,
java.util.List<java.net.InetSocketAddress> masterAddresses)
Creates a
FileSystemContext with an empty subject
, a null local block worker, and the given master addresses. |
static FileSystemContext |
FileSystemContext.create(ClientContext clientContext) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker,
java.util.List<java.net.InetSocketAddress> masterAddresses) |
static FileSystemContext |
FileSystemContext.create(javax.security.auth.Subject subject,
AlluxioConfiguration conf) |
static FileSystemContext |
FileSystemContext.create(javax.security.auth.Subject subject,
MasterInquireClient masterInquireClient,
AlluxioConfiguration alluxioConf)
This method is provided for testing, use the
create(alluxio.conf.AlluxioConfiguration, java.util.List<java.net.InetSocketAddress>) methods. |
| Modifier and Type | Method and Description |
|---|---|
static FileSystem |
FileSystem.Factory.create(FileSystemContext context) |
static FileSystem |
FileSystem.Factory.create(FileSystemContext context,
FileSystemOptions options) |
| Constructor and Description |
|---|
AlluxioFileInStream(URIStatus status,
InStreamOptions options,
FileSystemContext context) |
AlluxioFileOutStream(AlluxioURI path,
OutStreamOptions options,
FileSystemContext context)
Creates a new file output stream.
|
BaseFileSystem(FileSystemContext fsContext)
Constructs a new base file system.
|
ConfigHashSync(FileSystemContext context)
Constructs a new
ConfigHashSync. |
FileSystemContextReinitializer(FileSystemContext context)
Creates a new reinitializer for the context.
|
MetadataCachingFileSystem(FileSystem fileSystem,
FileSystemContext context) |
| Modifier and Type | Method and Description |
|---|---|
static OutStreamOptions |
OutStreamOptions.defaults(FileSystemContext context) |
static OutStreamOptions |
OutStreamOptions.defaults(FileSystemContext context,
AlluxioConfiguration alluxioConf) |
| Constructor and Description |
|---|
InStreamOptions(URIStatus status,
AlluxioConfiguration alluxioConf,
FileSystemContext context)
Creates with the default
OpenFilePOptions. |
InStreamOptions(URIStatus status,
OpenFilePOptions options,
AlluxioConfiguration alluxioConf,
FileSystemContext context)
Creates with given
OpenFilePOptions instance. |
OutStreamOptions(CreateFilePOptions options,
FileSystemContext context,
AlluxioConfiguration alluxioConf)
Creates an
OutStreamOptions instance from given options. |
Copyright © 2022. All Rights Reserved.