Modifier and Type | Field and Description |
---|---|
private long |
cellsPerTimeoutCheck |
private CellComparator |
comparator |
private byte[] |
family |
static long |
FIXED_OVERHEAD |
private KeepDeletedCells |
keepDeletedCells |
private int |
maxVersions |
private int |
minVersions |
private boolean |
newVersionBehavior |
private boolean |
parallelSeekEnabled |
private long |
preadMaxBytes |
private long |
tableMaxRowSize |
private long |
timeToPurgeDeletes |
private long |
ttl |
private boolean |
usePread |
Modifier | Constructor and Description |
---|---|
private |
ScanInfo(byte[] family,
int minVersions,
int maxVersions,
long ttl,
KeepDeletedCells keepDeletedCells,
long timeToPurgeDeletes,
CellComparator comparator,
long tableMaxRowSize,
boolean usePread,
long cellsPerTimeoutCheck,
boolean parallelSeekEnabled,
long preadMaxBytes,
boolean newVersionBehavior) |
|
ScanInfo(org.apache.hadoop.conf.Configuration conf,
byte[] family,
int minVersions,
int maxVersions,
long ttl,
KeepDeletedCells keepDeletedCells,
long blockSize,
long timeToPurgeDeletes,
CellComparator comparator,
boolean newVersionBehavior) |
|
ScanInfo(org.apache.hadoop.conf.Configuration conf,
ColumnFamilyDescriptor family,
long ttl,
long timeToPurgeDeletes,
CellComparator comparator) |
Modifier and Type | Method and Description |
---|---|
(package private) ScanInfo |
customize(int maxVersions,
long ttl,
KeepDeletedCells keepDeletedCells)
Used for CP users for customizing max versions, ttl and keepDeletedCells.
|
(package private) long |
getCellsPerTimeoutCheck() |
private static long |
getCellsPerTimeoutCheck(org.apache.hadoop.conf.Configuration conf) |
CellComparator |
getComparator() |
byte[] |
getFamily() |
KeepDeletedCells |
getKeepDeletedCells() |
int |
getMaxVersions() |
int |
getMinVersions() |
(package private) long |
getPreadMaxBytes() |
(package private) long |
getTableMaxRowSize() |
long |
getTimeToPurgeDeletes() |
long |
getTtl() |
boolean |
isNewVersionBehavior() |
(package private) boolean |
isParallelSeekEnabled() |
(package private) boolean |
isUsePread() |
private byte[] family
private int minVersions
private int maxVersions
private long ttl
private KeepDeletedCells keepDeletedCells
private long timeToPurgeDeletes
private CellComparator comparator
private long tableMaxRowSize
private boolean usePread
private long cellsPerTimeoutCheck
private boolean parallelSeekEnabled
private final long preadMaxBytes
private final boolean newVersionBehavior
public static final long FIXED_OVERHEAD
public ScanInfo(org.apache.hadoop.conf.Configuration conf, ColumnFamilyDescriptor family, long ttl, long timeToPurgeDeletes, CellComparator comparator)
conf
- family
- ColumnFamilyDescriptor
describing the column familyttl
- Store's TTL (in ms)timeToPurgeDeletes
- duration in ms after which a delete marker can be purged during a
major compaction.comparator
- The store's comparatorpublic ScanInfo(org.apache.hadoop.conf.Configuration conf, byte[] family, int minVersions, int maxVersions, long ttl, KeepDeletedCells keepDeletedCells, long blockSize, long timeToPurgeDeletes, CellComparator comparator, boolean newVersionBehavior)
conf
- family
- Name of this store's column familyminVersions
- Store's MIN_VERSIONS settingmaxVersions
- Store's VERSIONS settingttl
- Store's TTL (in ms)blockSize
- Store's block sizetimeToPurgeDeletes
- duration in ms after which a delete marker can
be purged during a major compaction.keepDeletedCells
- Store's keepDeletedCells settingcomparator
- The store's comparatorprivate ScanInfo(byte[] family, int minVersions, int maxVersions, long ttl, KeepDeletedCells keepDeletedCells, long timeToPurgeDeletes, CellComparator comparator, long tableMaxRowSize, boolean usePread, long cellsPerTimeoutCheck, boolean parallelSeekEnabled, long preadMaxBytes, boolean newVersionBehavior)
private static long getCellsPerTimeoutCheck(org.apache.hadoop.conf.Configuration conf)
long getTableMaxRowSize()
boolean isUsePread()
long getCellsPerTimeoutCheck()
boolean isParallelSeekEnabled()
public byte[] getFamily()
public int getMinVersions()
public int getMaxVersions()
public long getTtl()
public KeepDeletedCells getKeepDeletedCells()
public long getTimeToPurgeDeletes()
public CellComparator getComparator()
long getPreadMaxBytes()
public boolean isNewVersionBehavior()
ScanInfo customize(int maxVersions, long ttl, KeepDeletedCells keepDeletedCells)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.