From user-return-1566-archive-asf-public=cust-asf.ponee.io@kudu.apache.org Fri Dec 28 15:13:25 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 51CE6180652 for ; Fri, 28 Dec 2018 15:13:25 +0100 (CET) Received: (qmail 40909 invoked by uid 500); 28 Dec 2018 14:13:24 -0000 Mailing-List: contact user-help@kudu.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@kudu.apache.org Delivered-To: mailing list user@kudu.apache.org Received: (qmail 40898 invoked by uid 99); 28 Dec 2018 14:13:23 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 28 Dec 2018 14:13:23 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 593CCC2512 for ; Fri, 28 Dec 2018 14:13:23 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.099 X-Spam-Level: * X-Spam-Status: No, score=1.099 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=boristyukin.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id YNkxKQv7COGU for ; Fri, 28 Dec 2018 14:13:21 +0000 (UTC) Received: from mx26-out30.antispamcloud.com (mx26-out30.antispamcloud.com [148.251.71.30]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 4741A5FDE4 for ; Fri, 28 Dec 2018 14:13:21 +0000 (UTC) Received: from s2.fcomet.com ([99.198.101.250]) by mx114.antispamcloud.com with esmtps (TLSv1.2:ECDHE-RSA-AES256-GCM-SHA384:256) (Exim 4.89) (envelope-from ) id 1gcssz-000bXR-0Z for user@kudu.apache.org; Fri, 28 Dec 2018 15:13:14 +0100 DKIM-Signature: v=1; a=rsa-sha256; q=dns/txt; c=relaxed/relaxed; d=boristyukin.com; s=default; h=Content-Type:To:Subject:Message-ID:Date:From: MIME-Version:Sender:Reply-To:Cc:Content-Transfer-Encoding:Content-ID: Content-Description:Resent-Date:Resent-From:Resent-Sender:Resent-To:Resent-Cc :Resent-Message-ID:In-Reply-To:References:List-Id:List-Help:List-Unsubscribe: List-Subscribe:List-Post:List-Owner:List-Archive; bh=BEXBEhNVvJWnuELpH9B6o1uWPBWBdxJm/z1wxXKA6UE=; b=X/cloIi1OdA8RnKmP4eQdyR2NX 7QWxG/NgPGqKuC7ZjYKkhP4UVLoVgLdi5SjsyIl0q7YFnhNz0w+mW/zLo+Akr2qBZR8s9xZCikSFL xADiy7i7krUTz7Ew5U4YgFkwm1SgCnzOYqUUWEfpkM+oJHbrs+fTpoBNvZ1VBn2h9Pc8=; Received: from mail-io1-f43.google.com ([209.85.166.43]:45914) by s2.fcomet.com with esmtpsa (TLSv1.2:ECDHE-RSA-AES128-GCM-SHA256:128) (Exim 4.91) (envelope-from ) id 1gcssG-00CmHw-L1 for user@kudu.apache.org; Fri, 28 Dec 2018 08:12:28 -0600 Received: by mail-io1-f43.google.com with SMTP id p7so5959315iog.12 for ; Fri, 28 Dec 2018 06:12:29 -0800 (PST) X-Gm-Message-State: AJcUukdnbbJEUpVGD2oZdrR9b2c+QGu7SDzx8d4oOt0OoJdnFAO5JQ4j pB/LyN7FoFvLlWeUaUfJ4vLCWwdkoAaZy/ZgrLA= X-Google-Smtp-Source: ALg8bN7ZmFGi7J0qOb9O4srrt0U+xxpmDKWJ9PyUs8Vwv26CTg09aDodlGemOMad/Y0o+7FmRwWVWTAVO3ck6GQZ8xY= X-Received: by 2002:a6b:700a:: with SMTP id l10mr10796643ioc.138.1546006348755; Fri, 28 Dec 2018 06:12:28 -0800 (PST) MIME-Version: 1.0 From: Boris Tyukin Date: Fri, 28 Dec 2018 09:11:52 -0500 X-Gmail-Original-Message-ID: Message-ID: Subject: getRowErrors and operation type (insert, delete or update) To: user@kudu.apache.org Content-Type: multipart/alternative; boundary="0000000000003cfc14057e15a7be" X-AuthUser: boris@boristyukin.com X-Originating-IP: 99.198.101.250 X-Spampanel-Domain: s2.fcomet.com X-Spampanel-Username: 99.198.101.250 Authentication-Results: antispamcloud.com; auth=pass smtp.auth=99.198.101.250@s2.fcomet.com X-Spampanel-Outgoing-Class: unsure X-Spampanel-Outgoing-Evidence: Combined (0.27) X-Recommended-Action: accept X-Filter-ID: EX5BVjFpneJeBchSMxfU5qwuxxp2RaS0OF8EFpFQwL1602E9L7XzfQH6nu9C/Fh9KJzpNe6xgvOx q3u0UDjvO2HFEYQDlNqPthodLGs7Ym7sT+bYMn6GaM87VISxooGy6OxPABUn2J3dXRdJfW8jflpr jQPFk8m4tSTfORUp3ynEm+h0A2koB3qKN5bbUQlCA6/f1y/ezRoz5LzSoT+Zg5FVgpT1b21uZVck Gp0ccOYNj3IsPxUoOvqBoVWc32LibjGdSRNeAsqwADJIlioxB+Ri1Gwjhmdwj/RC7BTJQIETmEFB zGJ4I3iI+cUBLpxHZqMsFXHkY4b0tMjYHlbEsQ6yCIj+j+sW7DnHSTh9wIB9qzbFFetd0V4Svjqc FPolF8VpymDAm51vSeaku+X2qYfWdHzoB2yW92yX6zvRr8FsMyewd83qhRHUN79OaH7QZM3NuHht 4ah3jKpVe9Q5dQwPf1ekvTsJu+noz87G5EthgB37cSRdX+S8eSGMVvuOehIqUczFWeS6sE8e1b5/ UuG84yBZdFDsZzjqLz0+lM222LguP7WfBgKuNZ2csj5fEeOg1qaUe4k87jVqu3S08X2YhUFzumr4 /Rrao7gWEyo8UhGPaG7CdVktbtorlELc/UrFmK5wYa/eXfUwTQnr3wRidxm0V+KLdcupr3oUEcbj EWTqls501mLJw8/+/dTbuP0iZyxhueMNLK8wwrVwuCuOyNB4uEc7/ajN+tIWCqpIFkEZMXDu4jGe TB79fDtxbgiN4/KqCaA5uqjWFBGMmcESgE2ZGg51fM4+j3QAvRErOkZQ0gdEYNW3+3t4PP++647l NwN4qOsSZg+fYhVZG8V5YtbNPlagNs3+OO4fHCXmcNMYrgEyPifyrwrvAF3mj8dzHQPLO1WC2ToG 4+imXZFVgpT1b21uZVckGp0ccOZ0u747HEjxBT3YXFq5jdQhizABe0DPoZtQcTLoONusdG+U8T3K fj7tHuHDvXqVSlU= X-Report-Abuse-To: spam@quarantine1.antispamcloud.com --0000000000003cfc14057e15a7be Content-Type: text/plain; charset="UTF-8" Hi guys, I need to write some custom logic to handle Kudu exceptions in AUTO_FLUSH_BACKGROUND mode and I can get what I need from session.getPendingErrors().getRowErrors() except operation type (insert, delete or update). getRowErrors returns an array of RowError https://kudu.apache.org/apidocs/org/apache/kudu/client/RowError.html I can get error status code and error message, but I also need to know operation type. There is RowError.getOperation() method that returns Operation and I can also get PartialRow from Operation but I still cannot figure out how to get operation type on that row. Is it possible? Thanks and a Happy New Year! Boris --0000000000003cfc14057e15a7be Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi guys= ,

I need to write some custom logic to handle Kudu e= xceptions in AUTO_FLUSH_BACKGROUND mode and I can get what I need from sess= ion.getPendingErrors().getRowErrors() except operation type (insert, delete= or update).

getRowErrors returns an array of RowE= rror

I can get error status code and = error message, but I also need to know operation type. There is RowError.ge= tOperation() method that returns Operation and I can also get PartialRow fr= om Operation but I still cannot figure out how to get operation type on tha= t row.

Is it possible?

Thanks and a Happy New Year!
Boris<= /div>
--0000000000003cfc14057e15a7be--