Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.block.stream | |
alluxio.client.file | |
alluxio.client.lineage | |
alluxio.client.metrics | |
alluxio.hadoop | |
alluxio.master |
Modifier and Type | Method and Description |
---|---|
static AlluxioBlockStore |
AlluxioBlockStore.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 PacketWriter |
PacketWriter.Factory.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options) |
static BlockOutStream |
BlockOutStream.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options)
Creates an
BlockOutStream . |
static NettyPacketWriter |
NettyPacketWriter.create(FileSystemContext context,
WorkerNetAddress address,
long id,
long length,
Protocol.RequestType type,
OutStreamOptions options) |
static LocalFilePacketWriter |
LocalFilePacketWriter.create(FileSystemContext context,
WorkerNetAddress address,
long blockId,
OutStreamOptions options)
Creates an instance of
LocalFilePacketWriter . |
static UnderFileSystemFileOutStream |
UnderFileSystemFileOutStream.create(FileSystemContext context,
WorkerNetAddress address,
OutStreamOptions options)
Creates an instance of
UnderFileSystemFileOutStream that writes to a UFS file. |
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. |
Constructor and Description |
---|
Factory(FileSystemContext context,
WorkerNetAddress address,
long blockId,
long packetSize,
InStreamOptions options)
Creates an instance of
LocalFilePacketReader.Factory . |
Factory(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest readRequestPartial)
Creates an instance of
NettyPacketReader.Factory for block reads. |
Modifier and Type | Field and Description |
---|---|
protected FileSystemContext |
BaseFileSystem.mFileSystemContext |
Modifier and Type | Method and Description |
---|---|
static FileSystemContext |
FileSystemContext.create(Subject subject,
MasterInquireClient masterInquireClient)
This method is provided for testing, use the
get() methods. |
static FileSystemContext |
FileSystemContext.get() |
static FileSystemContext |
FileSystemContext.get(Subject subject) |
Modifier and Type | Method and Description |
---|---|
static BaseFileSystem |
BaseFileSystem.get(FileSystemContext context) |
static FileSystem |
FileSystem.Factory.get(FileSystemContext context) |
Constructor and Description |
---|
BaseFileSystem(FileSystemContext context)
Constructs a new base file system.
|
FileInStream(URIStatus status,
InStreamOptions options,
FileSystemContext context) |
FileOutStream(AlluxioURI path,
OutStreamOptions options,
FileSystemContext context)
Creates a new file output stream.
|
Modifier and Type | Method and Description |
---|---|
static LineageFileSystem |
LineageFileSystem.get(FileSystemContext fileSystemContext,
LineageContext lineageContext) |
Constructor and Description |
---|
LineageFileOutStream(FileSystemContext context,
AlluxioURI path,
OutStreamOptions options)
Creates a new file output stream when lineage is enabled.
|
Constructor and Description |
---|
ClientMasterSync(MetricsMasterClient masterClient,
FileSystemContext context)
Constructs a new
ClientMasterSync . |
Constructor and Description |
---|
HdfsFileInputStream(FileSystemContext context,
AlluxioURI uri,
org.apache.hadoop.fs.FileSystem.Statistics stats)
Constructs a new stream for reading a file from HDFS.
|
Modifier and Type | Method and Description |
---|---|
FileSystem |
LocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
MultiMasterLocalAlluxioCluster.getClient(FileSystemContext context) |
abstract FileSystem |
AbstractLocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
ClientPool.getClient(FileSystemContext context)
Returns a
FileSystem client using a specific context. |
FileSystem |
LocalAlluxioMaster.getClient(FileSystemContext context) |
Copyright © 2023. All Rights Reserved.