public class SubmitWorkInfo extends Object implements org.apache.hadoop.io.Writable
Constructor and Description |
---|
SubmitWorkInfo() |
SubmitWorkInfo(org.apache.hadoop.yarn.api.records.ApplicationId fakeAppId,
long creationTime,
int vertexParallelism,
byte[] vertexSpec,
byte[] vertexSpecSignature) |
Modifier and Type | Method and Description |
---|---|
static SubmitWorkInfo |
fromBytes(byte[] submitWorkInfoBytes) |
long |
getCreationTime() |
org.apache.hadoop.yarn.api.records.ApplicationId |
getFakeAppId() |
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> |
getToken() |
String |
getTokenIdentifier() |
byte[] |
getVertexBinary() |
int |
getVertexParallelism() |
byte[] |
getVertexSignature() |
void |
readFields(DataInput in) |
static byte[] |
toBytes(SubmitWorkInfo submitWorkInfo) |
void |
write(DataOutput out) |
public SubmitWorkInfo(org.apache.hadoop.yarn.api.records.ApplicationId fakeAppId, long creationTime, int vertexParallelism, byte[] vertexSpec, byte[] vertexSpecSignature)
public SubmitWorkInfo()
public org.apache.hadoop.yarn.api.records.ApplicationId getFakeAppId()
public String getTokenIdentifier()
public org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> getToken()
public long getCreationTime()
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 static byte[] toBytes(SubmitWorkInfo submitWorkInfo) throws IOException
IOException
public static SubmitWorkInfo fromBytes(byte[] submitWorkInfoBytes) throws IOException
IOException
public byte[] getVertexBinary()
public byte[] getVertexSignature()
public int getVertexParallelism()
Copyright © 2021 The Apache Software Foundation. All rights reserved.