org.apache.hadoop.hive.llap

Class LlapOutputFormatService

java.lang.Object

org.apache.hadoop.hive.llap.LlapOutputFormatService

public class LlapOutputFormatService
extends Object

Responsible for sending back result set data to the connections made by external clients via the LLAP input format.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	LlapOutputFormatService.LlapOutputFormatChannelCloseListener
protected class	LlapOutputFormatService.LlapOutputFormatServiceChannelHandler
protected class	LlapOutputFormatService.LlapOutputFormatServiceHandler

Method Summary

Modifier and Type	Method and Description
static LlapOutputFormatService	get()
int	getPort()
<K,V> org.apache.hadoop.mapred.RecordWriter<K,V>	getWriter(String id)
static void	initializeAndStart(org.apache.hadoop.conf.Configuration conf, SecretManager sm)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Method Detail

initializeAndStart

public static void initializeAndStart(org.apache.hadoop.conf.Configuration conf,
                                      SecretManager sm)
                               throws Exception

Throws:

Exception

get

public static LlapOutputFormatService get()
                                   throws IOException

Throws:

IOException

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()
          throws IOException,
                 InterruptedException

Throws:

IOException

InterruptedException

getWriter

public <K,V> org.apache.hadoop.mapred.RecordWriter<K,V> getWriter(String id)
                                                           throws IOException,
                                                                  InterruptedException

Throws:

IOException

InterruptedException

getPort

public int getPort()