public class LlapBaseInputFormat<V extends org.apache.hadoop.io.WritableComparable> extends Object implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,V>
Modifier and Type | Field and Description |
---|---|
static String |
PWD_KEY |
static String |
QUERY_KEY |
String |
SPLIT_QUERY |
static String |
URL_KEY |
static String |
USER_KEY |
Constructor and Description |
---|
LlapBaseInputFormat() |
LlapBaseInputFormat(String url,
String user,
String pwd,
String query) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V> |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits) |
public static final String URL_KEY
public static final String QUERY_KEY
public static final String USER_KEY
public static final String PWD_KEY
public final String SPLIT_QUERY
public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws IOException
getRecordReader
in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.io.WritableComparable>
IOException
public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits) throws IOException
getSplits
in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.io.WritableComparable>
IOException
public void close()
Copyright © 2016 The Apache Software Foundation. All rights reserved.