Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 01F8B200D3D for ; Sun, 29 Oct 2017 16:17:17 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 00891160BE3; Sun, 29 Oct 2017 15:17:17 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 8E7101609E6 for ; Sun, 29 Oct 2017 16:17:14 +0100 (CET) Received: (qmail 90090 invoked by uid 500); 29 Oct 2017 15:17:09 -0000 Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hbase.apache.org Delivered-To: mailing list commits@hbase.apache.org Received: (qmail 88151 invoked by uid 99); 29 Oct 2017 15:17:08 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 29 Oct 2017 15:17:08 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id BA612E00B7; Sun, 29 Oct 2017 15:17:02 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: git-site-role@apache.org To: commits@hbase.apache.org Date: Sun, 29 Oct 2017 15:17:21 -0000 Message-Id: <219badd190fb4cc7a64f9aff6517b5e1@git.apache.org> In-Reply-To: <11cba8af2f38407187399e27777da895@git.apache.org> References: <11cba8af2f38407187399e27777da895@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [20/51] [partial] hbase-site git commit: Published site at . archived-at: Sun, 29 Oct 2017 15:17:17 -0000 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1d9053bc/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/ScanType.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/ScanType.html b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/ScanType.html index 8641f1c..f4e7b13 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/ScanType.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/ScanType.html @@ -140,6 +140,17 @@ StoreFile. + +default void +RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanType scanType, + ScanOptions options, + CompactionLifeCycleTracker tracker, + CompactionRequest request) +
Called before we open store scanner for compaction.
+ + @@ -156,13 +167,31 @@ InternalScanner -ZooKeeperScanPolicyObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, +WriteHeavyIncrementObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request)  + +void +WriteHeavyIncrementObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanType scanType, + ScanOptions options, + CompactionLifeCycleTracker tracker, + CompactionRequest request)  + + +void +ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanType scanType, + ScanOptions options, + CompactionLifeCycleTracker tracker, + CompactionRequest request)  + @@ -231,6 +260,16 @@ the order they are declared.
Called prior to rewriting the store files selected for compaction
+ +ScanInfo +RegionCoprocessorHost.preCompactScannerOpen(HStore store, + ScanType scanType, + CompactionLifeCycleTracker tracker, + CompactionRequest request, + User user) +
Called prior to opening store scanner for compaction.
+ + @@ -240,9 +279,8 @@ the order they are declared. - - - - - - - + + + +
StoreScanner(HStore store, +StoreScanner(HStore store, ScanInfo scanInfo, - OptionalInt maxVersions, List<? extends KeyValueScanner> scanners, ScanType scanType, long smallestReadPoint, @@ -251,9 +289,8 @@ the order they are declared.
StoreScanner(HStore store, +StoreScanner(HStore store, ScanInfo scanInfo, - OptionalInt maxVersions, List<? extends KeyValueScanner> scanners, ScanType scanType, long smallestReadPoint, @@ -262,7 +299,7 @@ the order they are declared. byte[] dropDeletesToRow) 
StoreScanner(Optional<HStore> store, +StoreScanner(HStore store, Scan scan, ScanInfo scanInfo, int numColumns, @@ -316,7 +353,8 @@ the order they are declared.
protected InternalScannerCompactor.createScanner(HStore store, +Compactor.createScanner(HStore store, + ScanInfo scanInfo, List<StoreFileScanner> scanners, ScanType scanType, long smallestReadPoint, @@ -324,27 +362,35 @@ the order they are declared.
InternalScannerCompactor.InternalScannerFactory.createScanner(List<StoreFileScanner> scanners, +Compactor.InternalScannerFactory.createScanner(ScanInfo scanInfo, + List<StoreFileScanner> scanners, ScanType scanType, Compactor.FileDetails fd, long smallestReadPoint) 
InternalScannerStripeCompactor.StripeInternalScannerFactory.createScanner(List<StoreFileScanner> scanners, +StripeCompactor.StripeInternalScannerFactory.createScanner(ScanInfo scanInfo, + List<StoreFileScanner> scanners, ScanType scanType, Compactor.FileDetails fd, long smallestReadPoint) 
private InternalScannerCompactor.postCreateCoprocScanner(CompactionRequestImpl request, - ScanType scanType, - InternalScanner scanner, - User user) +Compactor.postCompactScannerOpen(CompactionRequestImpl request, + ScanType scanType, + InternalScanner scanner, + User user)
Calls coprocessor, if any, to create scanners - after normal scanner creation.
private ScanInfoCompactor.preCompactScannerOpen(CompactionRequestImpl request, + ScanType scanType, + User user) 
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1d9053bc/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Shipper.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Shipper.html b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Shipper.html index 9d6932f..707e09e 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Shipper.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Shipper.html @@ -159,12 +159,6 @@
Scanner that returns the next KeyValue.
- -interface  -RegionScanner -
RegionScanner describes iterators over rows in an HRegion.
- - @@ -252,6 +246,49 @@
+ + + + + + + + + + + + +
Fields in org.apache.hadoop.hbase.regionserver declared as Shipper 
Modifier and TypeField and Description
private ShipperRSRpcServices.RegionScannerShippedCallBack.shipper 
+ + + + + + + + + + + + +
Methods in org.apache.hadoop.hbase.regionserver with parameters of type Shipper 
Modifier and TypeMethod and Description
private RSRpcServices.RegionScannerHolderRSRpcServices.addScanner(String scannerName, + RegionScanner s, + Shipper shipper, + HRegion r, + boolean needCursor) 
+ + + + + + + + + + +
Constructors in org.apache.hadoop.hbase.regionserver with parameters of type Shipper 
Constructor and Description
RegionScannerShippedCallBack(String scannerName, + Shipper shipper, + Leases.Lease lease) 
  • http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1d9053bc/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Store.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Store.html b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Store.html index 745e62b..584afd1 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Store.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Store.html @@ -164,6 +164,17 @@ default void +RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanType scanType, + ScanOptions options, + CompactionLifeCycleTracker tracker, + CompactionRequest request) +
    Called before we open store scanner for compaction.
    + + + +default void RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> candidates, @@ -172,7 +183,7 @@ available candidates. - + default InternalScanner RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, @@ -181,6 +192,23 @@
    Called before a Store's memstore is flushed to disk.
    + +default void +RegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanOptions options, + FlushLifeCycleTracker tracker) +
    Called before we open store scanner for flush.
    + + + +default void +RegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, + Store store, + ScanOptions options) +
    Called before a store opens a new scanner.
    + +
    • @@ -197,7 +225,7 @@ InternalScanner -ZooKeeperScanPolicyObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, +WriteHeavyIncrementObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, @@ -205,12 +233,50 @@ CompactionRequest request)  +void +WriteHeavyIncrementObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanType scanType, + ScanOptions options, + CompactionLifeCycleTracker tracker, + CompactionRequest request)  + + +void +ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanType scanType, + ScanOptions options, + CompactionLifeCycleTracker tracker, + CompactionRequest request)  + + InternalScanner -ZooKeeperScanPolicyObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, +WriteHeavyIncrementObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker)  + +void +WriteHeavyIncrementObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanOptions options, + FlushLifeCycleTracker tracker)  + + +void +ZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, + Store store, + ScanOptions options, + FlushLifeCycleTracker tracker)  + + +void +WriteHeavyIncrementObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, + Store store, + ScanOptions options)  + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1d9053bc/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/StoreFileScanner.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/StoreFileScanner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/StoreFileScanner.html index 302dd3c..95fe114 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/StoreFileScanner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/StoreFileScanner.html @@ -244,7 +244,8 @@ protected InternalScanner -Compactor.createScanner(HStore store, +Compactor.createScanner(HStore store, + ScanInfo scanInfo, List<StoreFileScanner> scanners, long smallestReadPoint, long earliestPutTs, @@ -253,7 +254,8 @@ protected InternalScanner -Compactor.createScanner(HStore store, +Compactor.createScanner(HStore store, + ScanInfo scanInfo, List<StoreFileScanner> scanners, ScanType scanType, long smallestReadPoint, @@ -261,14 +263,16 @@ InternalScanner -Compactor.InternalScannerFactory.createScanner(List<StoreFileScanner> scanners, +Compactor.InternalScannerFactory.createScanner(ScanInfo scanInfo, + List<StoreFileScanner> scanners, ScanType scanType, Compactor.FileDetails fd, long smallestReadPoint)  InternalScanner -StripeCompactor.StripeInternalScannerFactory.createScanner(List<StoreFileScanner> scanners, +StripeCompactor.StripeInternalScannerFactory.createScanner(ScanInfo scanInfo, + List<StoreFileScanner> scanners, ScanType scanType, Compactor.FileDetails fd, long smallestReadPoint)  http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1d9053bc/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/AbstractMultiOutputCompactor.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/AbstractMultiOutputCompactor.html b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/AbstractMultiOutputCompactor.html index 671789b..440aa9d 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/AbstractMultiOutputCompactor.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/AbstractMultiOutputCompactor.html @@ -217,7 +217,7 @@ extends Compactor -commitWriter, compact, createScanner, createScanner, createTmpWriter, getProgress, performCompaction +commitWriter, compact, createScanner, createScanner, createTmpWriter, getProgress, performCompaction @@ -151,7 +151,7 @@ var activeTableTab = "activeTableTab";

    • createWriter

      -
      S createWriter(InternalScanner scanner,
+
      S createWriter(InternalScanner scanner,
                Compactor.FileDetails fd,
                boolean shouldDropBehind)
         throws IOException
      

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1d9053bc/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.FileDetails.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.FileDetails.html b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.FileDetails.html
index edcbaad..15e1b7e 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.FileDetails.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.FileDetails.html
@@ -107,7 +107,7 @@
 
 
      
 
      
-
      protected static class Compactor.FileDetails
+
      protected static class Compactor.FileDetails
 extends Object
      
 
      The sole reason this class exists is that java has no ref/out/pointer parameters.
      • @@ -225,7 +225,7 @@ extends

    • maxKeyCount

      -
      public long maxKeyCount
      +
      public long maxKeyCount
      Maximum key count after compaction (for blooms)
    @@ -235,7 +235,7 @@ extends

  • earliestPutTs

    -
    public long earliestPutTs
    +
    public long earliestPutTs
    Earliest put timestamp if major compaction
    • @@ -245,7 +245,7 @@ extends

  • latestPutTs

    -
    public long latestPutTs
    +
    public long latestPutTs
    Latest put timestamp
    • @@ -255,7 +255,7 @@ extends

  • maxSeqId

    -
    public long maxSeqId
    +
    public long maxSeqId
    The last key in the files we're compacting.
    • @@ -265,7 +265,7 @@ extends

  • maxMVCCReadpoint

    -
    public long maxMVCCReadpoint
    +
    public long maxMVCCReadpoint
    Latest memstore read point found in any of the involved files
    • @@ -275,7 +275,7 @@ extends

  • maxTagsLength

    -
    public int maxTagsLength
    +
    public int maxTagsLength
    Max tags length
    • @@ -285,7 +285,7 @@ extends

  • minSeqIdToKeep

    -
    public long minSeqIdToKeep
    +
    public long minSeqIdToKeep
    Min SeqId to keep during a major compaction
    • @@ -303,7 +303,7 @@ extends

  • FileDetails

    -
    protected FileDetails()
    +
    protected FileDetails()
    • http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1d9053bc/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.InternalScannerFactory.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.InternalScannerFactory.html b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.InternalScannerFactory.html index f8f51c0..e6d6da1 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.InternalScannerFactory.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/Compactor.InternalScannerFactory.html @@ -109,7 +109,7 @@ var activeTableTab = "activeTableTab";

    -
    protected static interface Compactor.InternalScannerFactory
    +
    protected static interface Compactor.InternalScannerFactory
    @@ -130,7 +130,8 @@ var activeTableTab = "activeTableTab"; InternalScanner -createScanner(List<StoreFileScanner> scanners, +createScanner(ScanInfo scanInfo, + List<StoreFileScanner> scanners, ScanType scanType, Compactor.FileDetails fd, long smallestReadPoint)  @@ -160,16 +161,17 @@ var activeTableTab = "activeTableTab"; - +