com.continuent.tungsten.replicator.extractor.mysql
Class WriteRowsLogEvent

java.lang.Object
  com.continuent.tungsten.replicator.extractor.mysql.LogEvent
      com.continuent.tungsten.replicator.extractor.mysql.RowsLogEvent
          com.continuent.tungsten.replicator.extractor.mysql.WriteRowsLogEvent

public class WriteRowsLogEvent
extends RowsLogEvent

Version:

1.0

Author:

Seppo Jaakola, Stephane Giron

Field Summary

Fields inherited from class com.continuent.tungsten.replicator.extractor.mysql.RowsLogEvent

bufferSize, columnsNumber, descriptionEvent, packedRowsBuffer, useBytesForString, usedColumns, usedColumnsForUpdate

Fields inherited from class com.continuent.tungsten.replicator.extractor.mysql.LogEvent

execTime, flags, logPos, serverId, startPosition, threadSpecificEvent, type, when

Constructor Summary

WriteRowsLogEvent(byte[] buffer, int eventLength, FormatDescriptionLogEvent descriptionEvent, boolean useBytesForString, java.lang.String currentPosition)

Method Summary

void	processExtractedEvent(RowChangeData rowChanges, TableMapLogEvent map)

Methods inherited from class com.continuent.tungsten.replicator.extractor.mysql.RowsLogEvent

extractValue, getEventSize, getForeignKeyChecksFlag, getTableId, getUniqueChecksFlag, processExtractedEventRow, processString

Methods inherited from class com.continuent.tungsten.replicator.extractor.mysql.LogEvent

doChecksum, extractDecimal, getDecimalBinarySize, getExecTime, getNextEventPosition, getType, getWhen, hexdump, hexdump, hexdump, readLogEvent

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteRowsLogEvent

public WriteRowsLogEvent(byte[] buffer,
                         int eventLength,
                         FormatDescriptionLogEvent descriptionEvent,
                         boolean useBytesForString,
                         java.lang.String currentPosition)
                  throws ReplicatorException

Throws:

ReplicatorException

Method Detail

processExtractedEvent

public void processExtractedEvent(RowChangeData rowChanges,
                                  TableMapLogEvent map)
                           throws ReplicatorException

Specified by:

processExtractedEvent in class RowsLogEvent

Throws:

ReplicatorException

See Also:

RowsLogEvent.processExtractedEvent(com.continuent.tungsten.replicator.dbms.RowChangeData, com.continuent.tungsten.replicator.extractor.mysql.TableMapLogEvent)