Return-Path: X-Original-To: apmail-hbase-commits-archive@www.apache.org Delivered-To: apmail-hbase-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0139E18FF4 for ; Thu, 26 Nov 2015 04:29:40 +0000 (UTC) Received: (qmail 13583 invoked by uid 500); 26 Nov 2015 04:29:34 -0000 Delivered-To: apmail-hbase-commits-archive@hbase.apache.org Received: (qmail 13494 invoked by uid 500); 26 Nov 2015 04:29:34 -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 6559 invoked by uid 99); 26 Nov 2015 04:29:26 -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; Thu, 26 Nov 2015 04:29:26 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C1F28E2C12; Thu, 26 Nov 2015 04:29:26 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: busbey@apache.org To: commits@hbase.apache.org Date: Thu, 26 Nov 2015 04:30:10 -0000 Message-Id: <9c5ff17fb927419891970e1e16603949@git.apache.org> In-Reply-To: <3bdc660350bc4ea49fdaa83a55939a7b@git.apache.org> References: <3bdc660350bc4ea49fdaa83a55939a7b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [45/51] [partial] hbase git commit: Published site at e73a9594c218ed969a2f5b0b356d7b8d0e1474c0. http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/coc.html ---------------------------------------------------------------------- diff --git a/coc.html b/coc.html index 4ca6f24..e10cf40 100644 --- a/coc.html +++ b/coc.html @@ -7,7 +7,7 @@ - + Apache HBase – Code of Conduct Policy @@ -331,7 +331,7 @@ For flagrant violations requiring a firm response the PMC may opt to skip early <a href="http://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2015-11-24</li> + <li id="publishDate" class="pull-right">Last Published: 2015-11-26</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/cygwin.html ---------------------------------------------------------------------- diff --git a/cygwin.html b/cygwin.html index e3731c8..8b80446 100644 --- a/cygwin.html +++ b/cygwin.html @@ -7,7 +7,7 @@ <head> <meta charset="UTF-8" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" /> - <meta name="Date-Revision-yyyymmdd" content="20151124" /> + <meta name="Date-Revision-yyyymmdd" content="20151126" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Installing Apache HBase (TM) on Windows using Cygwin @@ -673,7 +673,7 @@ Now your HBase server is running, start coding and build that next The Apache Software Foundation. All rights reserved. -
  • Last Published: 2015-11-24
  • +
  • Last Published: 2015-11-26
  • http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/dependencies.html ---------------------------------------------------------------------- diff --git a/dependencies.html b/dependencies.html index d02e322..ad3e6fe 100644 --- a/dependencies.html +++ b/dependencies.html @@ -7,7 +7,7 @@ - + Apache HBase – Project Dependencies @@ -518,7 +518,7 @@ The Apache Software Foundation. All rights reserved. -
  • Last Published: 2015-11-24
  • +
  • Last Published: 2015-11-26
  • http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/dependency-convergence.html ---------------------------------------------------------------------- diff --git a/dependency-convergence.html b/dependency-convergence.html index c799ce8..df0de99 100644 --- a/dependency-convergence.html +++ b/dependency-convergence.html @@ -7,7 +7,7 @@ - + Apache HBase – Reactor Dependency Convergence @@ -1592,7 +1592,7 @@ The Apache Software Foundation. All rights reserved. -
  • Last Published: 2015-11-24
  • +
  • Last Published: 2015-11-26
  • http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/dependency-info.html ---------------------------------------------------------------------- diff --git a/dependency-info.html b/dependency-info.html index a929364..874373a 100644 --- a/dependency-info.html +++ b/dependency-info.html @@ -7,7 +7,7 @@ - + Apache HBase – Dependency Information @@ -312,7 +312,7 @@ The Apache Software Foundation. All rights reserved. -
  • Last Published: 2015-11-24
  • +
  • Last Published: 2015-11-26
  • http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/dependency-management.html ---------------------------------------------------------------------- diff --git a/dependency-management.html b/dependency-management.html index 6f1f451..08f7721 100644 --- a/dependency-management.html +++ b/dependency-management.html @@ -7,7 +7,7 @@ - + Apache HBase – Project Dependency Management @@ -786,7 +786,7 @@ The Apache Software Foundation. All rights reserved. -
  • Last Published: 2015-11-24
  • +
  • Last Published: 2015-11-26
  • http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/constant-values.html ---------------------------------------------------------------------- diff --git a/devapidocs/constant-values.html b/devapidocs/constant-values.html index de5c6b3..588ee35 100644 --- a/devapidocs/constant-values.html +++ b/devapidocs/constant-values.html @@ -9530,34 +9530,41 @@ + + +public static final String +OUTPUT_CONF_PREFIX +"hbase.mapred.output." + + public static final String OUTPUT_TABLE "hbase.mapred.outputtable" - + public static final String QUORUM_ADDRESS "hbase.mapred.output.quorum" - + public static final String QUORUM_PORT "hbase.mapred.output.quorum.port" - + public static final String REGION_SERVER_CLASS "hbase.mapred.output.rs.class" - + public static final String http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/index-all.html ---------------------------------------------------------------------- diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html index dadc08c..1f53a4b 100644 --- a/devapidocs/index-all.html +++ b/devapidocs/index-all.html @@ -58626,6 +58626,10 @@ service.
     
    output - Variable in class org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter
     
    +
    OUTPUT_CONF_PREFIX - Static variable in class org.apache.hadoop.hbase.mapreduce.TableOutputFormat
    +
    +
    Prefix for configuration property overrides to apply in TableOutputFormat.setConf(Configuration).
    +
    OUTPUT_DATA_FILE_PREFIX - Static variable in class org.apache.hadoop.hbase.mapreduce.HashTable
     
    OUTPUT_TABLE - Static variable in class org.apache.hadoop.hbase.mapred.TableOutputFormat
    @@ -59075,6 +59079,10 @@ service.
    Parse a number and enforce a range.
    +
    parseMasterServerName(String) - Static method in class org.apache.hadoop.hbase.ZNodeClearer
    +
    +
    See HBASE-14861.
    +
    parseNamespaceResult(Result, QuotaTableUtil.NamespaceQuotasVisitor) - Static method in class org.apache.hadoop.hbase.quotas.QuotaTableUtil
     
    parseNamespaceResult(String, Result, QuotaTableUtil.NamespaceQuotasVisitor) - Static method in class org.apache.hadoop.hbase.quotas.QuotaTableUtil
    @@ -82330,6 +82338,10 @@ service.
     
    subprocs - Variable in class org.apache.hadoop.hbase.procedure.ProcedureMember
     
    +
    subset(Configuration, String) - Static method in class org.apache.hadoop.hbase.HBaseConfiguration
    +
    +
    Returns a subset of the configuration properties, matching the given key prefix.
    +
    subSet(Cell, Cell) - Method in class org.apache.hadoop.hbase.regionserver.CellSkipListSet
     
    subSet(Cell, boolean, Cell, boolean) - Method in class org.apache.hadoop.hbase.regionserver.CellSkipListSet
    @@ -83628,6 +83640,8 @@ service.
    Check if configured to put any tables on the active master
    +
    tablesOnMaster(Configuration) - Static method in class org.apache.hadoop.hbase.ZNodeClearer
    +
     
    TableSplit - Class in org.apache.hadoop.hbase.mapred
    A table split corresponds to a key range [low, high)
    http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/HBaseConfiguration.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/HBaseConfiguration.html b/devapidocs/org/apache/hadoop/hbase/HBaseConfiguration.html index e38fdd1..cf990f2 100644 --- a/devapidocs/org/apache/hadoop/hbase/HBaseConfiguration.html +++ b/devapidocs/org/apache/hadoop/hbase/HBaseConfiguration.html @@ -243,6 +243,13 @@ extends org.apache.hadoop.conf.Configuration
    Merge two configurations.
    + +static org.apache.hadoop.conf.Configuration +subset(org.apache.hadoop.conf.Configuration srcConf, + String prefix) +
    Returns a subset of the configuration properties, matching the given key prefix.
    + +
    • @@ -377,13 +384,28 @@ public  + + +
        +
      • +

        subset

        +
        public static org.apache.hadoop.conf.Configuration subset(org.apache.hadoop.conf.Configuration srcConf,
        +                                          String prefix)
        +
        Returns a subset of the configuration properties, matching the given key prefix. + The prefix is stripped from the return keys, ie. when calling with a prefix of "myprefix", + the entry "myprefix.key1 = value1" would be returned as "key1 = value1". If an entry's + key matches the prefix exactly ("myprefix = value2"), it will not be + included in the results, since it would show up as an entry with an empty key.
        +
      • +
      @@ -393,7 +415,7 @@ public 
    • getInt

      -
      public static int getInt(org.apache.hadoop.conf.Configuration conf,
      +
      public static int getInt(org.apache.hadoop.conf.Configuration conf,
                String name,
                String deprecatedName,
                int defaultValue)
      @@ -416,7 +438,7 @@ public 
    • getPassword

      -
      public static String getPassword(org.apache.hadoop.conf.Configuration conf,
      +
      public static String getPassword(org.apache.hadoop.conf.Configuration conf,
                        String alias,
                        String defPass)
                                 throws IOException
      @@ -435,7 +457,7 @@ public 
    • main

      -
      public static void main(String[] args)
      +
      public static void main(String[] args)
                        throws Exception
      For debugging. Dump configurations to system output as xml format. Master and RS configurations can also be dumped using http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/ZNodeClearer.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ZNodeClearer.html b/devapidocs/org/apache/hadoop/hbase/ZNodeClearer.html index feb394c..244cf87 100644 --- a/devapidocs/org/apache/hadoop/hbase/ZNodeClearer.html +++ b/devapidocs/org/apache/hadoop/hbase/ZNodeClearer.html @@ -95,7 +95,7 @@


    • -
      public class ZNodeClearer
      +
      public class ZNodeClearer
       extends Object

      Contains a set of methods for the collaboration between the start/stop scripts and the servers. It allows to delete immediately the znode when the master or the regions server crashes. @@ -184,10 +184,20 @@ extends static String +parseMasterServerName(String rsZnodePath) +

      See HBASE-14861.
      + + + +static String readMyEphemeralNodeOnDisk()
      read the content of znode file, expects a single line.
      + +private static boolean +tablesOnMaster(org.apache.hadoop.conf.Configuration conf)  + static void writeMyEphemeralNodeOnDisk(String fileContent) @@ -222,7 +232,7 @@ extends
    • LOG

      -
      private static final org.apache.commons.logging.Log LOG
      +
      private static final org.apache.commons.logging.Log LOG
    @@ -239,7 +249,7 @@ extends
  • ZNodeClearer

    -
    private ZNodeClearer()
    +
    private ZNodeClearer()
  • @@ -256,7 +266,7 @@ extends
  • writeMyEphemeralNodeOnDisk

    -
    public static void writeMyEphemeralNodeOnDisk(String fileContent)
    +
    public static void writeMyEphemeralNodeOnDisk(String fileContent)
    Logs the errors without failing on exception.
  • @@ -266,7 +276,7 @@ extends
  • readMyEphemeralNodeOnDisk

    -
    public static String readMyEphemeralNodeOnDisk()
    +
    public static String readMyEphemeralNodeOnDisk()
                                             throws IOException
    read the content of znode file, expects a single line.
    Throws:
    @@ -279,7 +289,7 @@ extends
  • getMyEphemeralNodeFileName

    -
    public static String getMyEphemeralNodeFileName()
    +
    public static String getMyEphemeralNodeFileName()
    Get the name of the file used to store the znode contents
  • @@ -289,19 +299,43 @@ extends
  • deleteMyEphemeralNodeOnDisk

    -
    public static void deleteMyEphemeralNodeOnDisk()
    +
    public static void deleteMyEphemeralNodeOnDisk()
    delete the znode file
  • + + + +
      +
    • +

      parseMasterServerName

      +
      public static String parseMasterServerName(String rsZnodePath)
      +
      See HBASE-14861. We are extracting master ServerName from rsZnodePath + example: "/hbase/rs/server.example.com,16020,1448266496481"
      +
      Parameters:
      rsZnodePath - from HBASE_ZNODE_FILE
      +
      Returns:
      String representation of ServerName or null if fails
      +
    • +
    + + + +
      +
    • +

      tablesOnMaster

      +
      private static boolean tablesOnMaster(org.apache.hadoop.conf.Configuration conf)
      +
      Returns:
      true if cluster is configured with master-rs collocation
      +
    • +
    • clear

      -
      public static boolean clear(org.apache.hadoop.conf.Configuration conf)
      +
      public static boolean clear(org.apache.hadoop.conf.Configuration conf)
      Delete the master znode if its content (ServerName string) is the same - as the one in the znode file. (env: HBASE_ZNODE_FILE).
      + as the one in the znode file. (env: HBASE_ZNODE_FILE). I case of master-rs + colloaction we extract ServerName string from rsZnode path.(HBASE-14861)
      Returns:
      true on successful deletion, false otherwise.
    http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceStability.Unstable.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceStability.Unstable.html b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceStability.Unstable.html index 0e68d71..c86084e 100644 --- a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceStability.Unstable.html +++ b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceStability.Unstable.html @@ -136,19 +136,19 @@ -org.apache.hadoop.hbase.http.lib +org.apache.hadoop.hbase.http
    - This package provides user-selectable (via configuration) classes that add - functionality to the web UI.
    + Copied from hadoop source code.
    + See https://issues.apache.org/jira/browse/HADOOP-10232 to know why. -org.apache.hadoop.hbase.http +org.apache.hadoop.hbase.http.lib
    - Copied from hadoop source code.
    - See https://issues.apache.org/jira/browse/HADOOP-10232 to know why.
    + This package provides user-selectable (via configuration) classes that add + functionality to the web UI. http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/classification/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/classification/package-tree.html b/devapidocs/org/apache/hadoop/hbase/classification/package-tree.html index da8cca8..b7f9699 100644 --- a/devapidocs/org/apache/hadoop/hbase/classification/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/classification/package-tree.html @@ -80,12 +80,12 @@

    Annotation Type Hierarchy

    http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/client/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/package-tree.html b/devapidocs/org/apache/hadoop/hbase/client/package-tree.html index b5e6aa1..d54b926 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/client/package-tree.html @@ -388,12 +388,12 @@ http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html b/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html index 87a52ea..106f48f 100644 --- a/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html @@ -161,13 +161,13 @@
  • @@ -327,7 +327,7 @@ extends
  • BoundedByteBufferPool

    -
    public BoundedByteBufferPool(int maxByteBufferSizeToCache,
    +
    public BoundedByteBufferPool(int maxByteBufferSizeToCache,
                          int initialByteBufferSize,
                          int maxToCache)
    Parameters:
    maxByteBufferSizeToCache -
    initialByteBufferSize -
    maxToCache -
    @@ -365,7 +365,7 @@ extends
  • toCountOfBuffers

    -
    private static int toCountOfBuffers(long state)
    +
    static int toCountOfBuffers(long state)
  • @@ -374,7 +374,7 @@ extends
  • toTotalCapacity

    -
    private static int toTotalCapacity(long state)
    +
    static int toTotalCapacity(long state)
  • @@ -383,7 +383,7 @@ extends
  • toState

    -
    private static long toState(int countOfBuffers,
    +
    static long toState(int countOfBuffers,
                int totalCapacity)
  • @@ -393,7 +393,7 @@ extends
  • subtractOneBufferFromState

    -
    private static long subtractOneBufferFromState(long state,
    +
    static long subtractOneBufferFromState(long state,
                                   int capacity)
  • @@ -403,7 +403,7 @@ extends
  • getBuffer

    -
    public ByteBuffer getBuffer()
    +
    public ByteBuffer getBuffer()
  • @@ -412,7 +412,7 @@ extends
  • putBuffer

    -
    public void putBuffer(ByteBuffer bb)
    +
    public void putBuffer(ByteBuffer bb)
  • http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html index 7d659b5..ed83b5c 100644 --- a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html @@ -291,11 +291,11 @@
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
  • http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/mapreduce/TableMapReduceUtil.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableMapReduceUtil.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableMapReduceUtil.html index c22e1ac..8fd8ed7 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableMapReduceUtil.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableMapReduceUtil.html @@ -847,7 +847,7 @@ extends
  • initCredentialsForCluster

    -
    public static void initCredentialsForCluster(org.apache.hadoop.mapreduce.Job job,
    +
    public static void initCredentialsForCluster(org.apache.hadoop.mapreduce.Job job,
                                  String quorumAddress)
                                           throws IOException
    Obtain an authentication token, for the specified cluster, on behalf of the current user @@ -867,7 +867,7 @@ extends
  • convertScanToString

    -
    static String convertScanToString(Scan scan)
    +
    static String convertScanToString(Scan scan)
                                throws IOException
    Writes the given scan into a Base64 encoded string.
    Parameters:
    scan - The scan to write out.
    @@ -882,7 +882,7 @@ extends
  • convertStringToScan

    -
    static Scan convertStringToScan(String base64)
    +
    static Scan convertStringToScan(String base64)
                              throws IOException
    Converts the given Base64 string back into a Scan instance.
    Parameters:
    base64 - The scan details.
    @@ -897,7 +897,7 @@ extends
  • initTableReducerJob

    -
    public static void initTableReducerJob(String table,
    +
    public static void initTableReducerJob(String table,
                            Class<? extends TableReducer> reducer,
                            org.apache.hadoop.mapreduce.Job job)
                                     throws IOException
    @@ -914,7 +914,7 @@ extends
  • initTableReducerJob

    -
    public static void initTableReducerJob(String table,
    +
    public static void initTableReducerJob(String table,
                            Class<? extends TableReducer> reducer,
                            org.apache.hadoop.mapreduce.Job job,
                            Class partitioner)
    @@ -933,7 +933,7 @@ extends 
     
  • initTableReducerJob

    -
    public static void initTableReducerJob(String table,
    +
    public static void initTableReducerJob(String table,
                            Class<? extends TableReducer> reducer,
                            org.apache.hadoop.mapreduce.Job job,
                            Class partitioner,
    @@ -965,7 +965,7 @@ extends 
     
  • initTableReducerJob

    -
    public static void initTableReducerJob(String table,
    +
    public static void initTableReducerJob(String table,
                            Class<? extends TableReducer> reducer,
                            org.apache.hadoop.mapreduce.Job job,
                            Class partitioner,
    @@ -999,7 +999,7 @@ extends 
     
  • limitNumReduceTasks

    -
    public static void limitNumReduceTasks(String table,
    +
    public static void limitNumReduceTasks(String table,
                            org.apache.hadoop.mapreduce.Job job)
                                     throws IOException
    Ensures that the given number of reduce tasks for the given job @@ -1015,7 +1015,7 @@ extends
  • setNumReduceTasks

    -
    public static void setNumReduceTasks(String table,
    +
    public static void setNumReduceTasks(String table,
                          org.apache.hadoop.mapreduce.Job job)
                                   throws IOException
    Sets the number of reduce tasks for the given job configuration to the @@ -1031,7 +1031,7 @@ extends
  • setScannerCaching

    -
    public static void setScannerCaching(org.apache.hadoop.mapreduce.Job job,
    +
    public static void setScannerCaching(org.apache.hadoop.mapreduce.Job job,
                          int batchSize)
    Sets the number of rows to return and cache with each scanner iteration. Higher caching values will enable faster mapreduce jobs at the expense of @@ -1046,7 +1046,7 @@ extends
  • addHBaseDependencyJars

    -
    public static void addHBaseDependencyJars(org.apache.hadoop.conf.Configuration conf)
    +
    public static void addHBaseDependencyJars(org.apache.hadoop.conf.Configuration conf)
                                        throws IOException
    Add HBase and its dependencies (only) to the job configuration.

    @@ -1067,7 +1067,7 @@ extends

  • buildDependencyClasspath

    -
    public static String buildDependencyClasspath(org.apache.hadoop.conf.Configuration conf)
    +
    public static String buildDependencyClasspath(org.apache.hadoop.conf.Configuration conf)
    Returns a classpath string built from the content of the "tmpjars" value in conf. Also exposed to shell scripts via `bin/hbase mapredcp`.
  • @@ -1078,7 +1078,7 @@ extends
  • addDependencyJars

    -
    public static void addDependencyJars(org.apache.hadoop.mapreduce.Job job)
    +
    public static void addDependencyJars(org.apache.hadoop.mapreduce.Job job)
                                   throws IOException
    Add the HBase dependency jars as well as jars for any of the configured job classes to the job configuration, so that JobClient will ship them @@ -1093,7 +1093,7 @@ extends
  • addDependencyJars

    -
    public static void addDependencyJars(org.apache.hadoop.conf.Configuration conf,
    +
    public static void addDependencyJars(org.apache.hadoop.conf.Configuration conf,
                          Class<?>... classes)
                                   throws IOException
    Add the jars containing the given classes to the job's configuration @@ -1109,7 +1109,7 @@ extends
  • findOrCreateJar

    -
    private static org.apache.hadoop.fs.Path findOrCreateJar(Class<?> my_class,
    +
    private static org.apache.hadoop.fs.Path findOrCreateJar(Class<?> my_class,
                                             org.apache.hadoop.fs.FileSystem fs,
                                             Map<String,String> packagedClasses)
                                                       throws IOException
    @@ -1131,7 +1131,7 @@ extends
  • updateMap

    -
    private static void updateMap(String jar,
    +
    private static void updateMap(String jar,
                  Map<String,String> packagedClasses)
                            throws IOException
    Add entries to packagedClasses corresponding to class files @@ -1147,7 +1147,7 @@ extends
  • findContainingJar

    -
    private static String findContainingJar(Class<?> my_class,
    +
    private static String findContainingJar(Class<?> my_class,
                            Map<String,String> packagedClasses)
                                      throws IOException
    Find a jar that contains a class of the same name, if any. It will return @@ -1166,7 +1166,7 @@ extends
  • getJar

    -
    private static String getJar(Class<?> my_class)
    +
    private static String getJar(Class<?> my_class)
    Invoke 'getJar' on a custom JarFinder implementation. Useful for some job configuration contexts (HBASE-8140) and also for testing on MRv2. check if we have HADOOP-9426.
    http://git-wip-us.apache.org/repos/asf/hbase/blob/a986dfe6/devapidocs/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.TableRecordWriter.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.TableRecordWriter.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.TableRecordWriter.html index 38c54bf..f6a6459 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.TableRecordWriter.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.TableRecordWriter.html @@ -104,7 +104,7 @@


  • -
    protected class TableOutputFormat.TableRecordWriter
    +
    protected class TableOutputFormat.TableRecordWriter
     extends org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation>
    Writes the reducer output to an HBase table.
  • @@ -206,7 +206,7 @@ extends org.apache.hadoop.mapreduce.RecordWriter<KEY,
  • connection

    -
    private Connection connection
    +
    private Connection connection
  • @@ -215,7 +215,7 @@ extends org.apache.hadoop.mapreduce.RecordWriter<KEY,
  • mutator

    -
    private BufferedMutator mutator
    +
    private BufferedMutator mutator
  • @@ -232,7 +232,7 @@ extends org.apache.hadoop.mapreduce.RecordWriter<KEY,
  • TableOutputFormat.TableRecordWriter

    -
    public TableOutputFormat.TableRecordWriter()
    +
    public TableOutputFormat.TableRecordWriter()
                                         throws IOException
    Throws:
    IOException
    @@ -252,7 +252,7 @@ extends org.apache.hadoop.mapreduce.RecordWriter<KEY,
  • close

    -
    public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
    +
    public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException
    Closes the writer, in this case flush table commits.
    @@ -271,7 +271,7 @@ extends org.apache.hadoop.mapreduce.RecordWriter<KEY,
  • write

    -
    public void write(KEY key,
    +
    public void write(KEY key,
              Mutation value)
                throws IOException
    Writes a key/value pair into the table.