org.apache.hadoop.hbase.io.asyncfs

Class FanOutOneBlockAsyncDFSOutputHelper

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutputHelper

@InterfaceAudience.Private
public final class FanOutOneBlockAsyncDFSOutputHelper
extends Object

Helper class for implementing FanOutOneBlockAsyncDFSOutput.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FanOutOneBlockAsyncDFSOutputHelper.NameNodeException Exception other than RemoteException thrown when calling create on namenode

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASYNC_DFS_OUTPUT_CREATE_MAX_RETRIES
static int	DEFAULT_ASYNC_DFS_OUTPUT_CREATE_MAX_RETRIES
static long	HEART_BEAT_SEQNO
static int	READ_TIMEOUT

Method Summary

Modifier and Type	Method and Description
static FanOutOneBlockAsyncDFSOutput	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) Create a FanOutOneBlockAsyncDFSOutput.
static boolean	shouldRetryCreate(org.apache.hadoop.ipc.RemoteException e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ASYNC_DFS_OUTPUT_CREATE_MAX_RETRIES

public static final String ASYNC_DFS_OUTPUT_CREATE_MAX_RETRIES

See Also:

Constant Field Values

DEFAULT_ASYNC_DFS_OUTPUT_CREATE_MAX_RETRIES

public static final int DEFAULT_ASYNC_DFS_OUTPUT_CREATE_MAX_RETRIES

See Also:

Constant Field Values

HEART_BEAT_SEQNO

public static final long HEART_BEAT_SEQNO

See Also:

Constant Field Values

READ_TIMEOUT

public static final int READ_TIMEOUT

See Also:

Constant Field Values

Method Detail

createOutput

public static FanOutOneBlockAsyncDFSOutput 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)
                                                 throws IOException

Create a FanOutOneBlockAsyncDFSOutput. The method maybe blocked so do not call it inside an EventLoop.

Throws:

IOException

shouldRetryCreate

public static boolean shouldRetryCreate(org.apache.hadoop.ipc.RemoteException e)