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 3A5C018A34 for ; Fri, 5 Feb 2016 04:32:22 +0000 (UTC) Received: (qmail 88659 invoked by uid 500); 5 Feb 2016 04:32:20 -0000 Delivered-To: apmail-hbase-commits-archive@hbase.apache.org Received: (qmail 87625 invoked by uid 500); 5 Feb 2016 04:32:18 -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 81734 invoked by uid 99); 5 Feb 2016 04:32:12 -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; Fri, 05 Feb 2016 04:32:12 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 8BBE8E1083; Fri, 5 Feb 2016 04:32:12 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: misty@apache.org To: commits@hbase.apache.org Date: Fri, 05 Feb 2016 04:32:58 -0000 Message-Id: <40314e6666ac4112af3702f803b625b2@git.apache.org> In-Reply-To: <49df44bf87274c6ca4833f867e09c715@git.apache.org> References: <49df44bf87274c6ca4833f867e09c715@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [48/51] [partial] hbase-site git commit: Published site at 18eff3c1c337003b2a419490e621f931d16936fb. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a8725a46/devapidocs/org/apache/hadoop/hbase/io/ByteBufferInputStream.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/io/ByteBufferInputStream.html b/devapidocs/org/apache/hadoop/hbase/io/ByteBufferInputStream.html new file mode 100644 index 0000000..7d3cf83 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/io/ByteBufferInputStream.html @@ -0,0 +1,390 @@ + + + + + +ByteBufferInputStream (Apache HBase 2.0.0-SNAPSHOT API) + + + + + + + + + + +
+
org.apache.hadoop.hbase.io
+

Class ByteBufferInputStream

+
+
+ +
+ +
+
+ +
+
+
    +
  • + + + + + +
      +
    • + + +

      Method Detail

      + + + +
        +
      • +

        read

        +
        public int read()
        +
        Reads the next byte of data from this input stream. The value byte is returned as an + int in the range 0 to 255. If no byte is available + because the end of the stream has been reached, the value -1 is returned.
        +
        +
        Specified by:
        +
        read in class InputStream
        +
        Returns:
        the next byte of data, or -1 if the end of the stream has been reached.
        +
      • +
      + + + +
        +
      • +

        read

        +
        public int read(byte[] b,
        +       int off,
        +       int len)
        +
        Reads up to next len bytes of data from buffer into passed array(starting from + given offset).
        +
        +
        Overrides:
        +
        read in class InputStream
        +
        Parameters:
        b - the array into which the data is read.
        off - the start offset in the destination array b
        len - the maximum number of bytes to read.
        +
        Returns:
        the total number of bytes actually read into the buffer, or -1 if not even + 1 byte can be read because the end of the stream has been reached.
        +
      • +
      + + + +
        +
      • +

        skip

        +
        public long skip(long n)
        +
        Skips n bytes of input from this input stream. Fewer bytes might be skipped if the + end of the input stream is reached. The actual number k of bytes to be skipped is + equal to the smaller of n and remaining bytes in the stream.
        +
        +
        Overrides:
        +
        skip in class InputStream
        +
        Parameters:
        n - the number of bytes to be skipped.
        +
        Returns:
        the actual number of bytes skipped.
        +
      • +
      + + + +
        +
      • +

        available

        +
        public int available()
        +
        +
        Overrides:
        +
        available in class InputStream
        +
        Returns:
        the number of remaining bytes that can be read (or skipped + over) from this input stream.
        +
      • +
      +
    • +
    +
  • +
+
+
+ + + + + +

Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.

+ + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a8725a46/devapidocs/org/apache/hadoop/hbase/io/ByteBufferOutputStream.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/io/ByteBufferOutputStream.html b/devapidocs/org/apache/hadoop/hbase/io/ByteBufferOutputStream.html index 16aedcf..e915ce2 100644 --- a/devapidocs/org/apache/hadoop/hbase/io/ByteBufferOutputStream.html +++ b/devapidocs/org/apache/hadoop/hbase/io/ByteBufferOutputStream.html @@ -35,7 +35,7 @@ + +static int +PRIORITY_UNSET  + @@ -341,7 +355,7 @@ implements
  • setPriority

    -
    public void setPriority(int priority)
    +
    public void setPriority(int priority)
    Parameters:
    priority - Priority for this request; should fall roughly in the range HConstants.NORMAL_QOS to HConstants.HIGH_QOS
  • @@ -352,7 +366,7 @@ implements
  • setPriority

    -
    public void setPriority(TableName tn)
    +
    public void setPriority(TableName tn)
    Parameters:
    tn - Set priority based off the table we are going against.
  • @@ -362,7 +376,7 @@ implements
  • getPriority

    -
    public int getPriority()
    +
    public int getPriority()
    Returns:
    The priority of this request
  • @@ -372,7 +386,7 @@ implements
  • reset

    -
    public void reset()
    +
    public void reset()
    Specified by:
    reset in interface com.google.protobuf.RpcController
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a8725a46/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html index a3cc241..fea565c 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html @@ -874,7 +874,7 @@ extends
  • doNotify

    -
    private void doNotify()
    +
    private void doNotify()
  • @@ -883,7 +883,7 @@ extends
  • readResponse

    -
    protected void readResponse()
    +
    protected void readResponse()
  • @@ -892,7 +892,7 @@ extends
  • isFatalConnectionException

    -
    private boolean isFatalConnectionException(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)
    +
    private boolean isFatalConnectionException(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)
    Returns:
    True if the exception is a fatal connection exception.
  • @@ -902,7 +902,7 @@ extends
  • createRemoteException

    -
    private org.apache.hadoop.ipc.RemoteException createRemoteException(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)
    +
    private org.apache.hadoop.ipc.RemoteException createRemoteException(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)
    Parameters:
    e - exception to be wrapped
    Returns:
    RemoteException made from passed e
  • @@ -913,7 +913,7 @@ extends
  • markClosed

    -
    protected boolean markClosed(IOException e)
    +
    protected boolean markClosed(IOException e)
  • @@ -922,7 +922,7 @@ extends
  • cleanupCalls

    -
    protected void cleanupCalls(boolean allCalls)
    +
    protected void cleanupCalls(boolean allCalls)
    Cleanup the calls older than a given timeout, in milli seconds.
    Parameters:
    allCalls - true for all calls, false for only the calls in timeout
  • http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a8725a46/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.html index 92e9dea..2fb5855 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcClientImpl.html @@ -413,7 +413,7 @@ extends
  • RpcClientImpl

    -
    RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
    +
    RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
                  String clusterId,
                  SocketFactory factory)
    Used in test only. Construct an IPC cluster client whose values are of the @@ -427,7 +427,7 @@ extends
  • RpcClientImpl

    -
    RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
    +
    RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
                  String clusterId,
                  SocketFactory factory,
                  SocketAddress localAddr,
    @@ -442,7 +442,7 @@ extends 
     
  • RpcClientImpl

    -
    RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
    +
    RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
                  String clusterId)
    Used in test only. Construct an IPC client for the cluster clusterId with the default SocketFactory
    @@ -454,7 +454,7 @@ extends
  • RpcClientImpl

    -
    public RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
    +
    public RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
                  String clusterId,
                  SocketAddress localAddr,
                  MetricsConnection metrics)
    @@ -494,7 +494,7 @@ extends
  • close

    -
    public void close()
    +
    public void close()
    Stop all threads related to this client. No further calls may be made using this client.
  • @@ -505,7 +505,7 @@ extends
  • call

    -
    protected Pair<com.google.protobuf.Message,CellScannercall(PayloadCarryingRpcController pcrc,
    +
    protected Pair<com.google.protobuf.Message,CellScannercall(PayloadCarryingRpcController pcrc,
                                                      com.google.protobuf.Descriptors.MethodDescriptor md,
                                                      com.google.protobuf.Message param,
                                                      com.google.protobuf.Message returnType,
    @@ -537,7 +537,7 @@ extends 
     
  • cancelConnections

    -
    public void cancelConnections(ServerName sn)
    +
    public void cancelConnections(ServerName sn)
    Interrupt the connections to the given ip:port server. This should be called if the server is known as actually dead. This will not prevent current operation to be retried, and, depending on their own behavior, they may retry on the same server. This can be a feature, @@ -553,7 +553,7 @@ extends
  • getConnection

    -
    protected RpcClientImpl.Connection getConnection(User ticket,
    +
    protected RpcClientImpl.Connection getConnection(User ticket,
                                          Call call,
                                          InetSocketAddress addr)
                                               throws IOException
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a8725a46/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html index e19c970..b5c3aaa 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html @@ -99,7 +99,7 @@


  • -
    public static class RpcServer.BlockingServiceAndInterface
    +
    public static class RpcServer.BlockingServiceAndInterface
     extends Object
    Datastructure for passing a BlockingService and its associated class of protobuf service interface. For example, a server that fielded what is defined @@ -200,7 +200,7 @@ extends
  • service

    -
    private final com.google.protobuf.BlockingService service
    +
    private final com.google.protobuf.BlockingService service
  • @@ -209,7 +209,7 @@ extends
  • serviceInterface

    -
    private final Class<?> serviceInterface
    +
    private final Class<?> serviceInterface
  • @@ -226,7 +226,7 @@ extends
  • RpcServer.BlockingServiceAndInterface

    -
    public RpcServer.BlockingServiceAndInterface(com.google.protobuf.BlockingService service,
    +
    public RpcServer.BlockingServiceAndInterface(com.google.protobuf.BlockingService service,
                                          Class<?> serviceInterface)
  • @@ -244,7 +244,7 @@ extends
  • getServiceInterface

    -
    public Class<?> getServiceInterface()
    +
    public Class<?> getServiceInterface()
  • @@ -253,7 +253,7 @@ extends
  • getBlockingService

    -
    public com.google.protobuf.BlockingService getBlockingService()
    +
    public com.google.protobuf.BlockingService getBlockingService()