alluxio.util.proto

Class ProtoUtils

java.lang.Object

alluxio.util.proto.ProtoUtils

public final class ProtoUtils
extends Object

Protobuf related utils.

Method Summary

Modifier and Type	Method and Description
static AccessControlList	fromProto(Acl.AccessControlList acl)
static AclAction	fromProto(Acl.AclAction action)
static AclActions	fromProto(Acl.AclActions actions)
static AclEntry	fromProto(Acl.AclEntry pEntry)
static AclEntryType	fromProto(Acl.AclEntryType pAclEntryType)
static SetAclAction	fromProto(File.PSetAclAction pSetAclAction) Converts proto type to wire type.
static io.grpc.Status	fromProto(Status.PStatus status) Creates a Status from a protocol buffer type status.
static List<Acl.NamedAclActions>	getNamedGroupsProto(ExtendedACLEntries entries)
static List<Acl.NamedAclActions>	getNamedUsersProto(ExtendedACLEntries entries)
static boolean	isTruncatedMessageException(IOException e) Checks whether the exception is an InvalidProtocolBufferException thrown because of a truncated message.
static int	readRawVarint32(InputStream input) A wrapper of CodedInputStream.readRawVarint32(InputStream).
static int	readRawVarint32(int firstByte, InputStream input) A wrapper of CodedInputStream.readRawVarint32(InputStream).
static Job.TaskInfo.Builder	setResult(Job.TaskInfo.Builder builder, byte[] bytes) A wrapper of Job.TaskInfo.Builder.setResult(com.google.protobuf.ByteString) to take byte[] as input.
static Acl.AccessControlList	toProto(AccessControlList acl)
static Acl.AclAction	toProto(AclAction aclAction)
static Acl.AclActions	toProto(AclActions actions)
static Acl.AclEntry	toProto(AclEntry aclEntry)
static Acl.AclEntryType	toProto(AclEntryType entryType)
static File.PSetAclAction	toProto(SetAclAction aclAction) Converts wire type to proto type.
static Status.PStatus	toProto(io.grpc.Status status) Converts an internal exception status to a protocol buffer type status.

Methods inherited from class java.lang.Object

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

Method Detail

readRawVarint32

public static int readRawVarint32(int firstByte,
                                  InputStream input)
                           throws IOException

A wrapper of CodedInputStream.readRawVarint32(InputStream).

Parameters:

firstByte - first byte in the input stream

input - input stream

Returns:

an int value read from the input stream

Throws:

IOException

readRawVarint32

public static int readRawVarint32(InputStream input)
                           throws IOException

A wrapper of CodedInputStream.readRawVarint32(InputStream).

Parameters:

input - input stream

Returns:

an int value read from the input stream

Throws:

IOException

setResult

public static Job.TaskInfo.Builder setResult(Job.TaskInfo.Builder builder,
                                             byte[] bytes)

A wrapper of Job.TaskInfo.Builder.setResult(com.google.protobuf.ByteString) to take byte[] as input.

Parameters:

builder - the builder to update

bytes - results bytes to set

Returns:

updated builder

isTruncatedMessageException

public static boolean isTruncatedMessageException(IOException e)

Checks whether the exception is an InvalidProtocolBufferException thrown because of a truncated message.

Parameters:

e - the exception

Returns:

whether the exception is an InvalidProtocolBufferException thrown because of a truncated message.

toProto

public static Acl.AccessControlList toProto(AccessControlList acl)

Parameters:

acl - AccessControlList

Returns:

protobuf representation

toProto

public static Acl.AclActions toProto(AclActions actions)

Parameters:

actions - the AclActions

Returns:

the protobuf representation of AclActions

toProto

public static Acl.AclAction toProto(AclAction aclAction)

Parameters:

aclAction - the acl action

Returns:

the protobuf representation of action

toProto

public static Acl.AclEntry toProto(AclEntry aclEntry)

Parameters:

aclEntry - the acl entry

Returns:

the proto representation of instance

toProto

public static File.PSetAclAction toProto(SetAclAction aclAction)

Converts wire type to proto type.

Parameters:

aclAction - the acl action to convert

Returns:

File.PSetAclAction equivalent

toProto

public static Status.PStatus toProto(io.grpc.Status status)

Converts an internal exception status to a protocol buffer type status.

Parameters:

status - the status to convert

Returns:

the protocol buffer type status

toProto

public static Acl.AclEntryType toProto(AclEntryType entryType)

Parameters:

entryType - the acl entry type

Returns:

the proto representation of enum

fromProto

public static AccessControlList fromProto(Acl.AccessControlList acl)

Parameters:

acl - the protobuf representation

Returns:

AccessControlList

fromProto

public static AclActions fromProto(Acl.AclActions actions)

Parameters:

actions - the protobuf representation of AclActions

Returns:

the AclActions decoded from the protobuf representation

fromProto

public static AclAction fromProto(Acl.AclAction action)

Parameters:

action - the protobuf representation of AclAction

Returns:

the AclAction decoded from the protobuf representation

fromProto

public static AclEntry fromProto(Acl.AclEntry pEntry)

Parameters:

pEntry - the proto representation

Returns:

the AclEntry instance created from the proto representation

fromProto

public static AclEntryType fromProto(Acl.AclEntryType pAclEntryType)

Parameters:

pAclEntryType - the proto representation

Returns:

the AclEntryType created from the proto representation

fromProto

public static SetAclAction fromProto(File.PSetAclAction pSetAclAction)

Converts proto type to wire type.

Parameters:

pSetAclAction - File.PSetAclAction

Returns:

SetAclAction equivalent

fromProto

public static io.grpc.Status fromProto(Status.PStatus status)

Creates a Status from a protocol buffer type status.

Parameters:

status - the protocol buffer type status

Returns:

the corresponding Status

getNamedUsersProto

public static List<Acl.NamedAclActions> getNamedUsersProto(ExtendedACLEntries entries)

Parameters:

entries - the extended acl entries

Returns:

a list of the proto representation of the named users actions

getNamedGroupsProto

public static List<Acl.NamedAclActions> getNamedGroupsProto(ExtendedACLEntries entries)

Parameters:

entries - the extended acl entries

Returns:

a list of the proto representation of the named group actions