org.apache.hadoop.hive.llap.tez

Class Converters

java.lang.Object

org.apache.hadoop.hive.llap.tez.Converters

public class Converters
extends Object

Constructor Summary

Constructors

Constructor and Description
Converters()

Method Summary

Modifier and Type	Method and Description
static LlapDaemonProtocolProtos.IOSpecProto	convertOutputSpecToProto(org.apache.tez.runtime.api.impl.OutputSpec outputSpec)
static LlapDaemonProtocolProtos.SignableVertexSpec	convertTaskSpecToProto(org.apache.tez.runtime.api.impl.TaskSpec taskSpec, int appAttemptId, String tokenIdentifier, Integer signatureKeyId, String user)
static org.apache.tez.dag.records.TezTaskAttemptID	createTaskAttemptId(LlapDaemonProtocolProtos.VertexIdentifier vertexId, int fragmentNum, int attemptNum)
static LlapDaemonProtocolProtos.VertexIdentifier	createVertexIdentifier(org.apache.tez.dag.records.TezTaskAttemptID taId, int appAttemptId)
static LlapDaemonProtocolProtos.SourceStateProto	fromVertexState(org.apache.tez.dag.api.event.VertexState state)
static org.apache.tez.runtime.api.impl.TaskSpec	getTaskSpecfromProto(LlapDaemonProtocolProtos.SignableVertexSpec vectorProto, int fragmentNum, int attemptNum, org.apache.tez.dag.records.TezTaskAttemptID attemptId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Converters

public Converters()

Method Detail

getTaskSpecfromProto

public static org.apache.tez.runtime.api.impl.TaskSpec getTaskSpecfromProto(LlapDaemonProtocolProtos.SignableVertexSpec vectorProto,
                                                                            int fragmentNum,
                                                                            int attemptNum,
                                                                            org.apache.tez.dag.records.TezTaskAttemptID attemptId)

createTaskAttemptId

public static org.apache.tez.dag.records.TezTaskAttemptID createTaskAttemptId(LlapDaemonProtocolProtos.VertexIdentifier vertexId,
                                                                              int fragmentNum,
                                                                              int attemptNum)

createVertexIdentifier

public static LlapDaemonProtocolProtos.VertexIdentifier createVertexIdentifier(org.apache.tez.dag.records.TezTaskAttemptID taId,
                                                                               int appAttemptId)

convertTaskSpecToProto

public static LlapDaemonProtocolProtos.SignableVertexSpec convertTaskSpecToProto(org.apache.tez.runtime.api.impl.TaskSpec taskSpec,
                                                                                 int appAttemptId,
                                                                                 String tokenIdentifier,
                                                                                 Integer signatureKeyId,
                                                                                 String user)

convertOutputSpecToProto

public static LlapDaemonProtocolProtos.IOSpecProto convertOutputSpecToProto(org.apache.tez.runtime.api.impl.OutputSpec outputSpec)

fromVertexState

public static LlapDaemonProtocolProtos.SourceStateProto fromVertexState(org.apache.tez.dag.api.event.VertexState state)