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 | Field and Description |
---|---|
protected FileSystemContext |
AbstractCollectInfoCommand.mFsContext |
Modifier and Type | Method and Description |
---|---|
static String |
CollectMetricsCommand.masterMetrics(FileSystemContext fsContext)
Get master metrics.
|
static List<String> |
CollectMetricsCommand.workerMetrics(FileSystemContext fsContext)
Get metrics from each worker.
|
Constructor and Description |
---|
AbstractCollectInfoCommand(FileSystemContext fsContext)
Creates an instance of
AbstractCollectInfoCommand . |
CollectAlluxioInfoCommand(FileSystemContext fsContext)
Creates a new instance of
CollectAlluxioInfoCommand . |
CollectConfigCommand(FileSystemContext fsContext)
Creates a new instance of
CollectConfigCommand . |
CollectEnvCommand(FileSystemContext fsContext)
Creates a new instance of
CollectEnvCommand . |
CollectJvmInfoCommand(FileSystemContext fsContext)
Creates an instance of
CollectJvmInfoCommand . |
CollectLogCommand(FileSystemContext fsContext)
Creates a new instance of
CollectLogCommand . |
CollectMetricsCommand(FileSystemContext fsContext)
Creates a new instance of
CollectMetricsCommand . |
ExecuteShellCollectInfoCommand(FileSystemContext fsContext)
Creates a new instance of
ExecuteShellCollectInfoCommand . |
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 |
---|
CancelCommand(FileSystemContext fsContext)
creates the cancel command.
|
GetCmdStatusCommand(FileSystemContext fsContext) |
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 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 UfsFallbackLocalFileDataWriter |
UfsFallbackLocalFileDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long blockId,
long blockSize,
OutStreamOptions options) |
static LocalFileDataWriter |
LocalFileDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long blockId,
long blockSize,
OutStreamOptions options)
Creates an instance of
LocalFileDataWriter . |
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,
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,
List<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,
List<InetSocketAddress> masterAddresses) |
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, java.util.List<java.net.InetSocketAddress>) methods. |
FileSystemContext |
BaseFileSystem.getFileSystemContext() |
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. |
Modifier and Type | Field and Description |
---|---|
protected FileSystemContext |
UfsBaseFileSystem.mFsContext |
Constructor and Description |
---|
UfsBaseFileSystem(FileSystemContext fsContext,
UfsFileSystemOptions options)
Constructs a new base file system.
|
Modifier and Type | Method and Description |
---|---|
static FuseUmountable |
AlluxioFuse.launchFuse(FileSystemContext fsContext,
FileSystem fs,
FuseOptions fuseOptions,
boolean blocking)
Launches Fuse application.
|
static AlluxioConfiguration |
AlluxioFuseUtils.tryLoadingConfigFromMaster(FileSystemContext fsContext)
Tries to laod Alluxio config from Alluxio Master through Grpc.
|
Constructor and Description |
---|
AlluxioJniFuseFileSystem(FileSystemContext fsContext,
FileSystem fs,
FuseOptions fuseOptions)
Creates a new instance of
AlluxioJniFuseFileSystem . |
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(URIStatus status,
FileSystemContext context,
long blockId,
WorkerNetAddress address,
boolean directCache)
Loads a block into the local worker.
|
Modifier and Type | Method and Description |
---|---|
FileSystem |
MultiMasterEmbeddedJournalLocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
MultiMasterLocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
LocalAlluxioCluster.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) |
Constructor and Description |
---|
JobMaster(MasterContext masterContext,
FileSystem filesystem,
FileSystemContext fsContext,
UfsManager ufsManager)
Creates a new instance of
JobMaster . |
Modifier and Type | Field and Description |
---|---|
protected FileSystemContext |
AbstractCmdRunner.mFsContext |
protected FileSystemContext |
CmdJobTracker.mFsContext |
Constructor and Description |
---|
AbstractCmdRunner(FileSystemContext fsContext,
JobMaster jobMaster) |
CmdJobTracker(FileSystemContext fsContext,
DistLoadCliRunner distLoadCliRunner,
MigrateCliRunner migrateCliRunner,
PersistRunner persistRunner)
Constructor with runner providers.
|
CmdJobTracker(FileSystemContext fsContext,
JobMaster jobMaster)
Create a new instance of
CmdJobTracker . |
DistLoadCliRunner(FileSystemContext fsContext,
JobMaster jobMaster)
constructor.
|
MigrateCliRunner(FileSystemContext fsContext,
JobMaster jobMaster)
constructor.
|
PersistRunner(FileSystemContext fsContext,
JobMaster jobMaster)
constructor.
|
Constructor and Description |
---|
DefaultWorkerProvider(FileSystemMaster fileSystemMaster,
FileSystemContext context)
Creates a new instance of
DefaultWorkerProvider . |
Modifier and Type | Method and Description |
---|---|
FileSystemContext |
MultiProcessCluster.getFilesystemContext() |
Constructor and Description |
---|
CacheRequestManager(ExecutorService service,
DefaultBlockWorker blockWorker,
FileSystemContext fsContext) |
FuseManager(FileSystemContext fsContext)
Constructs a new
FuseManager . |
RemoteBlockReader(FileSystemContext fsContext,
long blockId,
long blockSize,
InetSocketAddress dataSource,
Protocol.OpenUfsBlockOptions ufsOptions)
Constructs a remote block reader.
|
Copyright © 2023. All Rights Reserved.