io.deephaven.sbe.standalone.client.TableClient.Receiver

All Implemented Interfaces:: Runnable

Enclosing class:: TableClient

protected class TableClient.Receiver
extends Object
implements Runnable

Field Summary

Fields
Modifier and Type	Field	Description
`protected BeginTableUpdateDecoder`	`beginTableUpdateDecoder`
`protected BooleanArrayColumnDataDecoder`	`booleanArrayColumnDataDecoder`
`protected BooleanColumnDataDecoder`	`booleanColumnDataDecoder`
`protected ByteArrayColumnDataDecoder`	`byteArrayColumnDataDecoder`
`protected ByteColumnDataDecoder`	`byteColumnDataDecoder`
`protected CharArrayColumnDataDecoder`	`charArrayColumnDataDecoder`
`protected CharColumnDataDecoder`	`charColumnDataDecoder`
`protected ConnectionResponseDecoder`	`connectionResponseDecoder`
`protected DateTimeColumnDataDecoder`	`dateTimeColumnDataDecoder`
`protected DecimalColumnDataDecoder`	`decimalColumnDataDecoder`
`protected DoubleArrayColumnDataDecoder`	`doubleArrayColumnDataDecoder`
`protected DoubleColumnDataDecoder`	`doubleColumnDataDecoder`
`protected EndTableUpdateDecoder`	`endTableUpdateDecoder`
`protected FloatArrayColumnDataDecoder`	`floatArrayColumnDataDecoder`
`protected FloatColumnDataDecoder`	`floatColumnDataDecoder`
`protected static int`	`INIT_RECV_MSG_BUFFER_SIZE`
`protected IntArrayColumnDataDecoder`	`intArrayColumnDataDecoder`
`protected IntColumnDataDecoder`	`intColumnDataDecoder`
`protected LongArrayColumnDataDecoder`	`longArrayColumnDataDecoder`
`protected LongColumnDataDecoder`	`longColumnDataDecoder`
`protected MessageHandler`	`messageHandler`
`protected MessageHeaderDecoder`	`messageHeaderDecoder`
`protected RowsRemovedDecoder`	`rowsRemovedDecoder`
`protected ShortArrayColumnDataDecoder`	`shortArrayColumnDataDecoder`
`protected ShortColumnDataDecoder`	`shortColumnDataDecoder`
`protected boolean`	`stop`
`protected StringArrayColumnDataDecoder`	`stringArrayColumnDataDecoder`
`protected StringColumnDataDecoder`	`stringColumnDataDecoder`
`protected StringSetColumnDataDecoder`	`stringSetColumnDataDecoder`
`protected TableSubscriptionErrorDecoder`	`subscriptionErrorDecoder`
`protected TableSubscribeResponseDecoder`	`subscriptionResponseDecoder`
`protected TableUnsubscribeResponseDecoder`	`unsubscribeResponseDecoder`

Method Summary

Modifier and Type Method Description

protected void blockingRead(ByteBuffer dst)

void run()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- INIT_RECV_MSG_BUFFER_SIZE
  
  protected static final int INIT_RECV_MSG_BUFFER_SIZE
  
  See Also:
  
  Constant Field Values
- connectionResponseDecoder
  
  protected final ConnectionResponseDecoder connectionResponseDecoder
- messageHeaderDecoder
  
  protected final MessageHeaderDecoder messageHeaderDecoder
- subscriptionResponseDecoder
  
  protected final TableSubscribeResponseDecoder subscriptionResponseDecoder
- unsubscribeResponseDecoder
  
  protected final TableUnsubscribeResponseDecoder unsubscribeResponseDecoder
- subscriptionErrorDecoder
  
  protected final TableSubscriptionErrorDecoder subscriptionErrorDecoder
- beginTableUpdateDecoder
  
  protected final BeginTableUpdateDecoder beginTableUpdateDecoder
- endTableUpdateDecoder
  
  protected final EndTableUpdateDecoder endTableUpdateDecoder
- byteColumnDataDecoder
  
  protected final ByteColumnDataDecoder byteColumnDataDecoder
- booleanColumnDataDecoder
  
  protected final BooleanColumnDataDecoder booleanColumnDataDecoder
- intColumnDataDecoder
  
  protected final IntColumnDataDecoder intColumnDataDecoder
- longColumnDataDecoder
  
  protected final LongColumnDataDecoder longColumnDataDecoder
- stringColumnDataDecoder
  
  protected final StringColumnDataDecoder stringColumnDataDecoder
- decimalColumnDataDecoder
  
  protected final DecimalColumnDataDecoder decimalColumnDataDecoder
- doubleColumnDataDecoder
  
  protected final DoubleColumnDataDecoder doubleColumnDataDecoder
- floatColumnDataDecoder
  
  protected final FloatColumnDataDecoder floatColumnDataDecoder
- shortColumnDataDecoder
  
  protected final ShortColumnDataDecoder shortColumnDataDecoder
- charColumnDataDecoder
  
  protected final CharColumnDataDecoder charColumnDataDecoder
- byteArrayColumnDataDecoder
  
  protected final ByteArrayColumnDataDecoder byteArrayColumnDataDecoder
- booleanArrayColumnDataDecoder
  
  protected final BooleanArrayColumnDataDecoder booleanArrayColumnDataDecoder
- charArrayColumnDataDecoder
  
  protected final CharArrayColumnDataDecoder charArrayColumnDataDecoder
- doubleArrayColumnDataDecoder
  
  protected final DoubleArrayColumnDataDecoder doubleArrayColumnDataDecoder
- floatArrayColumnDataDecoder
  
  protected final FloatArrayColumnDataDecoder floatArrayColumnDataDecoder
- intArrayColumnDataDecoder
  
  protected final IntArrayColumnDataDecoder intArrayColumnDataDecoder
- longArrayColumnDataDecoder
  
  protected final LongArrayColumnDataDecoder longArrayColumnDataDecoder
- shortArrayColumnDataDecoder
  
  protected final ShortArrayColumnDataDecoder shortArrayColumnDataDecoder
- stringArrayColumnDataDecoder
  
  protected final StringArrayColumnDataDecoder stringArrayColumnDataDecoder
- dateTimeColumnDataDecoder
  
  protected final DateTimeColumnDataDecoder dateTimeColumnDataDecoder
- stringSetColumnDataDecoder
  
  protected final StringSetColumnDataDecoder stringSetColumnDataDecoder
- rowsRemovedDecoder
  
  protected final RowsRemovedDecoder rowsRemovedDecoder
- messageHandler
  
  protected final MessageHandler messageHandler
- stop
  
  protected volatile boolean stop
Method Details
- blockingRead
  
  protected void blockingRead(ByteBuffer dst) throws IOException
  
  Throws:
  
  IOException
- run
  
  public void run()
  
  Specified by:
  
  run in interface Runnable

Modifier and Type	Method	Description
`protected void`	`blockingRead(ByteBuffer dst)`
`void`	`run()`

Class TableClient.Receiver

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

Method Details