我需要在窗口上检查一个条件：-如果IND_DEF列是20，那么我想要更改该寄存器所属窗口的premium列的值，并将其设置为1。
浏览 6提问于2019-09-26得票数 1
回答已采纳
1回答
我有一个包含值ID和值的表-----------------| 1 | A || 2 | UnKnown || 3 | B |我需要从表中选择不同的id和相应的值。选择Id时，Id应是唯一的，并且如果值字段中有多个值，则应仅检索非未知值
因此，结果应
浏览 0提问于2016-09-03得票数 1
当我从Spark2.0REPL(火花-shell)运行下面的Scala代码时，它会按我的意愿运行，用一个简单的正则表达式拆分字符串。但是，如果我只在Spark2.1中使用一个文字反斜杠，我就会从JVM的regex引擎"Dangling meta character '?' near index 0"中得到错误。我知道这意味着问号没有正确地转义，但是它闻起来好像反斜杠本身必须对第一个Scala和SQL进行转义。
我猜想这对于将控制字符(如换行符)插入
浏览 10提问于2017-01-20得票数 7
回答已采纳
1回答
我需要从dataframe中删除一些不在正确位置的值。lastPhase.isin(2, 3)phase === 8 and lastPhase.isin(6, 7) )
val df = spark.create
浏览 2提问于2021-08-23得票数 0
回答已采纳
1回答
<init>(Symbols.scala:205) at scala.reflect.internal.Symbols$ClassSymbol.<init>(Symbols.scala:3222)
at scala.reflect.internal.Symbols$StubClassSy
浏览 2提问于2018-12-12得票数 0
回答已采纳
我知道我们可以用前缀+ shift + d来断开客户端的连接，但如果有人连接的屏幕尺寸不同或更小，这真的很烦人。如果程序依赖于tmux屏幕大小，它也可能使程序崩溃。请让我知道，如果有一个配置，我可以用来防止屏幕尺寸较小的人连接在第一位。此外，在他们连接后，如何防止tmux调整屏幕大小，如果连接的计算机调整其终端的大小。
浏览 3提问于2019-03-14得票数 0
3回答
我使用brew安装apache-spark安装了spark本身，它似乎已经安装了apache 2.2.0
但当我运行火星雨时，它就会喷出。/Users/me/anaconda/bin/pyspark: line 24: /Users/bruceho/spark-1.6/spark-1.6.2-bin-hadoop2.6/bin/load-spark-env.sh: No such file
浏览 10提问于2017-09-24得票数 2
回答已采纳
14回答
我想在spark中读取CSV，并将它转换为DataFrame，然后用df.registerTempTable("table_name")存储在HDFS中。10] at org.apache.spark.sql.parquet.ParquetRelation2$MetadataCache$$anonfun$refresh$6.apply(newParquet.scala
浏览 33提问于2015-04-17得票数 164
回答已采纳
我有一个整数的rdd (即RDD[Int])，我想要做的是计算以下10个百分位数：[0th, 10th, 20th, ..., 90th, 100th]。做到这一点最有效的方法是什么？
浏览 185提问于2015-03-02得票数 25
我正在尝试使用kinesis数据流创建实时情绪分析模型，并使用spark创建databricks笔记本。我尝试将我的笔记本作为作业运行，但处理spark流的代码块永远都不会运行，不会让其他代码块完成ETL过程。 这是我如何设置我的火花流的问题吗？下面是我如何设置它的代码： kinesisDF = spark \ .format("kinesis") \
.option("streamName", kinesisStreamNa
浏览 22提问于2020-06-27得票数 0
根据NSF文件中存在的条件，每个字母都是不同的。我需要根据这些条件打印这些信件。例如，如果客户I从未进行过NSF检查。我想打印一封漂亮的信(第1页)。如果客户进行了其他NSF检查，则检查letter 2(第2页)，以此类推。我创建了以下变量--我需要在值1,2,3,4,5中指定什么才能正确打印。谢谢
浏览 0提问于2012-12-01得票数 0
下面是代码和结果：3405691582
res0: Int = -889275714aa: Long = 3405691582
aa1: Long = -889275714P.S2：当我尝试用3405691582将变量计算为Int时，Sc
浏览 0提问于2015-02-14得票数 2
如果我根据度量“服务器异常”创建了一个新的警报，那么它似乎再次工作了。一旦它开火，它似乎会进入“活动”状态，其中有一个橙色三角形，其中有一个！请看下面的图片。我有一个轻量级的Web服务，它非常简单，应该永远不会失败，但它可以，因此，如果出现异常，我希望立即收到警报。
浏览 4提问于2015-06-30得票数 12
回答已采纳
4回答
我使用的是Java Swing。我在面板中有一个文本区域。我不需要那个textArea的水平滚动条，只需要一个垂直滚动条。我禁用了自动滚动条选项，但水平滚动条仍在工作。请用太赫兹来帮助我。
浏览 2提问于2010-06-07得票数 2
回答已采纳
我正在使用Git (GitHub)，并试图在gitattributes中决定将*.sql文件设置为什么。
浏览 1提问于2015-01-26得票数 16
回答已采纳
2回答
我正在尝试将一些Pandas代码转换为Spark以进行缩放。myfunc是一个复杂应用程序接口的包装器，它接受一个字符串并返回一个新的字符串(这意味着我不能使用矢量化函数)。我是Spark的新手，我想用pyspark来翻译这个逻辑。我已经将我的熊猫DataFrame转换为Spark：spark_schema= StructType([StructField(c,
浏览 2提问于2019-02-02得票数 1
回答已采纳
我首先将它设置为共享内存，然后设置为TCP/IP，最后设置为命名管道。另一位消息人士说，我的端口可能会被封锁，但我的防火墙上已经有了一条允许访问默认端口的规则，在我的情况下，默认端口是1433。
浏览 0提问于2014-11-25得票数 2
任何方式都可以通过它，因为我将使用spark run和s3分区的执行日期。submit_compaction_to_spark = SparkKubernetesOperator(
task_id="submit_compaction_to_spark",
浏览 13提问于2021-03-05得票数 1
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
