Modifier and Type | Method and Description |
---|---|
static Map<String,Command> |
FileSystemShellUtils.loadCommands(FileSystemContext fsContext)
Gets all
Command instances in the same package as FileSystemShell and load them
into a map. |
Modifier and Type | Field and Description |
---|---|
protected FileSystemContext |
AbstractFileSystemCommand.mFsContext |
Constructor and Description |
---|
LeaderCommand(FileSystemContext fsContext)
creates the job leader command.
|
ListCommand(FileSystemContext fsContext)
Creates the job list command.
|
StatCommand(FileSystemContext fsContext)
Creates the job stat command.
|
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 BlockOutStream |
BlockOutStream.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options)
Creates an
BlockOutStream . |
static DataWriter |
DataWriter.Factory.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options) |
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 LocalFileDataWriter |
LocalFileDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long blockId,
OutStreamOptions options)
Creates an instance of
LocalFileDataWriter . |
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. |
static BlockOutStream |
BlockOutStream.createReplicatedBlockOutStream(FileSystemContext context,
long blockId,
long blockSize,
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 readRequestPartial)
Creates an instance of
GrpcDataReader.Factory for block reads. |
Modifier and Type | Field and Description |
---|---|
protected FileSystemContext |
BaseFileSystem.mFsContext |
Modifier and Type | Method and Description |
---|---|
static FileSystemContext |
FileSystemContext.create(AlluxioConfiguration conf)
Creates a
FileSystemContext with a null subject. |
static FileSystemContext |
FileSystemContext.create(ClientContext clientContext) |
static FileSystemContext |
FileSystemContext.create(Subject subject,
AlluxioConfiguration conf) |
static FileSystemContext |
FileSystemContext.create(Subject subject,
MasterInquireClient masterInquireClient,
AlluxioConfiguration alluxioConf)
This method is provided for testing, use the
create(alluxio.conf.AlluxioConfiguration) methods. |
Modifier and Type | Method and Description |
---|---|
static FileSystem |
FileSystem.Factory.create(FileSystemContext context) |
static BaseFileSystem |
BaseFileSystem.create(FileSystemContext context) |
static BaseFileSystem |
BaseFileSystem.create(FileSystemContext context,
boolean cachingEnabled) |
Constructor and Description |
---|
BaseFileSystem(FileSystemContext fsContext,
boolean cachingEnabled)
Constructs a new base file system.
|
CachingFileSystem(FileSystemContext context,
boolean cachingEnabled) |
ConfigHashSync(FileSystemContext context)
Constructs a new
ConfigHashSync . |
FileInStream(URIStatus status,
InStreamOptions options,
FileSystemContext context) |
FileOutStream(AlluxioURI path,
OutStreamOptions options,
FileSystemContext context)
Creates a new file output stream.
|
FileSystemContextReinitializer(FileSystemContext context)
Creates a new reinitializer for the context.
|
Constructor and Description |
---|
BasicCheckpoint(String fileFolder,
int numFiles,
FileSystemContext fsContext) |
BasicNonByteBufferOperations(AlluxioURI filePath,
ReadType readType,
WriteType writeType,
boolean deleteIfExists,
int length,
FileSystemContext fsContext) |
BasicOperations(AlluxioURI filePath,
ReadType readType,
WriteType writeType,
FileSystemContext fsContext) |
Modifier and Type | Method and Description |
---|---|
FileSystemContext |
JobServerContext.getFsContext() |
Constructor and Description |
---|
JobServerContext(FileSystem filesystem,
FileSystemContext fsContext,
UfsManager ufsManager)
Creates a new instance of
JobServerContext . |
Modifier and Type | Method and Description |
---|---|
static void |
JobUtils.loadBlock(FileSystem fs,
FileSystemContext context,
String path,
long blockId)
Loads a block into the local worker.
|
Modifier and Type | Method and Description |
---|---|
FileSystem |
MultiMasterLocalAlluxioCluster.getClient(FileSystemContext context) |
abstract FileSystem |
AbstractLocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
LocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
ClientPool.getClient(FileSystemContext context)
Returns a
FileSystem client using a specific context. |
FileSystem |
LocalAlluxioMaster.getClient(FileSystemContext context) |
Constructor and Description |
---|
JobMaster(MasterContext masterContext,
FileSystem filesystem,
FileSystemContext fsContext,
UfsManager ufsManager)
Creates a new instance of
JobMaster . |
Modifier and Type | Method and Description |
---|---|
FileSystemContext |
MultiProcessCluster.getFilesystemContext() |
Constructor and Description |
---|
AsyncCacheRequestManager(ExecutorService service,
BlockWorker blockWorker,
FileSystemContext fsContext) |
RemoteBlockReader(FileSystemContext fsContext,
long blockId,
long blockSize,
InetSocketAddress dataSource,
Protocol.OpenUfsBlockOptions ufsOptions)
Constructs a remote block reader.
|
Constructor and Description |
---|
BlockWorkerImpl(WorkerProcess workerProcess,
FileSystemContext fsContext,
boolean domainSocketEnabled)
Creates a new implementation of gRPC BlockWorker interface.
|
Copyright © 2023. All Rights Reserved.