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

Class TableDataRequestImpl

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
final 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()
TableLocationKey	getLocationKey()
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 final void	onReferenceCountAtZero()	Callback method that will be invoked when the reference count returns to zero.
void	setDeadlineMillis(long deadlineMillis)
TableDataRequest	setTableLocationProviderStamp(long tableLocationProviderStamp)
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

setTableLocationProviderStamp

public TableDataRequest setTableLocationProviderStamp(long tableLocationProviderStamp)

Specified by:

setTableLocationProviderStamp 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

getLocationKey

public TableLocationKey getLocationKey()

Specified by:

getLocationKey in interface TableDataRequest