Package org.apache.hadoop.hdfs.server.namenode

Class FSEditLogOp

java.lang.Object

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp

@Private
@Unstable
public abstract class FSEditLogOp
extends Object

Helper classes for reading the ops from an InputStream. All ops derive from FSEditLogOp and are only instantiated from Reader#readOp()

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FSEditLogOp.OpInstanceCache
static class	FSEditLogOp.Reader	Class for reading editlog ops from a stream
static class	FSEditLogOp.Writer	Class for writing editlog ops

Field Summary

Fields

Modifier and Type	Field	Description
final FSEditLogOpCodes	opCode

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FSEditLogOp(FSEditLogOpCodes opCode)	Constructor for an EditLog Op.

Method Summary

Modifier and Type	Method	Description
static org.apache.hadoop.hdfs.protocol.Block	blockFromXml(XMLUtils.Stanza st)
static void	blockToXml(ContentHandler contentHandler, org.apache.hadoop.hdfs.protocol.Block block)
void	decodeXml(XMLUtils.Stanza st)
static org.apache.hadoop.security.token.delegation.DelegationKey	delegationKeyFromXml(XMLUtils.Stanza st)
static void	delegationKeyToXml(ContentHandler contentHandler, org.apache.hadoop.security.token.delegation.DelegationKey key)
static org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier	delegationTokenFromXml(XMLUtils.Stanza st)
static void	delegationTokenToXml(ContentHandler contentHandler, org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier token)
static org.apache.hadoop.fs.permission.FsPermission	fsPermissionFromXml(XMLUtils.Stanza st)
static void	fsPermissionToXml(ContentHandler contentHandler, org.apache.hadoop.fs.permission.FsPermission mode)
int	getCallId()	this has to be called after calling hasRpcIds()
byte[]	getClientId()	this has to be called after calling hasRpcIds()
long	getTransactionId()
String	getTransactionIdStr()
boolean	hasRpcIds()
boolean	hasTransactionId()
void	outputToXml(ContentHandler contentHandler)
static org.apache.hadoop.fs.permission.PermissionStatus	permissionStatusFromXml(XMLUtils.Stanza st)
static void	permissionStatusToXml(ContentHandler contentHandler, org.apache.hadoop.fs.permission.PermissionStatus perm)
void	setRpcCallId(int callId)
void	setRpcClientId(byte[] clientId)
void	setTransactionId(long txid)
protected abstract void	toXml(ContentHandler contentHandler)
abstract void	writeFields(DataOutputStream out)
void	writeFields(DataOutputStream out, int logVersion)

Methods inherited from class java.lang.Object

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

Field Details

opCode

public final FSEditLogOpCodes opCode

Constructor Details

FSEditLogOp

@VisibleForTesting
protected FSEditLogOp(FSEditLogOpCodes opCode)

Constructor for an EditLog Op. EditLog ops cannot be constructed directly, but only through Reader#readOp.

Method Details

getTransactionId

public long getTransactionId()

getTransactionIdStr

public String getTransactionIdStr()

hasTransactionId

public boolean hasTransactionId()

setTransactionId

public void setTransactionId(long txid)

hasRpcIds

public boolean hasRpcIds()

getClientId

public byte[] getClientId()

this has to be called after calling hasRpcIds()

setRpcClientId

public void setRpcClientId(byte[] clientId)

getCallId

public int getCallId()

this has to be called after calling hasRpcIds()

setRpcCallId

public void setRpcCallId(int callId)

writeFields

public abstract void writeFields(DataOutputStream out)
                          throws IOException

Throws:

IOException

writeFields

public void writeFields(DataOutputStream out,
 int logVersion)
                 throws IOException

Throws:

IOException

outputToXml

public void outputToXml(ContentHandler contentHandler)
                 throws SAXException

Throws:

SAXException

toXml

protected abstract void toXml(ContentHandler contentHandler)
                       throws SAXException

Throws:

SAXException

decodeXml

public void decodeXml(XMLUtils.Stanza st)
               throws XMLUtils.InvalidXmlException

Throws:

XMLUtils.InvalidXmlException

blockToXml

public static void blockToXml(ContentHandler contentHandler,
 org.apache.hadoop.hdfs.protocol.Block block)
                       throws SAXException

Throws:

SAXException

blockFromXml

public static org.apache.hadoop.hdfs.protocol.Block blockFromXml(XMLUtils.Stanza st)
                                                          throws XMLUtils.InvalidXmlException

Throws:

XMLUtils.InvalidXmlException

delegationTokenToXml

public static void delegationTokenToXml(ContentHandler contentHandler,
 org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier token)
                                 throws SAXException

Throws:

SAXException

delegationTokenFromXml

public static org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier delegationTokenFromXml(XMLUtils.Stanza st)
                                                                                                         throws XMLUtils.InvalidXmlException

Throws:

XMLUtils.InvalidXmlException

delegationKeyToXml

public static void delegationKeyToXml(ContentHandler contentHandler,
 org.apache.hadoop.security.token.delegation.DelegationKey key)
                               throws SAXException

Throws:

SAXException

delegationKeyFromXml

public static org.apache.hadoop.security.token.delegation.DelegationKey delegationKeyFromXml(XMLUtils.Stanza st)
                                                                                      throws XMLUtils.InvalidXmlException

Throws:

XMLUtils.InvalidXmlException

permissionStatusToXml

public static void permissionStatusToXml(ContentHandler contentHandler,
 org.apache.hadoop.fs.permission.PermissionStatus perm)
                                  throws SAXException

Throws:

SAXException

permissionStatusFromXml

public static org.apache.hadoop.fs.permission.PermissionStatus permissionStatusFromXml(XMLUtils.Stanza st)
                                                                                throws XMLUtils.InvalidXmlException

Throws:

XMLUtils.InvalidXmlException

fsPermissionToXml

public static void fsPermissionToXml(ContentHandler contentHandler,
 org.apache.hadoop.fs.permission.FsPermission mode)
                              throws SAXException

Throws:

SAXException

fsPermissionFromXml

public static org.apache.hadoop.fs.permission.FsPermission fsPermissionFromXml(XMLUtils.Stanza st)
                                                                        throws XMLUtils.InvalidXmlException

Throws:

XMLUtils.InvalidXmlException