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

Packages that use 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 StreamSlowMonitor in org.apache.hadoop.hbase.io.asyncfs

Fields in org.apache.hadoop.hbase.io.asyncfs declared as StreamSlowMonitor

Modifier and Type	Field	Description
private final StreamSlowMonitor	FanOutOneBlockAsyncDFSOutput.streamSlowMonitor

Methods in org.apache.hadoop.hbase.io.asyncfs with parameters of type StreamSlowMonitor

Modifier and Type	Method	Description
static 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, StreamSlowMonitor monitor, boolean noLocalWrite)	Create FanOutOneBlockAsyncDFSOutput for DistributedFileSystem, and a simple implementation for other FileSystem which wraps around a FSDataOutputStream.
private static FanOutOneBlockAsyncDFSOutput	FanOutOneBlockAsyncDFSOutputHelper.createOutput(org.apache.hadoop.hdfs.DistributedFileSystem dfs, String src, 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, StreamSlowMonitor monitor, boolean noLocalWrite)
static 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, StreamSlowMonitor monitor, boolean noLocalWrite)	Create a FanOutOneBlockAsyncDFSOutput.

Constructors in org.apache.hadoop.hbase.io.asyncfs with parameters of type StreamSlowMonitor

Modifier	Constructor	Description
(package private)	FanOutOneBlockAsyncDFSOutput(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hdfs.DistributedFileSystem dfs, org.apache.hadoop.hdfs.DFSClient client, org.apache.hadoop.hdfs.protocol.ClientProtocol namenode, String clientName, String src, org.apache.hadoop.hdfs.protocol.HdfsFileStatus stat, EnumSet<org.apache.hadoop.fs.CreateFlag> createFlags, org.apache.hadoop.hdfs.protocol.LocatedBlock locatedBlock, org.apache.hadoop.crypto.Encryptor encryptor, Map<org.apache.hbase.thirdparty.io.netty.channel.Channel,org.apache.hadoop.hdfs.protocol.DatanodeInfo> datanodeInfoMap, org.apache.hadoop.util.DataChecksum summer, org.apache.hbase.thirdparty.io.netty.buffer.ByteBufAllocator alloc, StreamSlowMonitor streamSlowMonitor)

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

Fields in org.apache.hadoop.hbase.io.asyncfs.monitor with type parameters of type StreamSlowMonitor

Modifier and Type	Field	Description
private final Map<String,StreamSlowMonitor>	ExcludeDatanodeManager.streamSlowMonitors

Methods in org.apache.hadoop.hbase.io.asyncfs.monitor that return StreamSlowMonitor

Modifier and Type	Method	Description
static StreamSlowMonitor	StreamSlowMonitor.create(org.apache.hadoop.conf.Configuration conf, String name)
StreamSlowMonitor	ExcludeDatanodeManager.getStreamSlowMonitor(String name)

Uses of StreamSlowMonitor in org.apache.hadoop.hbase.regionserver.wal

Fields in org.apache.hadoop.hbase.regionserver.wal declared as StreamSlowMonitor

Modifier and Type	Field	Description
private final StreamSlowMonitor	AsyncFSWAL.streamSlowMonitor

Methods in org.apache.hadoop.hbase.regionserver.wal with parameters of type StreamSlowMonitor

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, 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, 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, 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, StreamSlowMonitor monitor, boolean noLocalWrite)

Constructors in org.apache.hadoop.hbase.regionserver.wal with parameters of type StreamSlowMonitor

Modifier	Constructor	Description
	AsyncFSWAL(org.apache.hadoop.fs.FileSystem fs, Abortable abortable, org.apache.hadoop.fs.Path rootDir, String logDir, String archiveDir, org.apache.hadoop.conf.Configuration conf, List<WALActionsListener> listeners, boolean failIfWALExists, String prefix, String suffix, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, StreamSlowMonitor monitor)

Uses of StreamSlowMonitor in org.apache.hadoop.hbase.wal

Methods in org.apache.hadoop.hbase.wal with parameters of type StreamSlowMonitor

Modifier and Type	Method	Description
static 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, 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, 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, StreamSlowMonitor monitor)