Package org.apache.hadoop.hbase.regionserver

Class StripeStoreFlusher.SizeStripeFlushRequest

java.lang.Object

org.apache.hadoop.hbase.regionserver.StripeStoreFlusher.StripeFlushRequest

org.apache.hadoop.hbase.regionserver.StripeStoreFlusher.SizeStripeFlushRequest

Enclosing class:

StripeStoreFlusher

public static class StripeStoreFlusher.SizeStripeFlushRequest
extends StripeStoreFlusher.StripeFlushRequest

Stripe flush request wrapper based on size.

Field Summary

Fields

Modifier and Type	Field	Description
private final int	targetCount
private final long	targetKvs

Fields inherited from class org.apache.hadoop.hbase.regionserver.StripeStoreFlusher.StripeFlushRequest

comparator

Constructor Summary

Constructors

Constructor	Description
SizeStripeFlushRequest(CellComparator comparator, int targetCount, long targetKvs)

Method Summary

Modifier and Type	Method	Description
StripeMultiFileWriter	createWriter()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

targetCount

private final int targetCount

targetKvs

private final long targetKvs

Constructor Details

SizeStripeFlushRequest

public SizeStripeFlushRequest(CellComparator comparator,
 int targetCount,
 long targetKvs)

Parameters:

targetCount - The maximum number of stripes to flush into.

targetKvs - The KV count of each segment. If targetKvs*targetCount is less than total number of kvs, all the overflow data goes into the last stripe.

Method Details

createWriter

public StripeMultiFileWriter createWriter()
                                   throws IOException

Overrides:

createWriter in class StripeStoreFlusher.StripeFlushRequest

Throws:

IOException