Constructor and Description |
---|
BasicCheckpoint(String fileFolder,
int numFiles,
FileSystemContext fsContext) |
BasicNonByteBufferOperations(AlluxioURI filePath,
ReadType readType,
WriteType writeType,
boolean deleteIfExists,
int length,
FileSystemContext fsContext,
WorkerNetAddress workerNetAddress) |
BasicOperations(AlluxioURI filePath,
ReadType readType,
WriteType writeType,
FileSystemContext fsContext,
WorkerNetAddress workerNetAddress) |
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 |
---|
AbstractDistributedJobCommand(FileSystemContext fsContext) |
AbstractFileSystemCommand(FileSystemContext fsContext) |
CatCommand(FileSystemContext fsContext) |
CheckCachedCommand(FileSystemContext fsContext) |
ChecksumCommand(FileSystemContext fsContext) |
ChgrpCommand(FileSystemContext fsContext)
Creates a new instance of
ChgrpCommand . |
ChmodCommand(FileSystemContext fsContext)
Creates a new instance of
ChmodCommand . |
ChownCommand(FileSystemContext fsContext)
Creates a new instance of
ChownCommand . |
ConsistentHashCommand(FileSystemContext fsContext) |
CpCommand(FileSystemContext fsContext) |
FreeCommand(FileSystemContext fsContext)
Constructs a new instance to free the given file or folder from Alluxio.
|
HeadCommand(FileSystemContext fsContext) |
HelpCommand(FileSystemContext fsContext) |
LoadCommand(FileSystemContext fsContext)
Constructs a new instance to load a file or directory in Alluxio space.
|
LocationCommand(FileSystemContext fsContext)
Constructs a new instance to display a list of hosts that have the file specified in args
stored.
|
LsCommand(FileSystemContext fsContext)
Constructs a new instance to display information for all directories and files directly under
the path specified in args.
|
MkdirCommand(FileSystemContext fsContext)
Constructs a new instance to create a new directory.
|
MvCommand(FileSystemContext fsContext) |
RmCommand(FileSystemContext fsContext) |
StatCommand(FileSystemContext fsContext) |
TailCommand(FileSystemContext fsContext) |
TestCommand(FileSystemContext fsContext) |
TouchCommand(FileSystemContext fsContext) |
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 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 NettyDataWriter |
NettyDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long id,
long length,
RequestType type,
OutStreamOptions options) |
static GrpcDataWriter |
GrpcDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long id,
long length,
RequestType type,
OutStreamOptions options) |
static BufferCachingGrpcDataReader |
BufferCachingGrpcDataReader.create(FileSystemContext context,
WorkerNetAddress address,
ReadRequest readRequest)
Creates an instance of
BufferCachingGrpcDataReader for block reads. |
Constructor and Description |
---|
Factory(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest.Builder readRequestBuilder)
Creates an instance of
NettyDataReader.Factory for block reads. |
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 |
DoraCacheFileSystem.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. |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.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. |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.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. |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.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) |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(ClientContext clientContext) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker) |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(ClientContext ctx,
BlockWorker blockWorker) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses) |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(ClientContext ctx,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses) |
static FileSystemContext |
FileSystemContext.create(Subject subject,
AlluxioConfiguration conf) |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.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 |
FileSystemContext.FileSystemContextFactory.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. |
Modifier and Type | Method and Description |
---|---|
static FileSystem |
FileSystem.Factory.create(FileSystemContext context) |
static FileSystem |
FileSystem.Factory.create(FileSystemContext context,
FileSystemOptions options) |
DoraCacheFileSystem |
DoraCacheFileSystem.DoraCacheFileSystemFactory.createAnInstance(FileSystem fs,
FileSystemContext context) |
Constructor and Description |
---|
ConfigHashSync(FileSystemContext context)
Constructs a new
ConfigHashSync . |
DoraCacheFileSystem(FileSystem fs,
FileSystemContext context)
Wraps a file system instance to forward messages.
|
DoraCacheFileSystem(FileSystem fs,
FileSystemContext context,
DoraCacheClient doraCacheClient) |
DoraFileOutStream(DoraCacheClient doraClient,
NettyDataWriter dataWriter,
AlluxioURI path,
OutStreamOptions options,
FileSystemContext context,
FileOutStream ufsOutStream,
String uuid)
Creates a new file output stream.
|
FileSystemContextReinitializer(FileSystemContext context)
Creates a new reinitializer for the context.
|
FileSystemContextReinitializer(FileSystemContext context,
ConfigHashSync configHashSync)
Creates a new reinitializer for the context.
|
MetadataCachingFileSystem(FileSystem fileSystem,
FileSystemContext context) |
Modifier and Type | Method and Description |
---|---|
FileSystemContext |
DoraCacheClient.getContext()
Get Context.
|
Modifier and Type | Method and Description |
---|---|
DoraFileOutStream |
DoraCacheClient.getOutStream(AlluxioURI alluxioPath,
FileSystemContext fsContext,
OutStreamOptions outStreamOptions,
FileOutStream ufsOutStream,
String uuid)
Get a stream to write the data to dora cache cluster.
|
Constructor and Description |
---|
DoraCacheClient(FileSystemContext context)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static NettyDataWriter |
NettyDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long length,
RequestType type,
OutStreamOptions options) |
Constructor and Description |
---|
NettyDataReader(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest.Builder requestBuilder)
Constructor.
|
NettyDataReaderStateMachine(FileSystemContext context,
WorkerNetAddress address,
Protocol.ReadRequest.Builder requestBuilder,
ReadTargetBuffer buffer)
Constructor.
|
NettyDataWriter(FileSystemContext context,
WorkerNetAddress address,
long length,
long packetSize,
RequestType type,
OutStreamOptions options,
io.netty.channel.Channel channel)
Creates an instance of
NettyDataWriter . |
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. |
OutStreamOptions(FileSystemContext context,
AlluxioConfiguration alluxioConf) |
Modifier and Type | Field and Description |
---|---|
protected FileSystemContext |
UfsBaseFileSystem.mFsContext |
Constructor and Description |
---|
DoraOutStream(AlluxioURI path,
OutStreamOptions options,
FileSystemContext context,
String uuid,
DoraCacheClient doraClient)
Creates a new file output stream.
|
UfsBaseFileSystem(FileSystemContext fsContext,
UfsFileSystemOptions options)
Constructs a new base file system.
|
UfsBaseFileSystem(FileSystemContext fsContext,
UfsFileSystemOptions options,
UfsManager.UfsClient ufs)
Constructs a wrapper file system based on given UnderFileSystem.
|
Modifier and Type | Method and Description |
---|---|
protected FileSystem |
AlluxioFuse.createBaseFileSystem(FileSystemContext fsContext,
FuseOptions fuseOptions) |
AlluxioJniFuseFileSystem |
AlluxioFuse.createFuseFileSystem(FileSystemContext fsContext,
FileSystem fs,
FuseOptions fuseOptions)
Create a FuseFileSystem instance.
|
protected AlluxioJniFuseFileSystem |
AlluxioFuse.createJniFuseSystem(FileSystemContext fsContext,
FileSystem fs,
FuseOptions fuseOptions) |
static AlluxioJniFuseFileSystem |
AlluxioFuse.launchFuse(AlluxioJniFuseFileSystem fuseFs,
FileSystemContext fsContext,
FuseOptions fuseOptions,
boolean blocking)
Launches Fuse application.
|
protected void |
AlluxioFuse.startCommon(AlluxioConfiguration conf,
FuseOptions fuseOptions,
FileSystemContext fsContext)
Start common functionalities for a fuse client.
|
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 |
---|---|
FileSystem |
MultiMasterLocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
MultiMasterEmbeddedJournalLocalAlluxioCluster.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) |
abstract FileSystem |
AbstractLocalAlluxioCluster.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,
JobMaster jobMaster)
Create a new instance of
CmdJobTracker . |
CmdJobTracker(FileSystemContext fsContext,
MigrateCliRunner migrateCliRunner,
PersistRunner persistRunner)
Constructor with runner providers.
|
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 . |
MembershipManagerWorkerProvider(MembershipManager membershipMgr,
FileSystemContext context)
CTOR for MembershipManagerWorkerProvider.
|
Scheduler(FileSystemContext fsCtx,
WorkerProvider workerProvider,
JobMetaStore jobMetaStore)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
FileSystemContext |
MultiProcessCluster.getFilesystemContext() |
Constructor and Description |
---|
PagedDoraWorker(AtomicReference<Long> workerId,
WorkerIdentity identity,
AlluxioConfiguration conf,
CacheManager cacheManager,
MembershipManager membershipManager,
BlockMasterClientPool blockMasterClientPool,
FileSystemContext fileSystemContext) |
Copyright © 2023. All Rights Reserved.