@InterfaceAudience.Private public class DagTypeConverters extends Object
Constructor and Description |
---|
DagTypeConverters() |
public static DAGProtos.PlanLocalResourceVisibility convertToDAGPlan(org.apache.hadoop.yarn.api.records.LocalResourceVisibility visibility)
public static List<DAGProtos.PlanLocalResource> convertToDAGPlan(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> lrs)
public static org.apache.hadoop.yarn.api.records.LocalResourceVisibility convertFromDAGPlan(DAGProtos.PlanLocalResourceVisibility visibility)
public static DAGProtos.PlanEdgeDataSourceType convertToDAGPlan(EdgeProperty.DataSourceType sourceType)
public static EdgeProperty.DataSourceType convertFromDAGPlan(DAGProtos.PlanEdgeDataSourceType sourceType)
public static DAGProtos.PlanEdgeDataMovementType convertToDAGPlan(EdgeProperty.DataMovementType type)
public static EdgeProperty.DataMovementType convertFromDAGPlan(DAGProtos.PlanEdgeDataMovementType type)
public static DAGProtos.PlanEdgeSchedulingType convertToDAGPlan(EdgeProperty.SchedulingType type)
public static EdgeProperty.SchedulingType convertFromDAGPlan(DAGProtos.PlanEdgeSchedulingType type)
public static DAGProtos.PlanLocalResourceType convertToDAGPlan(org.apache.hadoop.yarn.api.records.LocalResourceType type)
public static org.apache.hadoop.yarn.api.records.LocalResourceType convertFromDAGPlan(DAGProtos.PlanLocalResourceType type)
public static VertexLocationHint convertFromDAGPlan(List<DAGProtos.PlanTaskLocationHint> locationHints)
public static String convertToDAGPlan(org.apache.hadoop.yarn.api.records.URL resource)
public static org.apache.hadoop.yarn.api.records.URL convertToYarnURL(String pathString)
public static Map<String,org.apache.hadoop.yarn.api.records.LocalResource> createLocalResourceMapFromDAGPlan(List<DAGProtos.PlanLocalResource> localResourcesList)
public static Map<String,String> createEnvironmentMapFromDAGPlan(List<DAGProtos.PlanKeyValuePair> environmentSettingList)
public static Map<String,DAGProtos.EdgePlan> createEdgePlanMapFromDAGPlan(List<DAGProtos.EdgePlan> edgeList)
public static DAGProtos.PlanEdgeProperty convertToProto(EdgeProperty prop)
public static EdgeProperty convertFromProto(DAGProtos.PlanEdgeProperty edge)
public static EdgeProperty createEdgePropertyMapFromDAGPlan(DAGProtos.EdgePlan edge)
public static org.apache.hadoop.yarn.api.records.Resource createResourceRequestFromTaskConfig(DAGProtos.PlanTaskConfiguration taskConfig)
public static Map<String,String> convertConfFromProto(DAGProtos.ConfigurationProto confProto)
public static DAGProtos.TezEntityDescriptorProto convertToDAGPlan(EntityDescriptor<?> descriptor)
public static String getHistoryTextFromProto(DAGProtos.TezEntityDescriptorProto proto)
public static DAGProtos.RootInputLeafOutputProto convertToDAGPlan(RootInputLeafOutput<? extends EntityDescriptor<?>,? extends EntityDescriptor<?>> rootIO)
public static InputDescriptor convertInputDescriptorFromDAGPlan(DAGProtos.TezEntityDescriptorProto proto)
public static OutputDescriptor convertOutputDescriptorFromDAGPlan(DAGProtos.TezEntityDescriptorProto proto)
public static NamedEntityDescriptor convertNamedDescriptorFromProto(DAGProtos.TezNamedEntityDescriptorProto proto)
public static InputInitializerDescriptor convertInputInitializerDescriptorFromDAGPlan(DAGProtos.TezEntityDescriptorProto proto)
public static OutputCommitterDescriptor convertOutputCommitterDescriptorFromDAGPlan(DAGProtos.TezEntityDescriptorProto proto)
public static VertexManagerPluginDescriptor convertVertexManagerPluginDescriptorFromDAGPlan(DAGProtos.TezEntityDescriptorProto proto)
public static EdgeManagerPluginDescriptor convertEdgeManagerPluginDescriptorFromDAGPlan(DAGProtos.TezEntityDescriptorProto proto)
public static ProcessorDescriptor convertProcessorDescriptorFromDAGPlan(DAGProtos.TezEntityDescriptorProto proto)
public static TezAppMasterStatus convertTezAppMasterStatusFromProto(DAGClientAMProtocolRPC.TezAppMasterStatusProto proto)
public static DAGClientAMProtocolRPC.TezAppMasterStatusProto convertTezAppMasterStatusToProto(TezAppMasterStatus status)
public static DAGProtos.PlanLocalResourcesProto convertFromLocalResources(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources)
public static Map<String,org.apache.hadoop.yarn.api.records.LocalResource> convertFromPlanLocalResources(DAGProtos.PlanLocalResourcesProto proto)
public static DAGProtos.PlanLocalResource convertLocalResourceToPlanLocalResource(String name, org.apache.hadoop.yarn.api.records.LocalResource lr)
public static org.apache.hadoop.yarn.api.records.LocalResource convertPlanLocalResourceToLocalResource(DAGProtos.PlanLocalResource plr)
public static TezCounters convertTezCountersFromProto(DAGProtos.TezCountersProto proto)
public static DAGProtos.TezCountersProto convertTezCountersToProto(TezCounters counters)
public static DAGProtos.StatusGetOptsProto convertStatusGetOptsToProto(StatusGetOpts statusGetOpts)
public static StatusGetOpts convertStatusGetOptsFromProto(DAGProtos.StatusGetOptsProto proto)
public static List<DAGProtos.StatusGetOptsProto> convertStatusGetOptsToProto(Set<StatusGetOpts> statusGetOpts)
public static Set<StatusGetOpts> convertStatusGetOptsFromProto(List<DAGProtos.StatusGetOptsProto> protoList)
public static com.google.protobuf.ByteString convertCredentialsToProto(org.apache.hadoop.security.Credentials credentials)
public static org.apache.hadoop.security.Credentials convertByteStringToCredentials(com.google.protobuf.ByteString byteString)
public static VertexLocationHint convertVertexLocationHintFromProto(DAGProtos.VertexLocationHintProto proto)
public static DAGProtos.VertexLocationHintProto convertVertexLocationHintToProto(VertexLocationHint vertexLocationHint)
public static UserPayload convertToTezUserPayload(@Nullable ByteBuffer payload, int version)
@Nullable public static ByteBuffer convertFromTezUserPayload(@Nullable UserPayload payload)
public static DAGProtos.VertexExecutionContextProto convertToProto(Vertex.VertexExecutionContext context)
public static Vertex.VertexExecutionContext convertFromProto(DAGProtos.VertexExecutionContextProto proto)
public static List<DAGProtos.TezNamedEntityDescriptorProto> convertNamedEntityCollectionToProto(NamedEntityDescriptor[] namedEntityDescriptors)
public static DAGProtos.TezNamedEntityDescriptorProto convertNamedEntityToProto(NamedEntityDescriptor namedEntityDescriptor)
public static DAGProtos.AMPluginDescriptorProto convertServicePluginDescriptorToProto(ServicePluginsDescriptor servicePluginsDescriptor)
public static DAGProtos.CallerContextProto convertCallerContextToProto(CallerContext callerContext)
public static CallerContext convertCallerContextFromProto(DAGProtos.CallerContextProto proto)
Copyright © 2016 Apache Software Foundation. All rights reserved.