udf

0热度

3回答

如何：在没有地图的情况下写入aerospike udf过滤器或在地图中返回完整记录

我在Aerospike中有一个带有过滤器和地图的udf流。如果我映射，按照我所看到的所有的例子，我可以选择从记录的字段，并返回与过滤和选择的领域一个新的地图。但是，我不想这样做。我想采取任何流，任何列/箱，应用过滤器，并返回完整的记录。一种方法可能是使用stream：fiter（my_filter）而不使用地图。直觉地（至少对我来说）这只是过滤和中继流。这似乎并不奏效，令我感到沮丧。接下来我尝试

0热度

1回答

在UDF查询中将UDF用作BigQuery

我在BigQuery中创建了一个UDF，并像在FROM子句中使用UDF的文档（https://cloud.google.com/bigquery/user-defined-functions#creating-the-query）中的示例那样运行它。但是，我需要的是在select中将UDF用作列。举一个例子 - 这是我的函数返回每个坐标在全球的四分之一是： function getQuarte

0热度

1回答

UDF使用Java方法上的火花

打破我已经做了这个代码在databricks环境，但是当我尝试在我的本地ENV它打破... val _event_day_of_week = (event_date_of_event: String) => { import java.time.LocalDate import java.time.format.DateTimeFormatter val form

0热度

1回答

如何比较Scala中使用DataFrame的表中的每列而不关心列是什么？

我之前问过的问题如下。 Last question 表1 - ID对表表2 - 属性表表3 例如，id1和id2具有不同的颜色和大小，所以id1和id2行（表3中的第二行）具有“id1 id2 0 0”; id1和id3具有相同的颜色和不同的尺寸，所以id1和id3行（表3中的第3行）具有“id1 id3 1 0”; 相同的属性--- 1个不同的属性--- 0 但是，如果我不知道表2中有多少属

1热度

1回答

如何创建一个UDF找到索引数组列

我有一个表如下： val question = sqlContext.createDataFrame(Seq((1, Seq("d11","d12","d13")), (2, Seq("d21", "d22", "")))).toDF("Id", "Dates") +---+---------------+ | Id| Dates| +---+---------------+ | 1|

0热度

1回答

字符串排列火花udf

我正在收敛一个猪脚本来使用scala来激发1.6，我有一个包含字符串的数据框，并且我想以特定顺序交换字符。例如： +----------------+ | Info| +----------------+ |8106f510000dc502| +----------------+ 我想把它转换成这样的顺序[3,1,5,7,6，（8-16），4,2] +--------------

1热度

1回答

Excel2011：Vlookup和Combine

我有一些困难结合几个功能来做我想要的70000 +行excel文件。任何提示或指示或建议非常感谢。我有2列（约值70000行）。在第1栏中，我有客户的帐号（有重复的），在第2栏旁边有我想提取的数据。我也有第三列（第3列），这是一个帐号列表，但已被删除重复。我正在尝试让Vlookup查看第三列（lookup_value）的第一行，然后在（table_array）的第1列中搜索该值，并返回第2列中与

1热度

1回答

Cassandra集合函数“first_row”

我知道，卡桑德拉允许GROUP BY并且可以在该数据上运行UDF。是否有任何默认函数来获取每个聚合集的第一行？（How）我可以停止处理数据并立即从我的UDF返回结果（E.G.经过1或几行处理后）吗？现在我使用... COUNT(1) ...作为解决方法。

5热度

1回答

Spark与SQL嵌套列

0热度

1回答

为什么SQL服务器使用函数

将0值插入到我的表中而不是正确的值希望有人可以帮助我，因为我完全不知道为什么会发生这种情况。我目前正在对英超比赛结果进行一些分析，并且作为其中的一部分，我创建了一个多语句表UDF。该函数接受HomeTeam，AwayTeam和MatchDate参数，然后计算在指定的匹配日期之前在主队和客队之间赢得，抽签或失去的每个比赛结果。此功能通过手动调用它工作正常，并返回这些值的 Home Away D