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 org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec.Builder	constructSignableVertexSpec(org.apache.tez.runtime.api.impl.TaskSpec taskSpec, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryIdentifierProto queryIdentifierProto, String tokenIdentifier, String user, String hiveQueryIdString)
static org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.IOSpecProto	convertOutputSpecToProto(org.apache.tez.runtime.api.impl.OutputSpec outputSpec)
static org.apache.tez.dag.records.TezTaskAttemptID	createTaskAttemptId(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryIdentifierProto queryIdProto, int vertexIndex, int fragmentNum, int attemptNum)
static org.apache.tez.dag.records.TezTaskAttemptID	createTaskAttemptId(org.apache.tez.runtime.api.TaskContext ctx)
static org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateProto	fromVertexState(org.apache.tez.dag.api.event.VertexState state)
static org.apache.tez.runtime.api.impl.TaskSpec	getTaskSpecfromProto(org.apache.hadoop.hive.llap.daemon.rpc.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(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec vectorProto,
                                                                            int fragmentNum,
                                                                            int attemptNum,
                                                                            org.apache.tez.dag.records.TezTaskAttemptID attemptId)

createTaskAttemptId

public static org.apache.tez.dag.records.TezTaskAttemptID createTaskAttemptId(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryIdentifierProto queryIdProto,
                                                                              int vertexIndex,
                                                                              int fragmentNum,
                                                                              int attemptNum)

createTaskAttemptId

public static org.apache.tez.dag.records.TezTaskAttemptID createTaskAttemptId(org.apache.tez.runtime.api.TaskContext ctx)

constructSignableVertexSpec

public static org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec.Builder constructSignableVertexSpec(org.apache.tez.runtime.api.impl.TaskSpec taskSpec,
                                                                                                                                     org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryIdentifierProto queryIdentifierProto,
                                                                                                                                     String tokenIdentifier,
                                                                                                                                     String user,
                                                                                                                                     String hiveQueryIdString)

convertOutputSpecToProto

public static org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.IOSpecProto convertOutputSpecToProto(org.apache.tez.runtime.api.impl.OutputSpec outputSpec)

fromVertexState

public static org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateProto fromVertexState(org.apache.tez.dag.api.event.VertexState state)