Field Detail

• conf

  protected org.apache.hadoop.conf.Configuration conf

• store

  protected Store store

Constructor Detail

• DefaultStoreFlusher

  public DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf,
                     Store store)

Method Detail

• flushSnapshot

  public List<org.apache.hadoop.fs.Path> flushSnapshot(MemStoreSnapshot snapshot,
                                              long cacheFlushId,
                                              MonitoredTask status,
                                              ThroughputController throughputController)
                                                throws IOException

  Turns a snapshot of memstore into a set of store files.

  Parameters:

  snapshot - Memstore snapshot.

  cacheFlushId - Log cache flush sequence number.

  status - Task that represents the flush operation and may be updated with status.

  throughputController - A controller to avoid flush too fast

  Returns:

  List of files written. Can be empty; must not be null.

  Throws:

  IOException

• finalizeWriter

  protected void finalizeWriter(StoreFile.Writer writer,
                    long cacheFlushSeqNum,
                    MonitoredTask status)
                         throws IOException

  Throws:

  IOException

• createScanner

  protected InternalScanner createScanner(KeyValueScanner snapshotScanner,
                              long smallestReadPoint)
                                   throws IOException

  Creates the scanner for flushing snapshot. Also calls coprocessors.

  Parameters:

  snapshotScanner -

  smallestReadPoint -

  Returns:

  The scanner; null if coprocessor is canceling the flush.

  Throws:

  IOException

• performFlush

  protected void performFlush(InternalScanner scanner,
                  Compactor.CellSink sink,
                  long smallestReadPoint,
                  ThroughputController throughputController)
                       throws IOException

  Performs memstore flush, writing data from scanner into sink.

  Parameters:

  scanner - Scanner to get data from.

  sink - Sink to write data to. Could be StoreFile.Writer.

  smallestReadPoint - Smallest read point used for the flush.

  throughputController - A controller to avoid flush too fast

  Throws:

  IOException