private static class ScannerContext.LimitFields extends Object
InternalScanner.next(java.util.List)
and InternalScanner.next(java.util.List)
Modifier and Type | Field and Description |
---|---|
(package private) int |
batch |
(package private) long |
dataSize |
private static int |
DEFAULT_BATCH
Default values of the limit fields.
|
private static ScannerContext.LimitScope |
DEFAULT_SCOPE
Default scope that is assigned to a limit if a scope is not specified.
|
private static long |
DEFAULT_SIZE |
private static long |
DEFAULT_TIME |
(package private) long |
heapSize |
(package private) ScannerContext.LimitScope |
sizeScope |
(package private) long |
time |
(package private) ScannerContext.LimitScope |
timeScope |
Constructor and Description |
---|
LimitFields()
Fields keep their default values.
|
Modifier and Type | Method and Description |
---|---|
(package private) boolean |
canEnforceBatchLimitFromScope(ScannerContext.LimitScope checkerScope) |
(package private) boolean |
canEnforceSizeLimitFromScope(ScannerContext.LimitScope checkerScope) |
(package private) boolean |
canEnforceTimeLimitFromScope(ScannerContext.LimitScope checkerScope) |
(package private) void |
copy(ScannerContext.LimitFields limitsToCopy) |
(package private) int |
getBatch() |
(package private) long |
getDataSize() |
(package private) long |
getHeapSize() |
(package private) ScannerContext.LimitScope |
getSizeScope() |
(package private) long |
getTime() |
(package private) ScannerContext.LimitScope |
getTimeScope() |
(package private) void |
setBatch(int batch) |
(package private) void |
setDataSize(long dataSize) |
(package private) void |
setFields(int batch,
ScannerContext.LimitScope sizeScope,
long dataSize,
long heapSize,
ScannerContext.LimitScope timeScope,
long time)
Set all fields together.
|
(package private) void |
setHeapSize(long heapSize) |
(package private) void |
setSizeScope(ScannerContext.LimitScope scope)
Change the scope in which the size limit is enforced
|
(package private) void |
setTime(long time) |
(package private) void |
setTimeScope(ScannerContext.LimitScope scope)
Change the scope in which the time limit is enforced
|
String |
toString() |
private static int DEFAULT_BATCH
private static long DEFAULT_SIZE
private static long DEFAULT_TIME
private static final ScannerContext.LimitScope DEFAULT_SCOPE
int batch
ScannerContext.LimitScope sizeScope
long dataSize
long heapSize
ScannerContext.LimitScope timeScope
long time
LimitFields()
void copy(ScannerContext.LimitFields limitsToCopy)
void setFields(int batch, ScannerContext.LimitScope sizeScope, long dataSize, long heapSize, ScannerContext.LimitScope timeScope, long time)
int getBatch()
void setBatch(int batch)
boolean canEnforceBatchLimitFromScope(ScannerContext.LimitScope checkerScope)
checkerScope
- long getDataSize()
long getHeapSize()
void setDataSize(long dataSize)
void setHeapSize(long heapSize)
ScannerContext.LimitScope getSizeScope()
ScannerContext.LimitScope
indicating scope in which the size limit is enforcedvoid setSizeScope(ScannerContext.LimitScope scope)
boolean canEnforceSizeLimitFromScope(ScannerContext.LimitScope checkerScope)
checkerScope
- long getTime()
void setTime(long time)
ScannerContext.LimitScope getTimeScope()
ScannerContext.LimitScope
indicating scope in which the time limit is enforcedvoid setTimeScope(ScannerContext.LimitScope scope)
boolean canEnforceTimeLimitFromScope(ScannerContext.LimitScope checkerScope)
checkerScope
- Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.