You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by an...@apache.org on 2018/11/08 22:01:38 UTC
[beam] branch master updated (7f48e5a -> f65b485)
This is an automated email from the ASF dual-hosted git repository.
anton pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 7f48e5a [BEAM-6013] Reduce logging within SerializableCoder. (#6982)
add 71860a6 [BEAM-5943][BEAM-5940] 1. Add ENDS_WITH. 2. Add LEGNTH.
add 92d561e [BEAM-5945] add reverse
add 7abdfa9 [BEAM-5952] add STARTS_WITH.
add b95558b [SQL] add NULL check for builtin functions.
add aebb7b7 [BEAM-5852] add FROM_HEX
add adc1fed [BEAM-5962] Add TO_HEX
add 91f9a4b [BEAM-5963]: add LPAD
add 139f4d1 [BEAM-5965] Add RPAD
new f65b485 Merge pull request #6928 from amaliujia/rui_wang-add_string_functions
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../interpreter/operator/BeamSqlPrimitive.java | 1 +
.../sql/impl/udf/BuiltinStringFunctions.java | 302 +++++++++++++++++++++
.../impl/udf/BuiltinTrigonometricFunctions.java | 9 +
.../extensions/sql/impl/utils/CalciteUtils.java | 3 +
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 84 ++++++
.../udf/BeamSalUhfSpecialTypeAndValueTest.java | 170 ++++++++++++
.../sql/impl/udf/BeamSqlUdfExpressionTest.java | 202 ++++++++++++++
.../sql/impl/udf/BeamSqlUdfImplTest.java | 139 ----------
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 7 +
9 files changed, 778 insertions(+), 139 deletions(-)
create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BuiltinStringFunctions.java
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/udf/BeamSalUhfSpecialTypeAndValueTest.java
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/udf/BeamSqlUdfExpressionTest.java
delete mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/udf/BeamSqlUdfImplTest.java
[beam] 01/01: Merge pull request #6928 from
amaliujia/rui_wang-add_string_functions
Posted by an...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
anton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit f65b4850502137b2555574c4e73c91cacf38da48
Merge: 7f48e5a 139f4d1
Author: Anton Kedin <33...@users.noreply.github.com>
AuthorDate: Thu Nov 8 17:01:26 2018 -0500
Merge pull request #6928 from amaliujia/rui_wang-add_string_functions
[BEAM-5852] BeamSQL functions
.../interpreter/operator/BeamSqlPrimitive.java | 1 +
.../sql/impl/udf/BuiltinStringFunctions.java | 302 +++++++++++++++++++++
.../impl/udf/BuiltinTrigonometricFunctions.java | 9 +
.../extensions/sql/impl/utils/CalciteUtils.java | 3 +
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 84 ++++++
.../udf/BeamSalUhfSpecialTypeAndValueTest.java | 170 ++++++++++++
.../sql/impl/udf/BeamSqlUdfExpressionTest.java | 202 ++++++++++++++
.../sql/impl/udf/BeamSqlUdfImplTest.java | 139 ----------
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 7 +
9 files changed, 778 insertions(+), 139 deletions(-)
diff --cc sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java
index cd93166,f5c89a2..5c22314
--- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java
+++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java
@@@ -202,8 -203,10 +203,10 @@@ public class CalciteUtils
*/
public static RelDataType sqlTypeWithAutoCast(RelDataTypeFactory typeFactory, Type rawType) {
//For Joda time types, return SQL type for java.util.Date.
- if (rawType instanceof Class && ReadableInstant.class.isAssignableFrom((Class<?>) rawType)) {
+ if (rawType instanceof Class && AbstractInstant.class.isAssignableFrom((Class<?>) rawType)) {
return typeFactory.createJavaType(Date.class);
+ } else if (rawType instanceof Class && ByteString.class.isAssignableFrom((Class<?>) rawType)) {
+ return typeFactory.createJavaType(byte[].class);
}
return typeFactory.createJavaType((Class) rawType);
}