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 and Description
private StreamSlowMonitor	FanOutOneBlockAsyncDFSOutput.streamSlowMonitor

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

Modifier and Type	Method and Description
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) Create a FanOutOneBlockAsyncDFSOutput.
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)
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) Create FanOutOneBlockAsyncDFSOutput for DistributedFileSystem, and a simple implementation for other FileSystem which wraps around a FSDataOutputStream.

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

Constructor and Description

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, long fileId, 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 and Description
private Map<String,StreamSlowMonitor>	ExcludeDatanodeManager.streamSlowMonitors

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

Modifier and Type	Method and 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 and Description
private StreamSlowMonitor	AsyncFSWAL.streamSlowMonitor

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

Modifier and Type	Method and 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 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)
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)
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)

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

Constructor and 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.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 and 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	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)
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)