org.apache.hadoop.hbase.client.example

Class HttpProxyExample

java.lang.Object

org.apache.hadoop.hbase.client.example.HttpProxyExample

@InterfaceAudience.Private
public class HttpProxyExample
extends Object

A simple example on how to use AsyncTable to write a fully asynchronous HTTP proxy server. The AsyncConnection will share the same event loop with the HTTP server.

The request URL is:

 http://<host>:<port>/<table>/<rowgt;/<family>:<qualifier>
 

Use HTTP GET to fetch data, and use HTTP PUT to put data. Encode the value as the request content when doing PUT.

Notice that, future class methods will all return a new Future, so you always have one future that will not been checked, so we need to suppress error-prone "FutureReturnValueIgnored" warnings on the methods such as join and stop. In your real production code, you should use your own convenient way to address the warning.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	HttpProxyExample.Params
private static class	HttpProxyExample.RequestHandler

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	bossGroup
private org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup	channelGroup
private org.apache.hadoop.conf.Configuration	conf
private AsyncConnection	conn
private int	port
private org.apache.hbase.thirdparty.io.netty.channel.Channel	serverChannel
private org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	workerGroup

Constructor Summary

Constructors

Constructor and Description
HttpProxyExample(org.apache.hadoop.conf.Configuration conf, int port)

Method Summary

Modifier and Type	Method and Description
void	join()
static void	main(String[] args)
int	port()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

bossGroup

private final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup bossGroup

workerGroup

private final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup workerGroup

conf

private final org.apache.hadoop.conf.Configuration conf

port

private final int port

conn

private AsyncConnection conn

serverChannel

private org.apache.hbase.thirdparty.io.netty.channel.Channel serverChannel

channelGroup

private org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup channelGroup

Constructor Detail

HttpProxyExample

public HttpProxyExample(org.apache.hadoop.conf.Configuration conf,
                        int port)

Method Detail

start

public void start()
           throws InterruptedException,
                  ExecutionException

Throws:

InterruptedException

ExecutionException

join

public void join()

port

public int port()

stop

public void stop()
          throws IOException

Throws:

IOException

main

public static void main(String[] args)
                 throws InterruptedException,
                        ExecutionException

Throws:

InterruptedException

ExecutionException