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(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)
void	setDeadlineMillis(long deadlineMillis)
TableDataRequest	setTableLocationProviderStamp(long stamp)
TableDataRequest	withHandler(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
 TableKey tableKey)

withHandler

@NotNull
TableDataRequest withHandler(@NotNull
 RequestResultHandler handler)

markProvider

TableDataRequest markProvider(@NotNull
 TableLocationProvider provider)

setTableLocationProviderStamp

TableDataRequest setTableLocationProviderStamp(long stamp)

initTableLocationRefreshRequest

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

initColumnLocationExistenceRequest

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

initColumnFileSizeRequest

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

initColumnFileDataRequest

TableDataRequest initColumnFileDataRequest(@NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName,
 @NotNull
 ColumnFileType columnFileType,
 @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()