public class LlapInputSplit extends Object implements org.apache.hadoop.mapred.InputSplitWithLocationInfo
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) |
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) |
public Schema getSchema()
public long getLength() throws IOException
getLength
in interface org.apache.hadoop.mapred.InputSplit
IOException
public String[] getLocations() throws IOException
getLocations
in interface org.apache.hadoop.mapred.InputSplit
IOException
public int getSplitNum()
public byte[] getPlanBytes()
public byte[] getFragmentBytes()
public byte[] getFragmentBytesSignature()
public byte[] getTokenBytes()
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public org.apache.hadoop.mapred.SplitLocationInfo[] getLocationInfo() throws IOException
getLocationInfo
in interface org.apache.hadoop.mapred.InputSplitWithLocationInfo
IOException
public String getLlapUser()
Copyright © 2021 The Apache Software Foundation. All rights reserved.