java.lang.Object

com.illumon.util.referencecounting.ReferenceCounted

com.illumon.iris.db.v2.locations.protocol.TableDataRequestImpl

All Implemented Interfaces:: com.fishlib.base.log.LogOutputAppendable, TableDataRequest, Serializable

public class TableDataRequestImpl
extends ReferenceCounted
implements com.fishlib.base.log.LogOutputAppendable, TableDataRequest

Re-usable request class - tracks status and responses for an outstanding request.

See Also:: Serialized Form

Method Summary

Modifier and Type	Method	Description
`com.fishlib.base.log.LogOutput`	`append(com.fishlib.base.log.LogOutput logOutput)`
`TableDataRequest`	`awaitResponse()`
`TableDataRequest`	`cancel()`
`TableDataRequest`	`dispatch()`
`void`	`done()`
`boolean`	`getColumnExistanceResult()`
`int`	`getColumnFileDataLengthResult()`
`long`	`getColumnFileSizeResult()`
`boolean`	`getColumnHasSymbolTableResult()`
`boolean`	`getColumnIsLittleEndianResult()`
`long`	`getDeadlineMillis()`
`RequestResultHandler`	`getHandler()`
`long`	`getKey()`
`long`	`getTableLocationProviderStamp()`
`TableDataProtocol.RequestMessageType`	`getType()`
`TableDataRequest`	`initColumnFileDataRequest(TableKey tableKey, TableLocationKey locationKey, CharSequence columnName, ColumnFileType columnFileType, ByteBuffer buffer, long position)`
`TableDataRequest`	`initColumnFileSizeRequest(TableKey tableKey, TableLocationKey locationKey, CharSequence columnName, ColumnFileType columnFileType, long requiredSize)`
`TableDataRequest`	`initColumnLocationExistenceRequest(TableKey tableKey, TableLocationKey locationKey, CharSequence columnName)`
`TableDataRequest`	`initTableLocationRefreshRequest(boolean subscribe, TableKey tableKey, TableLocationKey locationKey)`
`TableDataRequest`	`initTableLocationsRequest(boolean subscribe, TableKey tableKey)`
`TableDataRequest`	`initUnsubscribeRequest(long keyToUnsubscribe)`
`boolean`	`isSubscribe()`
`TableDataRequest`	`markProvider(TableLocationProvider provider)`
`protected void`	`onReferenceCountAtZero()`	Callback method that will be invoked when the reference count returns to zero.
`void`	`setDeadlineMillis(long deadlineMillis)`
`String`	`toString()`
`TableDataRequest`	`withHandler(RequestResultHandler handler)`

Methods inherited from class com.illumon.util.referencecounting.ReferenceCounted

decrementReferenceCount, incrementReferenceCount, resetReferenceCount, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

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

Method Details
- onReferenceCountAtZero
  
  protected final void onReferenceCountAtZero()
  
  Description copied from class: ReferenceCounted
  
  Callback method that will be invoked when the reference count returns to zero.
  
  Specified by:
  
  onReferenceCountAtZero in class ReferenceCounted
- append
  
  public final com.fishlib.base.log.LogOutput append(@NotNull com.fishlib.base.log.LogOutput logOutput)
  
  Specified by:
  
  append in interface com.fishlib.base.log.LogOutputAppendable
  
  Overrides:
  
  append in class ReferenceCounted
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class ReferenceCounted
- initUnsubscribeRequest
  
  public TableDataRequest initUnsubscribeRequest(long keyToUnsubscribe)
  
  Specified by:
  
  initUnsubscribeRequest in interface TableDataRequest
- initTableLocationsRequest
  
  public TableDataRequest initTableLocationsRequest(boolean subscribe, @NotNull TableKey tableKey)
  
  Specified by:
  
  initTableLocationsRequest in interface TableDataRequest
- withHandler
  
  @NotNull public TableDataRequest withHandler(@NotNull RequestResultHandler handler)
  
  Specified by:
  
  withHandler in interface TableDataRequest
- markProvider
  
  public TableDataRequest markProvider(@NotNull TableLocationProvider provider)
  
  Specified by:
  
  markProvider in interface TableDataRequest
- initTableLocationRefreshRequest
  
  public TableDataRequest initTableLocationRefreshRequest(boolean subscribe, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey)
  
  Specified by:
  
  initTableLocationRefreshRequest in interface TableDataRequest
- initColumnLocationExistenceRequest
  
  public TableDataRequest initColumnLocationExistenceRequest(@NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName)
  
  Specified by:
  
  initColumnLocationExistenceRequest in interface TableDataRequest
- initColumnFileSizeRequest
  
  public TableDataRequest initColumnFileSizeRequest(@NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, long requiredSize)
  
  Specified by:
  
  initColumnFileSizeRequest in interface TableDataRequest
- initColumnFileDataRequest
  
  public TableDataRequest initColumnFileDataRequest(@NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, @NotNull ByteBuffer buffer, long position)
  
  Specified by:
  
  initColumnFileDataRequest in interface TableDataRequest
- dispatch
  
  public TableDataRequest dispatch()
  
  Specified by:
  
  dispatch in interface TableDataRequest
- awaitResponse
  
  public TableDataRequest awaitResponse()
  
  Specified by:
  
  awaitResponse in interface TableDataRequest
- cancel
  
  public TableDataRequest cancel()
  
  Specified by:
  
  cancel in interface TableDataRequest
- done
  
  public void done()
  
  Specified by:
  
  done in interface TableDataRequest
- getHandler
  
  public RequestResultHandler getHandler()
  
  Specified by:
  
  getHandler in interface TableDataRequest
- setDeadlineMillis
  
  public void setDeadlineMillis(long deadlineMillis)
  
  Specified by:
  
  setDeadlineMillis in interface TableDataRequest
- getDeadlineMillis
  
  public long getDeadlineMillis()
  
  Specified by:
  
  getDeadlineMillis in interface TableDataRequest
- isSubscribe
  
  public boolean isSubscribe()
  
  Specified by:
  
  isSubscribe in interface TableDataRequest
- getType
  
  public TableDataProtocol.RequestMessageType getType()
  
  Specified by:
  
  getType in interface TableDataRequest
- getKey
  
  public long getKey()
  
  Specified by:
  
  getKey in interface TableDataRequest
- getColumnExistanceResult
  
  public boolean getColumnExistanceResult()
  
  Specified by:
  
  getColumnExistanceResult in interface TableDataRequest
- getColumnIsLittleEndianResult
  
  public boolean getColumnIsLittleEndianResult()
  
  Specified by:
  
  getColumnIsLittleEndianResult in interface TableDataRequest
- getColumnHasSymbolTableResult
  
  public boolean getColumnHasSymbolTableResult()
  
  Specified by:
  
  getColumnHasSymbolTableResult in interface TableDataRequest
- getColumnFileSizeResult
  
  public long getColumnFileSizeResult()
  
  Specified by:
  
  getColumnFileSizeResult in interface TableDataRequest
- getColumnFileDataLengthResult
  
  public int getColumnFileDataLengthResult()
  
  Specified by:
  
  getColumnFileDataLengthResult in interface TableDataRequest
- getTableLocationProviderStamp
  
  public long getTableLocationProviderStamp()
  
  Specified by:
  
  getTableLocationProviderStamp in interface TableDataRequest

Class TableDataRequestImpl

Method Summary

Methods inherited from class com.illumon.util.referencecounting.ReferenceCounted

Methods inherited from class java.lang.Object

Method Details