public final class KahaRewrittenDataFileCommand extends org.apache.activemq.protobuf.BaseMessage<T> implements JournalCommand<KahaRewrittenDataFileCommand>
Constructor and Description |
---|
KahaRewrittenDataFileCommand() |
addAll, assertInitialized, checktInitialized, computeGroupSize, computeMessageSize, isInitialized, load, loadAndClear, mergeFramed, mergeFramed, mergeFramed, mergeFramed, mergeUnframed, mergeUnframed, mergeUnframed, prefix, readGroup, readRawByte, readRawVarint32, serializedSizeFramed, toFramedBuffer, toFramedByteArray, toUnframedBuffer, toUnframedByteArray, writeFramed, writeFramed, writeGroup, writeMessage, writeUnframed
finalize, getClass, notify, notifyAll, wait, wait, wait
assertInitialized, mergeFramed, mergeFramed, mergeFramed, mergeFramed, mergeUnframed, mergeUnframed, mergeUnframed, serializedSizeFramed, toFramedBuffer, toFramedByteArray, toUnframedBuffer, toUnframedByteArray, writeFramed, writeFramed, writeUnframed
public KahaRewrittenDataFileCommand()
public ArrayList<String> missingFields()
missingFields
in class org.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
public void clear()
clear
in interface org.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
clear
in class org.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
public KahaRewrittenDataFileCommand clone()
clone
in interface org.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
clone
in class org.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
public KahaRewrittenDataFileCommand mergeFrom(KahaRewrittenDataFileCommand other)
mergeFrom
in interface org.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
mergeFrom
in class org.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
public int serializedSizeUnframed()
serializedSizeUnframed
in interface org.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
public KahaRewrittenDataFileCommand mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) throws IOException
mergeUnframed
in interface org.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
IOException
public void writeUnframed(org.apache.activemq.protobuf.CodedOutputStream output) throws IOException
writeUnframed
in interface org.apache.activemq.protobuf.Message<KahaRewrittenDataFileCommand>
writeUnframed
in class org.apache.activemq.protobuf.BaseMessage<KahaRewrittenDataFileCommand>
IOException
public static KahaRewrittenDataFileCommand parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public static KahaRewrittenDataFileCommand parseUnframed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaRewrittenDataFileCommand parseUnframed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaRewrittenDataFileCommand parseUnframed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public static KahaRewrittenDataFileCommand parseFramed(org.apache.activemq.protobuf.CodedInputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public static KahaRewrittenDataFileCommand parseFramed(org.apache.activemq.protobuf.Buffer data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaRewrittenDataFileCommand parseFramed(byte[] data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
org.apache.activemq.protobuf.InvalidProtocolBufferException
public static KahaRewrittenDataFileCommand parseFramed(InputStream data) throws org.apache.activemq.protobuf.InvalidProtocolBufferException, IOException
org.apache.activemq.protobuf.InvalidProtocolBufferException
IOException
public StringBuilder toString(StringBuilder sb, String prefix)
public void visit(Visitor visitor) throws IOException
visit
in interface JournalCommand<KahaRewrittenDataFileCommand>
IOException
public KahaEntryType type()
type
in interface JournalCommand<KahaRewrittenDataFileCommand>
public boolean equals(KahaRewrittenDataFileCommand obj)
public boolean hasSourceDataFileId()
public int getSourceDataFileId()
public T setSourceDataFileId(int sourceDataFileId)
public void clearSourceDataFileId()
public boolean hasRewriteType()
public int getRewriteType()
public T setRewriteType(int rewriteType)
public void clearRewriteType()
public boolean hasSkipIfSourceExists()
public boolean getSkipIfSourceExists()
public T setSkipIfSourceExists(boolean skipIfSourceExists)
public void clearSkipIfSourceExists()
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.