Package com.illumon.iris.sbetransport.server.messages

Class ColumnDataMessageEncoder

java.lang.Object

com.illumon.iris.sbetransport.server.messages.MessageEncoder

com.illumon.iris.sbetransport.server.messages.ColumnDataMessageEncoder

Direct Known Subclasses:

BooleanColumnDataMessageEncoder, ByteColumnDataMessageEncoder, CharColumnDataMessageEncoder, DateTimeColumnDataMessageEncoder, DecimalColumnDataMessageEncoder, DoubleColumnDataMessageEncoder, FloatColumnDataMessageEncoder, IntColumnDataMessageEncoder, LongColumnDataMessageEncoder, PrimitiveArrayColumnDataMessageEncoder, ShortColumnDataMessageEncoder, StringArrayColumnDataMessageEncoder, StringColumnDataMessageEncoder, StringSetColumnDataMessageEncoder

public abstract class ColumnDataMessageEncoder
extends MessageEncoder

Base class for encoding column data updates. Since any number of rows may be added/modified in a single table update, we must provide for splitting into any number of fixed-size SBE messages. This class provides the splitting logic, and delegates the job of encoding each "chunk" of column data to the subsclass.

Field Summary

Fields inherited from class com.illumon.iris.sbetransport.server.messages.MessageEncoder

freeBufferSupplier, log, messageConsumer, messageHeaderEncoder

Method Summary

Modifier and Type	Method	Description
void	send(int subscriptionId, int columnId, ColumnSource columnSource, Index index, boolean isModified)

Methods inherited from class java.lang.Object

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

Method Details

send

public void send(int subscriptionId,
 int columnId,
 ColumnSource columnSource,
 Index index,
 boolean isModified)
          throws Exception

Throws:

Exception