clear query| facets| time Search criteria: .   Results from 1 to 10 from 136 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-5202] register UDF/UDAF with ServiceLoader - Beam - [issue]
...create a ServiceLoader for UDF/UDAF register, if the autoLoad option is set to TRUE....
http://issues.apache.org/jira/browse/BEAM-5202    Author: Xu Mingmin , 2018-10-11, 16:58
[BEAM-1775] fix issue of start_from_previous_offset in KafkaIO - Beam - [issue]
...Jins George [EMAIL PROTECTED] via aermail.onmicrosoft.com 5:50 PM (15 hours ago)to userHello,I am writing a Beam pipeline(streaming) with Flink runner to consume data from Kafka and apply so...
http://issues.apache.org/jira/browse/BEAM-1775    Author: Xu Mingmin , 2018-10-05, 06:29
[BEAM-5210] VARBINARY is not supported in BeamSqlPrimitive - Beam - [issue]
...See error as belowCaused by: java.lang.UnsupportedOperationException: Unsupported Beam SQL type in expression: VARBINARY at org.apache.beam.sdk.extensions.sql.impl.interpreter.operator.BeamS...
http://issues.apache.org/jira/browse/BEAM-5210    Author: Xu Mingmin , 2018-08-31, 17:10
[BEAM-5204] reduce restriction of JOIN - Beam - [issue]
...ATM streaming-streaming JOIN is acceptable only when triggersOncePerWindow(windowingStrategy). With PaneInfo exposed by UDF, we should allow JOIN with multiple triggers as developers can fil...
http://issues.apache.org/jira/browse/BEAM-5204    Author: Xu Mingmin , 2018-08-23, 06:04
[BEAM-5203] expose PaneInfo and BoundedWindow as UDF - Beam - [issue]
...besides adding new keywords in Calcite, there's an alternative way to expose PaneInfo and BoundedWindow of Row by UDF....
http://issues.apache.org/jira/browse/BEAM-5203    Author: Xu Mingmin , 2018-08-23, 05:59
[BEAM-5198] add functions to add/remove/list tables in BeamSqlEnv - Beam - [issue]
...We use a customized CLI implementation to submit streaming queries with BeamSql, the capability to add/remove/list tables in BeamSqlEnv is helpful for user-interactive....
http://issues.apache.org/jira/browse/BEAM-5198    Author: Xu Mingmin , 2018-08-22, 19:00
[BEAM-2281] call SqlFunctions in operator implementation - Beam - [issue]
...Calcite has a collections of functions in org.apache.calcite.runtime.SqlFunctions. It sounds a good source to leverage when adding operators as BeamSqlExpression. James Xu Tarush Grover, any...
http://issues.apache.org/jira/browse/BEAM-2281    Author: Xu Mingmin , 2018-06-19, 13:55
[BEAM-2998] add IT test for SQL - Beam - [issue]
...Add IT test for SQL modulehttps://github.com/apache/beam/blob/master/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/BeamSqlExample.java is the base example...
http://issues.apache.org/jira/browse/BEAM-2998    Author: Xu Mingmin , 2018-06-18, 21:12
[BEAM-3918] test failure BeamSqlDslAggregationTest.testTriggeredTumble - Beam - [issue]
...I cannot pass the test case added in https://github.com/apache/beam/pull/4826, here's the error message: (run with mvn clean install -pl sdks/java/extensions/sql/)[ERROR] Failures:[ERROR] &n...
http://issues.apache.org/jira/browse/BEAM-3918    Author: Xu Mingmin , 2018-04-25, 03:20
[BEAM-2990] support data type MAP - Beam - [issue]
...support Non-scalar types:MAP Collection of keys mapped to valuesARRAY Ordered, contiguous collection that may contain duplicates...
http://issues.apache.org/jira/browse/BEAM-2990    Author: Xu Mingmin , 2018-04-16, 20:53