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

Interface TableDataRequest

All Superinterfaces:

com.fishlib.base.log.LogOutputAppendable

All Known Implementing Classes:

TableDataRequestImpl

public interface TableDataRequest
extends com.fishlib.base.log.LogOutputAppendable

Method Summary

Modifier and Type	Method	Description
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(@NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, @NotNull ByteBuffer buffer, long position)
TableDataRequest	initColumnFileSizeRequest(@NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, long requiredSize)
TableDataRequest	initColumnLocationExistenceRequest(@NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName)
TableDataRequest	initTableLocationRefreshRequest(boolean subscribe, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey)
TableDataRequest	initTableLocationsRequest(boolean subscribe, @NotNull TableKey tableKey)
TableDataRequest	initUnsubscribeRequest(long keyToUnsubscribe)
boolean	isSubscribe()
TableDataRequest	markProvider(@NotNull TableLocationProvider provider)
void	setDeadlineMillis(long deadlineMillis)
TableDataRequest	setTableLocationProviderStamp(long stamp)
@NotNull TableDataRequest	withHandler(@NotNull RequestResultHandler handler)

Methods inherited from interface com.fishlib.base.log.LogOutputAppendable

append

Method Details

initUnsubscribeRequest

TableDataRequest initUnsubscribeRequest(long keyToUnsubscribe)

initTableLocationsRequest

TableDataRequest initTableLocationsRequest(boolean subscribe,
 @NotNull
 @NotNull TableKey tableKey)

withHandler

@NotNull
@NotNull TableDataRequest withHandler(@NotNull
 @NotNull RequestResultHandler handler)

markProvider

TableDataRequest markProvider(@NotNull
 @NotNull TableLocationProvider provider)

setTableLocationProviderStamp

TableDataRequest setTableLocationProviderStamp(long stamp)

initTableLocationRefreshRequest

TableDataRequest initTableLocationRefreshRequest(boolean subscribe,
 @NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey)

initColumnLocationExistenceRequest

TableDataRequest initColumnLocationExistenceRequest(@NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey,
 @NotNull
 @NotNull CharSequence columnName)

initColumnFileSizeRequest

TableDataRequest initColumnFileSizeRequest(@NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey,
 @NotNull
 @NotNull CharSequence columnName,
 @NotNull
 @NotNull ColumnFileType columnFileType,
 long requiredSize)

initColumnFileDataRequest

TableDataRequest initColumnFileDataRequest(@NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey,
 @NotNull
 @NotNull CharSequence columnName,
 @NotNull
 @NotNull ColumnFileType columnFileType,
 @NotNull
 @NotNull ByteBuffer buffer,
 long position)

dispatch

TableDataRequest dispatch()

awaitResponse

TableDataRequest awaitResponse()

cancel

TableDataRequest cancel()

done

void done()

getHandler

RequestResultHandler getHandler()

setDeadlineMillis

void setDeadlineMillis(long deadlineMillis)

getDeadlineMillis

long getDeadlineMillis()

isSubscribe

boolean isSubscribe()

getType

TableDataProtocol.RequestMessageType getType()

getKey

long getKey()

getColumnExistanceResult

boolean getColumnExistanceResult()

getColumnIsLittleEndianResult

boolean getColumnIsLittleEndianResult()

getColumnHasSymbolTableResult

boolean getColumnHasSymbolTableResult()

getColumnFileSizeResult

long getColumnFileSizeResult()

getColumnFileDataLengthResult

int getColumnFileDataLengthResult()

getTableLocationProviderStamp

long getTableLocationProviderStamp()

getLocationKey

TableLocationKey getLocationKey()