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,
LlapDaemonInfo[] llapDaemonInfos,
Schema schema,
String llapUser,
byte[] tokenBytes,
String jwt) |
Modifier and Type | Method and Description |
---|---|
byte[] |
getFragmentBytes() |
byte[] |
getFragmentBytesSignature() |
String |
getJwt() |
long |
getLength() |
LlapDaemonInfo[] |
getLlapDaemonInfos() |
String |
getLlapUser() |
org.apache.hadoop.mapred.SplitLocationInfo[] |
getLocationInfo() |
String[] |
getLocations() |
byte[] |
getPlanBytes() |
Schema |
getSchema() |
int |
getSplitNum() |
byte[] |
getTokenBytes() |
void |
readFields(DataInput in) |
void |
setPlanBytes(byte[] planBytes) |
void |
setSchema(Schema schema) |
void |
write(DataOutput out) |
public LlapInputSplit()
public LlapInputSplit(int splitNum, byte[] planBytes, byte[] fragmentBytes, byte[] fragmentBytesSignature, org.apache.hadoop.mapred.SplitLocationInfo[] locations, LlapDaemonInfo[] llapDaemonInfos, Schema schema, String llapUser, byte[] tokenBytes, String jwt)
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 setPlanBytes(byte[] planBytes)
public void setSchema(Schema schema)
public String getJwt()
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()
public LlapDaemonInfo[] getLlapDaemonInfos()
Copyright © 2023 The Apache Software Foundation. All rights reserved.