org.apache.hadoop.hive.llap

Class LlapInputSplit

java.lang.Object

org.apache.hadoop.hive.llap.LlapInputSplit

All Implemented Interfaces:

org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit, org.apache.hadoop.mapred.InputSplitWithLocationInfo

public class LlapInputSplit
extends Object
implements org.apache.hadoop.mapred.InputSplitWithLocationInfo

Constructor Summary

Constructors

Constructor and Description
LlapInputSplit()
LlapInputSplit(int splitNum, byte[] planBytes, byte[] fragmentBytes, byte[] fragmentBytesSignature, org.apache.hadoop.mapred.SplitLocationInfo[] locations, Schema schema, String llapUser, byte[] tokenBytes)

Method Summary

Modifier and Type	Method and Description
byte[]	getFragmentBytes()
byte[]	getFragmentBytesSignature()
long	getLength()
String	getLlapUser()
org.apache.hadoop.mapred.SplitLocationInfo[]	getLocationInfo()
String[]	getLocations()
byte[]	getPlanBytes()
Schema	getSchema()
int	getSplitNum()
byte[]	getTokenBytes()
void	readFields(DataInput in)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

LlapInputSplit

public LlapInputSplit()

LlapInputSplit

public LlapInputSplit(int splitNum,
                      byte[] planBytes,
                      byte[] fragmentBytes,
                      byte[] fragmentBytesSignature,
                      org.apache.hadoop.mapred.SplitLocationInfo[] locations,
                      Schema schema,
                      String llapUser,
                      byte[] tokenBytes)

Method Detail

getSchema

public Schema getSchema()

getLength

public long getLength()
               throws IOException

Specified by:

getLength in interface org.apache.hadoop.mapred.InputSplit

Throws:

IOException

getLocations

public String[] getLocations()
                      throws IOException

Specified by:

getLocations in interface org.apache.hadoop.mapred.InputSplit

Throws:

IOException

getSplitNum

public int getSplitNum()

getPlanBytes

public byte[] getPlanBytes()

getFragmentBytes

public byte[] getFragmentBytes()

getFragmentBytesSignature

public byte[] getFragmentBytesSignature()

getTokenBytes

public byte[] getTokenBytes()

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

getLocationInfo

public org.apache.hadoop.mapred.SplitLocationInfo[] getLocationInfo()
                                                             throws IOException

Specified by:

getLocationInfo in interface org.apache.hadoop.mapred.InputSplitWithLocationInfo

Throws:

IOException

getLlapUser

public String getLlapUser()