1. 云栖社区>
  2. 全部标签>
  3. #string#
string

#string#

已有4人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

[@小川游鱼][¥20]为什么 Java 中的 String 是不可变的(Immutable)?

问题来自Java技术沙龙的李博Java线下沙龙报名链接:https://yq.aliyun.com/activity/796

java aliyun string activity

[@徐雷frank][¥20]怎么将 byte 转换为 String?

问题来自Java技术沙龙的李博Java线下沙龙报名链接:https://yq.aliyun.com/activity/796

java aliyun string activity

OrcTableSource是否支持S3文件系统?

我使用OrcTableSource从云对象存储(IBM COS)获取Orc文件时遇到了一些麻烦,代码片段如下所示: OrcTableSource soORCTableSource = OrcTableSource.builder() //…

java hadoop Apache path runtime 对象存储 string open class thread csv flink

Spark UDF找不到参数num的隐含值:Numeric [Nothing]

我正在尝试编写泛型add方法,可以采用任何参数类型并返回该类型的结果 def addExactUDFT(implicit num: Numeric[T]): T = { import num._ x + y } def addExact(…

spark string UDF flink

[@talishboy][¥20]怎样更好的实现文件解压缩

下面是文件解压部分 /** * 解压文件到指定目录 * 解压后的文件名,和之前一致 * @param zipFile 待解压的zip文件 * @param descDir 指定目录 */ @SuppressW…

编程语言 java string static void charset file

Spark结构化流媒体从Cassandra中丰富

我使用结构化流式传输来自Kafka的数据 val df = spark .readStream .format("kafka") .option("kafka.bootstrap.servers", "localhost:9092") .…

spark string Cassandra url test schema uuid Group Commit bootstrap

结构化流式传输到rdd不起作用

试图对stractured流做一些操作,并且需要使用.rdd函数,但得到"""AnalysisException: Queries with streaming sources must be executed with writeStr…

函数 spark string url schema

如何重命名scala数据框中的列标题

如何在scala数据帧上执行string.replace(“fromstr”,“tostr”)。据我所知,withColumnRenamed执行替换所有列而不仅仅是标题。

spark scala string

Scala [type1,type2]

以下是使用Either的一个工作示例: val a: Either[Int, String] = {if (true) Left(42) // return an Int else Right("Hello, world") // ret…

SQL Apache spark scala string file type read

Spark Scala - 检查嵌套案例类的字段

我有三个案例类如下: case class Result( result: Seq[Signal], hop: Int) case class Signal( rtt: Double, from: String) …

Json spark scala string 序列 class timestamp

如何防止kafka的spark sql在数据帧中向JSON字符串添加反斜杠

出于某种原因,我执行代码.wriestream.format(json).option(Path)。我有json,由于某种原因,标签都有双“”。我想删除所有“”。 val selectData = kafkaDF.select(($"va…

SQL Json path spark string

想了解Spark ShuffleMapTask计算的输出文件,是如何把大于内存的输入数据(HDFS数据源)进行合并相同key,并进行排序的

[问题]).ShuffleMapTask输出数据文件前,key合并,和排序是如何做到的,如果数据远大于内存?).SPARK 1.6.0-cdh5.15.0[复现]).scala worldcount: val distFile:org.…

hdfs Apache 排序 spark scala string Spark排序

如果列表中存在,则从列中删除单词

我有一个带有'text'列的数据框,其中有许多行包含英文句子。 文本 It is eveningGood morningHello everyoneWhat is your nameI'll see you tomorrow我有一个Lis…

SQL Apache spark string list

在Spark Stream中保存PairRdd时出错[重复]

我试图在spark流中保存我的Pair Rdd但在最后一步保存时出错。 这是我的示例代码 def main(args: Array[String]) { val inputPath = args(0) val output = args(…

hadoop Apache spark string stream input

可以在飞行中构建spark代码并执行吗?

我正在尝试使用数据库CSV READER创建一个通用函数来读取csv文件。但是该选项不是强制性的,它可以根据我的输入json配置文件而有所不同。 例1: "ReaderOption":{ "delimite…

函数 Json 数据库 配置 spark DataFrame string schema read csv

为什么这个Scala代码显然没有在Spark工作器上运行,而只在Spark驱动程序节点上运行?

我使用这里提到的代码在Scala中创建一个HashMap。为方便起见,下面复制粘贴: def genList(xx: String) = { Seq("one", "two", "three", "four") } val oriword…

java 集群 spark scala string exception thread hashmap

安装后无法执行pyspark

我已手动复制spark-2.4.0-bin-hadoop2.7.tgz并提取。然后我进入.bash_profile如下: export SPARK_HOME = / Users / suman / Pyspark / spark-2.4.…

python java hadoop Apache spark scala string exception file Security

映射JavaRDD时删除空值

我正在开发Java + Apache Spark应用程序。它的一个功能是trim Strings。例如: // Having JavaSparkContext jsc previously defined and a function l…

java Apache spark string

带参数的getItem是列名

我的专栏col1是一个数组。 我知道这col1.getItem(2)允许您访问列的第二个参数。是否有一个函数可以使用参数作为列进行访问col1.getItem(col2) ? 我可以创建一个UDF,但是我必须指定数组的类型(并且它可以是多…

函数 spark string UDF index 数组

Spark SQL - createDataFrame错误的struct schema

尝试使用Spark SQL创建DataFrame时,通过传递一个行列表,如下所示: some_data = [{'some-column': [{'timestamp': 1353534535353, 'strVal': 'some-st…

python 架构 SQL spark DataFrame string schema timestamp

上一页 1 ... 2 3 4 5 6 ... 12 下一页
12
GO