public class LlapOutputFormatService extends Object
Modifier and Type | Class and Description |
---|---|
protected class |
LlapOutputFormatService.LlapOutputFormatChannelCloseListener |
protected class |
LlapOutputFormatService.LlapOutputFormatServiceChannelHandler |
protected class |
LlapOutputFormatService.LlapOutputFormatServiceHandler |
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() |
public static void initializeAndStart(org.apache.hadoop.conf.Configuration conf, SecretManager sm) throws Exception
Exception
public static LlapOutputFormatService get() throws IOException
IOException
public void start() throws IOException
IOException
public void stop() throws IOException, InterruptedException
IOException
InterruptedException
public <K,V> org.apache.hadoop.mapred.RecordWriter<K,V> getWriter(String id) throws IOException, InterruptedException
IOException
InterruptedException
public int getPort()
Copyright © 2021 The Apache Software Foundation. All rights reserved.