Re: Random outputs for ARRAY_CONCAT_AGG fn zetasql

put data. > > On Tue, Mar 2, 2021 at 3:57 AM Sonam Ramchand < > sonam.ramch...@venturedive.com> wrote: > >> Is there any way I can access the output array resulting from the sql >> query? Then maybe I can sort and compare both *output array* and *expected >>

Re: Random outputs for ARRAY_CONCAT_AGG fn zetasql

it >> should give you an idea for some next steps. >> >> >> On Mon, Mar 1, 2021 at 12:37 AM Sonam Ramchand < >> sonam.ramch...@venturedive.com> wrote: >> >>> Hi Devs, >>> I have implemented the ARRAY_CONCAT_AGG function for ze

Random outputs for ARRAY_CONCAT_AGG fn zetasql

Hi Devs, I have implemented the ARRAY_CONCAT_AGG function for zetasql dialect. I am trying to validate the test as: @Test public void testArrayConcatAggZetasql() { String sql = "SELECT ARRAY_CONCAT_AGG(x) AS array_concat_agg FROM (SELECT [1, 2, 3, 4] AS x UNION ALL SELECT [5, 6] UNION ALL

COVAR_POP aggregate function test for the ZetaSql dialec

Hi Devs, I am trying to test the COVAR_POP aggregate function for the ZetaSql dialect. I see https://github.com/apache/beam/blob/b74fcf7b30d956fb42830d652a57b265a1546973/sdks/[…]he/beam/sdk/extensions/sql/impl/transform/agg/CovarianceFn.java

Need help with the Go Sdk

Hi Devs, For ':sdks:go:resolveBuildDependencies' task, I have been getting: Exception in resolution, message is: Cannot resolve dependency:github.com/ajstarks/deck: commit='LATEST_COMMIT', urls=[https://github.com/ajstarks/deck.git, g...@github.com:ajstarks/deck.git] Resolution stack is: +-

Problem with :sdks:java:container:pullLicenses

Hi All!! For ./gradlew :sdks:java:container:pullLicenses , i have been getting: Process 'command './license_scripts/license_script.sh'' finished with non-zero exit value 1 The issue is closely related to https://issues.apache.org/jira/browse/BEAM-9913. If anyone has an idea about this issue?

Re: "org.apache.kafka:kafka-clients:5.3.2-ccs" dependency issue.

m/apache/beam/pull/12938 > > On Mon, Dec 14, 2020 at 12:24 PM Sonam Ramchand < > sonam.ramch...@venturedive.com> wrote: > >> Please refer to the link to understand the problem better >> https://gradle.com/s/zaqcnvh2uiwga. >> >> Thanks! >> >> On T

Re: "org.apache.kafka:kafka-clients:5.3.2-ccs" dependency issue.

Please refer to the link to understand the problem better https://gradle.com/s/zaqcnvh2uiwga. Thanks! On Tue, Dec 15, 2020 at 1:03 AM Sonam Ramchand < sonam.ramch...@venturedive.com> wrote: > Hi Devs, > I have been getting:Could not resolve all dependencies for c

"org.apache.kafka:kafka-clients:5.3.2-ccs" dependency issue.

Hi Devs, I have been getting:Could not resolve all dependencies for configuration ':sdks:java:container:dockerDependency'. > Could not find org.apache.kafka:kafka-clients:5.3.2-ccs. Searched in the following locations: -

Implementing ARR_AGG

Hi Devs, I have tried to implement the ARR_AGG function for Zetasql dialect by following the STRING_AGG implementation ( https://github.com/apache/beam/pull/11895). Draft PR for ARR_AGG is (https://github.com/apache/beam/pull/13483). When i try to run the test, @Test public void

Query regarding Array_Agg impl

Hi Devs, I am trying to implement Array_Agg( https://cloud.google.com/bigquery/docs/reference/standard-sql/aggregate_functions#array_agg ) for Beam SQL ZetaSQL dialect, as CombineFn. Rough Pseudocode: * public static class ArrayAgg extends CombineFn { //todo }* But then I came to know we cannot

Re: Gradle Build issue

er. > > Have a good day, > Michal > > > On Wed, Nov 25, 2020 at 8:44 AM Sonam Ramchand < > sonam.ramch...@venturedive.com> wrote: > >> Hi Devs, >> When I run the "Gradle build" command after I take the latest pull, I >> have been gett

Gradle Build issue

Hi Devs, When I run the "Gradle build" command after I take the latest pull, I have been getting the following error. FAILURE: Build failed with an exception. * Where: *Build file '/home/vend/ApacheBeam/beam/buildSrc/build.gradle' line: 23* ** What went wrong:An exception occurred applying

Re: Question about LOGICAL_AND

tensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperators.java >>>>> >>>>> Then add the operator the table here: >>>>> https://github.com/apache/beam/blob/master/sdks/java/extensions/sql/zeta

Re: Question about LOGICAL_AND

er/sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperatorMappingTable.java > > On Thu, Nov 12, 2020 at 11:14 AM Sonam Ramchand < > sonam.ramch...@venturedive.com> wrote: > >> There is no LOGICAL_AND operator in SqlStdOp

Re: Getting ClassCastException

mo Suzuki wrote: > Hi Sonam, > > Do you want to share the stack trace of the error? It would help which > line it hit the error and the function calls. > > On Fri, Nov 13, 2020 at 6:40 AM Sonam Ramchand < > sonam.ramch...@venturedive.com> wrote: > >> Hi Dev

Getting ClassCastException

Hi Devs, I am trying to implement LOGICAL_AND functions for Beam SQL ZetaSQL dialect, as CombineFn. https://github.com/sonam-vend/beam/commit/9ad8ee1d8fa617aca7fcafc8e7efe8bf388b3afb When I try to execute testLogicalAndZetaSQL, I am getting

Question about LOGICAL_AND

There is no LOGICAL_AND operator in SqlStdOperatorTable, is there any other way to implement LOGICAL_AND? -- Regards, *Sonam* Software Engineer Mobile: +92 3088337296

Problem being encountered while running the Query with COUNTIF function

Hi Devs, I am trying to implement the COUNTIF function for Beam SQL ZetaSQL dialect, as CombineFn. Where I try to run the Test query (SELECT COUNTIF(f_long > 0) AS countif_no FROM PCOLLECTION GROUP BY f_int2), I am getting Exception Caused by: