我正在尝试在多个列上应用字符串索引器。$9: (string) => double) at org.apache.spark.sql.catalyst.expressions
浏览 77提问于2019-07-22得票数 7
1回答
我有一个名为“description”值的dataframe列，格式如下我想把它解析成3列，如下所示
| mode |它适用于简单的UDF函数，但不适用于我编写的函数。挑战在于，存储的价值可以是两个以上的词，也可以是没有固定数量的单词。18/10/06 21:38:02错误执行器:阶段5.0中任务0.0中的异常(TID 5) org.apache.spark.SparkException:
浏览 1提问于2018-10-06得票数 3
回答已采纳
我感兴趣的是在我的数据帧中获取一个名为mapColumn的列| mapColumn || Map(KEY -> VALUE) |并创建一个stringColumn，它只是Map列的键和值，其中值是" key，VALUE"： if (null
浏览 23提问于2019-08-06得票数 0
1回答
我试图用服务器端页面创建一个表，这样它也可以为我的表中的每个列应用过滤器。|| category string| 因此，我想到要为要筛选的列创建一个复合索引：如文档所述，问题在于，如果列没有在索引左侧形成前缀，则查询优化器无法使用索引</
浏览 0提问于2020-01-06得票数 0
回答已采纳
例如，当输入5.51123123时，它将显示3，我所知道的就是我应该使用charAt，我应该使用while循环吗？提前感谢
浏览 0提问于2013-10-30得票数 0
我试图在多个列上应用一个函数，然后创建多个列来计算每个条目的长度。基本上，我有5个索引为5、7、9、13和15的列，这些列中的每个条目都是表单'WrappedArray(|2008-11-12, |2008-11-12)'的字符串，而在我的函数中，我试图剥离wrappedArray部分并拆分这两个值，并使用以下方法计算(length - 1)；
def updates(row,n
浏览 0提问于2018-11-26得票数 0
回答已采纳
我正在尝试将一个相当大的(大约200M文档)文档数据库导入到Azure搜索中，但我发现索引器在大约24小时后超时。当索引器重新启动时，它会重新开始，而不是从它到达的地方开始，这意味着我不能将超过4000万个文档放入搜索索引。当索引器像这样失败时，是否应该尊重高水位线，如果不是，我如何对如此庞大的数据集进行索引？
浏览 2提问于2016-09-19得票数 0
1回答
我有一个part #列，它可以包含许多非字母数字字符。我经常需要比较来自客户或供应商的part #与我们的数据。我已经成功地使用了一个用户定义的函数，它只返回字母数字。我通过在索引视图上创建一个名为stripPartNum的计算列来提高性能。我想将这个计算列移动到表中。
我无法将计算列创建为持久化列，因此可以在该列上创建索引。错误:表'inventory‘中的计算
浏览 0提问于2012-10-26得票数 2
2回答
| 15 | 21 | 29 | 35 | 40 ] <Integer>
使用，我希望按照降序排列第一个列表的值对它们排序。(例如:由于索引4和5的元素相等，所以我必须按自然顺序按第二列表中的索引4和5的元素排序: 123.12 = 123.12，但"2000-01-12“> "2000-01-11"，所以后两个索引的顺序是在上面列中的每个元素之后，我用逗
浏览 2提问于2015-06-13得票数 1
2回答
在Server中，索引视图是限制的hellscape。但我需要一个。我有一个格式化程序SQLCLR函数，它创建一个域密钥的修饰版本--用户希望能够在该修饰版本的子字符串上搜索。因此，我需要一个持久化计算列或物化视图的全文索引。因此，这对于视图很好，但对于持久化计算列则不行，因为这些列不能从多个表进行查询。我可以使用T FORMAT函数
浏览 0提问于2019-08-20得票数 2
回答已采纳
4回答
我正在使用sed重新格式化输入字符串，其中的一部分我希望用不同的字符串替换。%Y-%m-%dT%H:%M:%S.我定义了以下数组来使用：
declare -A MONTHS=([01]="Jan" [02]="Feb" [03]="Mar" [04]="Apr" [05]="May" [06]="Jun" [07]="Jul&q
浏览 9提问于2016-01-20得票数 2
回答已采纳
我在Spark DataFrame中有两列，每一列中的每个条目都是字符串数组。ngramDataFrame.withColumn("full_array", concatUDF($"filtered_words", $"ngrams_array"))
我可以在两个数组上成功地使用concat_array函数。由于阶段失败而中止的任务:阶段16.0中的任务0失败1次，最近的失败:阶段16.0中丢失的任务0.0 (TID 12，localhost)：
浏览 1提问于2018-03-07得票数 9
回答已采纳
2回答
我在csv文件中有一个时间戳字段，我使用spark库将其加载到dataframe中。同一段代码在我的本地机器上使用Spark2.0版本，但在Azure Hortonworks HDP 3.5和3.6上抛出一个错误。我已经检查过了，Azure HDInsight 3.5也在使用相同的Spark版本，所以我不认为这是火花版本的问题。$$anonfun$makeConverter$9$$anonfun$apply$13$$anonfun$apply$2.apply(Univo
浏览 3提问于2017-04-06得票数 9
我有一个数据阅读器从数据库中读取数据。我正在从销售表中读取TotalPrice。我想用小数点后两位表示总价。
浏览 1提问于2012-02-01得票数 9
回答已采纳
1回答
我正在使用Server 2008。我在DateTime列"DateFrom“上有一个非唯一的非聚集索引。我是根据这个专栏搜索表的。我只想知道转换()函数对索引的影响，如下所示：SELECT *WHERE CONVERT(VARCHAR(10),DateFrom,23) >=但是我在想，由于列是转换的，所以SQL Server可能不会使用索引，对
浏览 4提问于2011-11-14得票数 11
回答已采纳
1回答
Long companyNumber;}public class CompanySpecification implements Specification<Company> {
public Pre
浏览 1提问于2019-04-17得票数 1
回答已采纳
我在java中使用spark的Dataset读取该文件。
.getOrCreate();
我想使用withColumn函数与自定义UDF一起添加一个新列。不能将java.lang.String
浏览 2提问于2017-08-25得票数 4
回答已采纳
1回答
: 'John Doe', 'public_profile': True我们读到了有关名称空间的内容，但是当我们尝试使用一般文档进行查询时public_profile', True))结果是null，但是当我们删除查询带来的所有记录的"where“语句时，文档说明查询与辅助索引一起工作
浏览 7提问于2017-02-06得票数 1
回答已采纳
2回答
其他列并不是唯一的。在我的机器上，这个查询大约需要140 my才能运行。我需要把这个降到20毫秒或更多。我认为解决方案是按照这个顺序添加一个新的覆盖索引，该索引是针对cid、tid和name定义的。但没什么区别。
有什么想法吗？我的覆盖索引设置不正确吗？
浏览 4提问于2015-10-19得票数 0
回答已采纳
1回答
在C#中用元组键绑定字典
、、、、
例如，我知道如果使用Dictionary<string, double>，我只会让Path="[" + keyString + "]"使用，但是如果我想使用一个元组作为密钥，我就不知道该做什么。即使是似乎也没有显式地处理这种情况，尽管它确实注意到
在索引器中，可以有由逗号(，)分隔的多个索引器参数。可以用括号指定每个参数的类型。例如，您可以使用P
浏览 1提问于2017-04-26得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
