Uses of Class
org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor

Packages that use org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor
Package
Description
org.apache.hadoop.hbase.io.asyncfs
 
org.apache.hadoop.hbase.io.asyncfs.monitor
 
org.apache.hadoop.hbase.regionserver.wal
 
org.apache.hadoop.hbase.wal
 

  • Uses of org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in org.apache.hadoop.hbase.io.asyncfs

    Methods in org.apache.hadoop.hbase.io.asyncfs with parameters of type org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in in
    Modifier and Type
    Method
    Description
    static org.apache.hadoop.hbase.io.asyncfs.AsyncFSOutput
    AsyncFSOutputHelper.createOutput(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path f, boolean overwrite, boolean createParent, short replication, long blockSize, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor, boolean noLocalWrite)
    Create FanOutOneBlockAsyncDFSOutput for DistributedFileSystem, and a simple implementation for other FileSystem which wraps around a FSDataOutputStream.
    static org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutput
    FanOutOneBlockAsyncDFSOutputHelper.createOutput(org.apache.hadoop.hdfs.DistributedFileSystem dfs, org.apache.hadoop.fs.Path f, boolean overwrite, boolean createParent, short replication, long blockSize, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor, boolean noLocalWrite)
    Create a FanOutOneBlockAsyncDFSOutput.

  • Uses of org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in org.apache.hadoop.hbase.io.asyncfs.monitor

    Methods in org.apache.hadoop.hbase.io.asyncfs.monitor that return org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in in
    Modifier and Type
    Method
    Description
    static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor
    StreamSlowMonitor.create(org.apache.hadoop.conf.Configuration conf, String name)
     
    org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor
    ExcludeDatanodeManager.getStreamSlowMonitor(String name)
     

  • Uses of org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in org.apache.hadoop.hbase.regionserver.wal

    Methods in org.apache.hadoop.hbase.regionserver.wal with parameters of type org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in in
    Modifier and Type
    Method
    Description
    void
    AbstractProtobufLogWriter.init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf, boolean overwritable, long blocksize, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor)
     
    protected abstract void
    AbstractProtobufLogWriter.initOutput(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, int bufferSize, short replication, long blockSize, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor, boolean noLocalWrite)
     
    protected void
    AsyncProtobufLogWriter.initOutput(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, int bufferSize, short replication, long blockSize, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor, boolean noLocalWrite)
     
    protected void
    ProtobufLogWriter.initOutput(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, int bufferSize, short replication, long blockSize, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor, boolean noLocalWrite)
     
    Constructors in org.apache.hadoop.hbase.regionserver.wal with parameters of type org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in in
    Modifier
    Constructor
    Description
     
    AsyncFSWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.Abortable abortable, org.apache.hadoop.fs.Path rootDir, String logDir, String archiveDir, org.apache.hadoop.conf.Configuration conf, List<org.apache.hadoop.hbase.regionserver.wal.WALActionsListener> listeners, boolean failIfWALExists, String prefix, String suffix, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor)
     

  • Uses of org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in org.apache.hadoop.hbase.wal

    Methods in org.apache.hadoop.hbase.wal with parameters of type org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor in in
    Modifier and Type
    Method
    Description
    static org.apache.hadoop.hbase.wal.AsyncFSWALProvider.AsyncWriter
    AsyncFSWALProvider.createAsyncWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, long blocksize, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor)
    Public because of AsyncFSWAL.
    void
    AsyncFSWALProvider.AsyncWriter.init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration c, boolean overwritable, long blocksize, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor)
     
    void
    FSHLogProvider.Writer.init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration c, boolean overwritable, long blocksize, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor)