hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jya...@apache.org
Subject svn commit: r1448778 - in /hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase: coprocessor/RegionObserver.java regionserver/compactions/Compactor.java regionserver/compactions/DefaultCompactor.java
Date Thu, 21 Feb 2013 19:21:47 GMT
Author: jyates
Date: Thu Feb 21 19:21:46 2013
New Revision: 1448778

URL: http://svn.apache.org/r1448778
Log:
HBASE-7725: Add ability to create custom compaction request - ADDENDUM: fix javadocs

Modified:
    hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/RegionObserver.java
    hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
    hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java

Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/RegionObserver.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/RegionObserver.java?rev=1448778&r1=1448777&r2=1448778&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/RegionObserver.java
(original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/RegionObserver.java
Thu Feb 21 19:21:46 2013
@@ -148,8 +148,10 @@ public interface RegionObserver extends 
    * @param store the store where compaction is being requested
    * @param candidates the store files currently available for compaction
    * @throws IOException if an error occurred on the coprocessor
-   * @deprecated Use {@link #preCompactSelection(ObserverContext, Store, List, Object)} instead
+   * @deprecated Use {@link #preCompactSelection(ObserverContext, Store, List, CompactionRequest)}
+   *             instead
    */
+  @Deprecated
   void preCompactSelection(final ObserverContext<RegionCoprocessorEnvironment> c,
       final Store store, final List<StoreFile> candidates) throws IOException;
 
@@ -170,9 +172,8 @@ public interface RegionObserver extends 
    * @param c the environment provided by the region server
    * @param store the store being compacted
    * @param selected the store files selected to compact
-   * @param compactionAttributes custom attributes for the compaction
-   * @deprecated use {@link #postCompactSelection(ObserverContext, Store, ImmutableList,
Object)}
-   *             instead.
+   * @deprecated use {@link #postCompactSelection(ObserverContext, Store, ImmutableList,
+   *             CompactionRequest)} instead.
    */
   @Deprecated
   void postCompactSelection(final ObserverContext<RegionCoprocessorEnvironment> c,
@@ -221,13 +222,12 @@ public interface RegionObserver extends 
    * @param store the store being compacted
    * @param scanner the scanner over existing data used in the store file rewriting
    * @param scanType type of Scan
-   * @param request the requested compaction
    * @return the scanner to use during compaction. Should not be {@code null} unless the
    *         implementation is writing new store files on its own.
    * @throws IOException if an error occurred on the coprocessor
    * @deprecated use
-   *             {@link #preCompact(ObserverContext, Store, InternalScanner, ScanType, CompactionRequest)}
-   *             instead
+   *             {@link #preCompact(ObserverContext, Store, InternalScanner,
+   *             ScanType, CompactionRequest)} instead
    */
   @Deprecated
   InternalScanner preCompact(final ObserverContext<RegionCoprocessorEnvironment> c,
@@ -271,13 +271,12 @@ public interface RegionObserver extends 
    * @param earliestPutTs timestamp of the earliest put that was found in any of the involved
store
    *          files
    * @param s the base scanner, if not {@code null}, from previous RegionObserver in the
chain
-   * @param request the requested compaction
    * @return the scanner to use during compaction. {@code null} if the default implementation
is to
    *         be used.
    * @throws IOException if an error occurred on the coprocessor
    * @deprecated Use
-   *             {@link #preCompactScannerOpen(ObserverContext, Store, List, ScanType, long,
InternalScanner, CompactionRequest)}
-   *             instead.
+   *             {@link #preCompactScannerOpen(ObserverContext, Store, List, ScanType, long,
+   *             InternalScanner, CompactionRequest)} instead.
    */
   @Deprecated
   InternalScanner preCompactScannerOpen(final ObserverContext<RegionCoprocessorEnvironment>
c,

Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java?rev=1448778&r1=1448777&r2=1448778&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
(original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
Thu Feb 21 19:21:46 2013
@@ -18,7 +18,6 @@
 package org.apache.hadoop.hbase.regionserver.compactions;
 
 import java.io.IOException;
-import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
 
@@ -42,7 +41,6 @@ public abstract class Compactor {
 
   /**
    * Do a minor/major compaction on an explicit set of storefiles from a Store.
-   * @param filesToCompact which files to compact
    * @param request the requested compaction
    * @return Product of compaction or an empty list if all cells expired or deleted and nothing
made
    *         it through the compaction.

Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java?rev=1448778&r1=1448777&r2=1448778&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java
(original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java
Thu Feb 21 19:21:46 2013
@@ -44,8 +44,7 @@ import org.apache.hadoop.hbase.util.Byte
 import org.apache.hadoop.util.StringUtils;
 
 /**
- * Compact passed set of files.
- * Create an instance and then call {@link #compact(Collection, boolean)}.
+ * Compact passed set of files. Create an instance and then call {@link #compact(CompactionRequest)}
  */
 @InterfaceAudience.Private
 public class DefaultCompactor extends Compactor {



Mime
View raw message