Mailing-List: contact dev-help@phoenix.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@phoenix.apache.org
MIME-Version: 1.0
In-Reply-To: <CAFGo-hyByFEyRDfbacwvMkts9O3mQwq8PK6x5uMg+8oUJL-e-w@mail.gmail.com>
References: <CAFGo-hyByFEyRDfbacwvMkts9O3mQwq8PK6x5uMg+8oUJL-e-w@mail.gmail.com>
From: Tulasi Paradarami <tulasi.krishna.p@gmail.com>
Date: Thu, 19 Jan 2017 16:33:11 -0800
Message-ID: <CAFGo-hx=jtdguxR4DduR-AgFJ=+vK_5MHevu1qgOQf2mES_qrg@mail.gmail.com>
Subject: Re: Timeline consistency using PQS
To: user@phoenix.apache.org, dev@phoenix.apache.org
Content-Type: multipart/alternative; boundary=001a1147b9046efcee05467bcb22
archived-at: Fri, 20 Jan 2017 00:33:19 -0000

--001a1147b9046efcee05467bcb22
Content-Type: text/plain; charset=UTF-8

Could someone clarify how this property is used by Phoenix:
phoenix.connection.consistency
If I set it in hbase-site.xml, does phoenix utilize it for every query
(even queries from PQS)?

It's not documented on the website but it's defined in QueryServices.java:
// consistency configuration setting
public static final String CONSISTENCY_ATTRIB =
"phoenix.connection.consistency";

And used in PhoenixConnection.java
this.consistency = JDBCUtil.getConsistencyLevel(url, this.info,
this.services.getProps().get("phoenix.connection.consistency",
QueryServicesOptions.DEFAULT_CONSISTENCY_LEVEL));


On Thu, Jan 19, 2017 at 2:35 PM, Tulasi Paradarami <
tulasi.krishna.p@gmail.com> wrote:

> Hi,
>
> Does PQS support HBase's timeline consistency (HBASE-10070)?
>
> Looking at the connection properties implementation within Avatica, I see
> that following are defined: ["transactionIsolation", "schema", "readOnly",
> "dirty", "autoCommit", "catalog"] but there's isn't a property defined for
> setting consistency.
>
> org.apache.calcite.avatica.ConnectionPropertiesImpl.java:
>   @JsonCreator
>   public ConnectionPropertiesImpl(
>       @JsonProperty("autoCommit") Boolean autoCommit,
>       @JsonProperty("readOnly") Boolean readOnly,
>       @JsonProperty("transactionIsolation") Integer transactionIsolation,
>       @JsonProperty("catalog") String catalog,
>       @JsonProperty("schema") String schema) {
>     this.autoCommit = autoCommit;
>     this.readOnly = readOnly;
>     this.transactionIsolation = transactionIsolation;
>     this.catalog = catalog;
>     this.schema = schema;
>   }
>
>

--001a1147b9046efcee05467bcb22--