Return-Path: X-Original-To: apmail-kudu-commits-archive@minotaur.apache.org Delivered-To: apmail-kudu-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6DC11196E0 for ; Mon, 11 Apr 2016 16:28:20 +0000 (UTC) Received: (qmail 58547 invoked by uid 500); 11 Apr 2016 16:28:20 -0000 Delivered-To: apmail-kudu-commits-archive@kudu.apache.org Received: (qmail 58503 invoked by uid 500); 11 Apr 2016 16:28:20 -0000 Mailing-List: contact commits-help@kudu.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kudu.incubator.apache.org Delivered-To: mailing list commits@kudu.incubator.apache.org Received: (qmail 58490 invoked by uid 99); 11 Apr 2016 16:28:20 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Apr 2016 16:28:20 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id B094B180220 for ; Mon, 11 Apr 2016 16:28:19 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -3.221 X-Spam-Level: X-Spam-Status: No, score=-3.221 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.001] autolearn=disabled Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id jVushbnKvQaC for ; Mon, 11 Apr 2016 16:28:10 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with SMTP id 626F35FBA6 for ; Mon, 11 Apr 2016 16:28:08 +0000 (UTC) Received: (qmail 58187 invoked by uid 99); 11 Apr 2016 16:28:07 -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; Mon, 11 Apr 2016 16:28:07 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 26D7DDFAB5; Mon, 11 Apr 2016 16:28:07 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jdcryans@apache.org To: commits@kudu.incubator.apache.org Date: Mon, 11 Apr 2016 16:28:28 -0000 Message-Id: <29d4b48614384dca9ba9747d1d850b7f@git.apache.org> In-Reply-To: <06beda7c146b4609825ea8c470edd03e@git.apache.org> References: <06beda7c146b4609825ea8c470edd03e@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [23/45] incubator-kudu git commit: Add 0.8.0 docs http://git-wip-us.apache.org/repos/asf/incubator-kudu/blob/c78a2f80/releases/0.8.0/apidocs/org/kududb/client/RowResultIterator.html ---------------------------------------------------------------------- diff --git a/releases/0.8.0/apidocs/org/kududb/client/RowResultIterator.html b/releases/0.8.0/apidocs/org/kududb/client/RowResultIterator.html new file mode 100644 index 0000000..1c124c2 --- /dev/null +++ b/releases/0.8.0/apidocs/org/kududb/client/RowResultIterator.html @@ -0,0 +1,357 @@ + + + + + +RowResultIterator (Kudu 0.8.0 API) + + + + + + + + + + +
+
org.kududb.client
+

Class RowResultIterator

+
+
+ +
+
    +
  • +
    +
    All Implemented Interfaces:
    +
    Iterable<RowResult>, Iterator<RowResult>
    +
    +
    +
    +
    @InterfaceAudience.Public
    +@InterfaceStability.Evolving
    +public class RowResultIterator
    +extends Object
    +implements Iterator<RowResult>, Iterable<RowResult>
    +
    Class that contains the rows sent by a tablet server, exhausting this iterator only means + that all the rows from the last server response were read.
    +
  • +
+
+
+ +
+
+
    +
  • + +
      +
    • + + +

      Method Detail

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

        getNumRows

        +
        public int getNumRows()
        +
        Get the number of rows in this iterator. If all you want is to count + rows, call this and skip the rest.
        +
        Returns:
        number of rows in this iterator
        +
      • +
      + + + + + + + + + + + +
        +
      • +

        getElapsedMillis

        +
        public long getElapsedMillis()
        +
        Get the number of milliseconds elapsed since the RPC was created up to the moment when this + response was created.
        +
        Returns:
        Elapsed time in milliseconds.
        +
      • +
      + + + +
        +
      • +

        getTsUUID

        +
        public String getTsUUID()
        +
        Get the identifier of the tablet server that sent the response.
        +
        Returns:
        A string containing a UUID.
        +
      • +
      +
    • +
    +
  • +
+
+
+ + + + + +

Copyright © 2016. All rights reserved.

+ + http://git-wip-us.apache.org/repos/asf/incubator-kudu/blob/c78a2f80/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.FlushMode.html ---------------------------------------------------------------------- diff --git a/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.FlushMode.html b/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.FlushMode.html new file mode 100644 index 0000000..3c3af4d --- /dev/null +++ b/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.FlushMode.html @@ -0,0 +1,337 @@ + + + + + +SessionConfiguration.FlushMode (Kudu 0.8.0 API) + + + + + + + + + + +
+
org.kududb.client
+

Enum SessionConfiguration.FlushMode

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

      Method Detail

      + + + +
        +
      • +

        values

        +
        public static SessionConfiguration.FlushMode[] values()
        +
        Returns an array containing the constants of this enum type, in +the order they are declared. This method may be used to iterate +over the constants as follows: +
        +for (SessionConfiguration.FlushMode c : SessionConfiguration.FlushMode.values())
        +    System.out.println(c);
        +
        +
        Returns:
        an array containing the constants of this enum type, in the order they are declared
        +
      • +
      + + + +
        +
      • +

        valueOf

        +
        public static SessionConfiguration.FlushMode valueOf(String name)
        +
        Returns the enum constant of this type with the specified name. +The string must match exactly an identifier used to declare an +enum constant in this type. (Extraneous whitespace characters are +not permitted.)
        +
        Parameters:
        name - the name of the enum constant to be returned.
        +
        Returns:
        the enum constant with the specified name
        +
        Throws:
        +
        IllegalArgumentException - if this enum type has no constant with the specified name
        +
        NullPointerException - if the argument is null
        +
      • +
      +
    • +
    +
  • +
+
+
+ + + + + +

Copyright © 2016. All rights reserved.

+ + http://git-wip-us.apache.org/repos/asf/incubator-kudu/blob/c78a2f80/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.html ---------------------------------------------------------------------- diff --git a/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.html b/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.html new file mode 100644 index 0000000..93c9242 --- /dev/null +++ b/releases/0.8.0/apidocs/org/kududb/client/SessionConfiguration.html @@ -0,0 +1,481 @@ + + + + + +SessionConfiguration (Kudu 0.8.0 API) + + + + + + + + + + +
+
org.kududb.client
+

Interface SessionConfiguration

+
+
+
+
    +
  • +
    +
    All Known Implementing Classes:
    +
    AsyncKuduSession, KuduSession
    +
    +
    +
    +
    @InterfaceAudience.Public
    +@InterfaceStability.Evolving
    +public interface SessionConfiguration
    +
    Interface that defines the methods used to configure a session. It also exposes ways to + query its state.
    +
  • +
+
+
+ +
+
+
    +
  • + +
      +
    • + + +

      Method Detail

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

        setMutationBufferSpace

        +
        void setMutationBufferSpace(int size)
        +
        Set the number of operations that can be buffered.
        +
        Parameters:
        size - number of ops.
        +
        Throws:
        +
        IllegalArgumentException - if the buffer isn't empty.
        +
      • +
      + + + +
        +
      • +

        setMutationBufferLowWatermark

        +
        void setMutationBufferLowWatermark(float mutationBufferLowWatermarkPercentage)
        +
        Set the low watermark for this session. The default is set to half the mutation buffer space. + For example, a buffer space of 1000 with a low watermark set to 50% (0.5) will start randomly + sending PleaseRetryExceptions once there's an outstanding flush and the buffer is over 500. + As the buffer gets fuller, it becomes likelier to hit the exception.
        +
        Parameters:
        mutationBufferLowWatermarkPercentage - a new low watermark as a percentage, + has to be between 0 and 1 (inclusive). A value of 1 disables + the low watermark since it's the same as the high one
        +
        Throws:
        +
        IllegalArgumentException - if the buffer isn't empty or if the watermark isn't between + 0 and 1
        +
      • +
      + + + +
        +
      • +

        setFlushInterval

        +
        void setFlushInterval(int interval)
        +
        Set the flush interval, which will be used for the next scheduling decision.
        +
        Parameters:
        interval - interval in milliseconds.
        +
      • +
      + + + +
        +
      • +

        getTimeoutMillis

        +
        long getTimeoutMillis()
        +
        Get the current timeout.
        +
        Returns:
        operation timeout in milliseconds, 0 if none was configured.
        +
      • +
      + + + +
        +
      • +

        setTimeoutMillis

        +
        void setTimeoutMillis(long timeout)
        +
        Sets the timeout for the next applied operations. + The default timeout is 0, which disables the timeout functionality.
        +
        Parameters:
        timeout - Timeout in milliseconds.
        +
      • +
      + + + +
        +
      • +

        isClosed

        +
        boolean isClosed()
        +
        Returns true if this session has already been closed.
        +
      • +
      + + + +
        +
      • +

        hasPendingOperations

        +
        boolean hasPendingOperations()
        +
        Check if there are operations that haven't been completely applied.
        +
        Returns:
        true if operations are pending, else false.
        +
      • +
      + + + +
        +
      • +

        setExternalConsistencyMode

        +
        void setExternalConsistencyMode(ExternalConsistencyMode consistencyMode)
        +
        Set the new external consistency mode for this session.
        +
        Parameters:
        consistencyMode - new external consistency mode, can the same as the previous one.
        +
        Throws:
        +
        IllegalArgumentException - if the buffer isn't empty.
        +
      • +
      + + + +
        +
      • +

        isIgnoreAllDuplicateRows

        +
        boolean isIgnoreAllDuplicateRows()
        +
        Tells if the session is currently ignoring row errors when the whole list returned by a tablet + server is of the AlreadyPresent type.
        +
        Returns:
        true if the session is enforcing this, else false
        +
      • +
      + + + +
        +
      • +

        setIgnoreAllDuplicateRows

        +
        void setIgnoreAllDuplicateRows(boolean ignoreAllDuplicateRows)
        +
        Configures the option to ignore all the row errors if they are all of the AlreadyPresent type. + This can be needed when facing KUDU-568. The effect of enabling this is that operation + responses that match this pattern will be cleared of their row errors, meaning that we consider + them successful. + This is disabled by default.
        +
        Parameters:
        ignoreAllDuplicateRows - true if this session should enforce this, else false
        +
      • +
      + + + +
        +
      • +

        countPendingErrors

        +
        int countPendingErrors()
        +
        Return the number of errors which are pending. Errors may accumulate when + using the AUTO_FLUSH_BACKGROUND mode.
        +
        Returns:
        a count of errors
        +
      • +
      + + + +
        +
      • +

        getPendingErrors

        +
        RowErrorsAndOverflowStatus getPendingErrors()
        +
        Return any errors from previous calls. If there were more errors + than could be held in the session's error storage, the overflow state is set to true. + Resets the pending errors.
        +
        Returns:
        an object that contains the errors and the overflow status
        +
      • +
      +
    • +
    +
  • +
+
+
+ + + + + +

Copyright © 2016. All rights reserved.

+ +