public class Converters extends Object
Constructor and Description |
---|
Converters() |
Modifier and Type | Method and Description |
---|---|
static LlapDaemonProtocolProtos.SignableVertexSpec.Builder |
constructSignableVertexSpec(org.apache.tez.runtime.api.impl.TaskSpec taskSpec,
LlapDaemonProtocolProtos.QueryIdentifierProto queryIdentifierProto,
String tokenIdentifier,
String user,
String hiveQueryIdString) |
static LlapDaemonProtocolProtos.IOSpecProto |
convertOutputSpecToProto(org.apache.tez.runtime.api.impl.OutputSpec outputSpec) |
static org.apache.tez.dag.records.TezTaskAttemptID |
createTaskAttemptId(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 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) |
public static org.apache.tez.runtime.api.impl.TaskSpec getTaskSpecfromProto(LlapDaemonProtocolProtos.SignableVertexSpec vectorProto, int fragmentNum, int attemptNum, org.apache.tez.dag.records.TezTaskAttemptID attemptId)
public static org.apache.tez.dag.records.TezTaskAttemptID createTaskAttemptId(LlapDaemonProtocolProtos.QueryIdentifierProto queryIdProto, int vertexIndex, int fragmentNum, int attemptNum)
public static org.apache.tez.dag.records.TezTaskAttemptID createTaskAttemptId(org.apache.tez.runtime.api.TaskContext ctx)
public static LlapDaemonProtocolProtos.SignableVertexSpec.Builder constructSignableVertexSpec(org.apache.tez.runtime.api.impl.TaskSpec taskSpec, LlapDaemonProtocolProtos.QueryIdentifierProto queryIdentifierProto, String tokenIdentifier, String user, String hiveQueryIdString)
public static LlapDaemonProtocolProtos.IOSpecProto convertOutputSpecToProto(org.apache.tez.runtime.api.impl.OutputSpec outputSpec)
public static LlapDaemonProtocolProtos.SourceStateProto fromVertexState(org.apache.tez.dag.api.event.VertexState state)
Copyright © 2022 The Apache Software Foundation. All rights reserved.