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....    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 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...    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...    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...    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....    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....    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...    Author: Xu Mingmin , 2018-06-19, 13:55
[BEAM-2998] add IT test for SQL - Beam - [issue]
...Add IT test for SQL module is the base example...    Author: Xu Mingmin , 2018-06-18, 21:12
[BEAM-3918] test failure BeamSqlDslAggregationTest.testTriggeredTumble - Beam - [issue]
...I cannot pass the test case added in, here's the error message: (run with mvn clean install -pl sdks/java/extensions/sql/)[ERROR] Failures:[ERROR] &n...    Author: Xu Mingmin , 2018-04-25, 03:20
[BEAM-2990] support data type MAP - Beam - [issue] Non-scalar types:MAP Collection of keys mapped to valuesARRAY Ordered, contiguous collection that may contain duplicates...    Author: Xu Mingmin , 2018-04-16, 20:53