已有0人关注此标签
请教问题:schema中的 pg_temp_*,pg_toast_temp_* 这样的schema可以手动删除掉吗? 目前我们的系统中有84个这样的schema,我节点之前不到10个,最近暴涨.
作者： 游客886
49人浏览
0人回答
请教问题:schema中的 pg_temp_,pg_toast_temp_ 这样的schema可以手动删除掉吗?目前我们的系统中有84个这样的schema,我节点之前不到10个,最近暴涨.
求助，springboot中使用配置可以在创建data-source时读取resources下的sql脚本文件，但是 我在代码中需要动态创建数据库并创建data source 怎么样才能够在每次创建data-source
作者： 李博 bluemind
163人浏览
0人回答
时也读取脚本在对应的库中创建表呢这里的setSchema.sql只能设置Schema的名字 但是并不会运行脚本文件有人知道怎么回事吗？ 本问题来自云栖社区【阿里Java技术进阶2群】。https://yq.aliyun.com/artic…
可以将spark配置为将空数据集推断为空模式吗
作者： 小六码奴
498人浏览
1人回答
我们有很多parquet数据集，按年/月/日/小时划分。 只有一个_SUCCESS文件，其中一些时间是空的。 我们实现迭代所有分区并执行工作的作业。打开空数据集时遇到问题。org.apache.spark.sql.AnalysisExce…
如何解决未初始化的常量Search :: error
作者： 小六码奴
144人浏览
1人回答
我正在为与汽车维护相关的约会模型创建一个高级搜索/过滤器，其中schema.rb中的每个表都是： create_table "appointments", force: :cascade do |t| t.string "VIN" t.s…
mongoose如何返回特定时间段数据
作者： 李博 bluemind
187人浏览
1人回答
假定数据结构如下： { userid:1111, data1:[ {title:'test',content:'test',createTime:'2019-03-25T09:24:00.000Z'} {title:'te…
greenplum系统表reindex后查询效率不生反降
作者： heartofstone
219人浏览
0人回答
对pg_catalog schema下的表做了reindex/vacuum/reindex/analyze，查询的效率反而降低了。该从哪方面考虑解决这个问题
pgsql中，不同数据库下的schema是隔离的吗？schema是属于某个数据库的，还是属于一个实例的？网上说通过schema跨库访问，没看懂。
作者： 我叫石头
209人浏览
1人回答
我的理解是，仅仅通过schema设定。用户可以访问多个数据库的资源，但不能在一个数据库下select另外一个数据库的table。这样对吗？
【FLINK】在同一个流上执行多次sql，导致第二个sql中的where条件不可用
作者： 游客6juj22qmvfpmk
419人浏览
0人回答
List fields = Lists.newArrayList("rawMessage"); Schema schema = new Schema(); for (int i = 0; i < fields.siz…
flink1.7.1 写es6外部表没数据问题
作者： 冷丰
755人浏览
2人回答
用的是flink1.7.1,测试代码为 import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, _} import org.apache.flink…
有没有人用过1.7 state schema evolution 吗？ 不太明白怎么用
作者： flink小助手
320人浏览
1人回答
有没有人用过1.7 state schema evolution 吗？ 不太明白怎么用
org.apache.avro.SchemaParseException：未定义的名称
作者： k8s小能手
410人浏览
1人回答
我的spark工作是从kafka读取并解码消息。我的spark工作在MAC 上的本地spark集群（https://archive.apache.org/dist/spark/spark-2.2.1/spark-2.2.1-bin-had…
pyspark - 在json流数据中找到max和min usign createDataFrame
作者： 社区小助手
419人浏览
1人回答
我有一组由Kafka流式传输的json消息，每个消息都描述一个网站用户。使用pyspark，我需要计算每个国家/地区每个流媒体窗口的用户数，并返回具有最大和最小用户数的国家/地区。 以下是流式json消息的示例： {"id":1,"fir…
当Spark在S3上读取大数据集时，在“停机时间”期间发生了什么？
作者： 社区小助手
303人浏览
1人回答
我在AWS S3中有一堆JSON数据 - 让我们说100k文件，每个大约5MB - 我正在使用Spark 2.2 DataFrameReader来读取和处理它们： sparkSession.read.json(...) 我发现Spark在…
在Spark Streaming Python中将RDD转换为Dataframe
作者： 社区小助手
437人浏览
1人回答
我试图在Spark Streaming中将RDD转换为DataFrame。我正在关注以下流程。 socket_stream = ssc.socketTextStream("localhost", 9999)def convert_to_d…
Spark scala让类找不到scala.Any
作者： 社区小助手
869人浏览
1人回答
val schema = df.schemaval x = df.flatMap(r => (0 until schema.length).map { idx => ((idx, r.get(idx)), 1l) })这会产…
Apache Spark 2.0：Expression-string到orderBy（）/ sort（）列的降序
作者： 社区小助手
423人浏览
1人回答
from pyspark.sql import functions as sFn # Note: I import Spark functions this way to avoid name collisions w/ Python…
scala如何参数化case类，并将case类变量传递给[T <：Product：TypeTag]
作者： 社区小助手
329人浏览
1人回答
// class definition of RsGoods schemacase class RsGoods(add_time: Int) // my operationoriginRDD.toDF[Schemas.RsGoods]()…
如何从代码外部提供spark / scala中的模式
作者： 社区小助手
299人浏览
1人回答
我想读取ex：schema_file的文件，它将包含模式，并希望在代码中使用它来创建DataFrame 我已阅读过ConfigFactory提供架构但无法使用它，因为将来可能会更改架构。 schema[ { columnName = …
在schema下新建的表，对于一个已经存在的用户不会自动赋予select的权限的，需要我们使用grant select...手动去执行，这样就比较麻烦，总不能每次新建表，我们就赋权一次；这个有什么好办法吗
作者： 我叫石头
354人浏览
1人回答
喜爱PostgresSQL的同学扫码进群
如何在CSV文件中的更新行上运行流查询？
作者： 社区小助手
224人浏览
1人回答
我在一个不断更新的文件夹中有一个csv文件。我需要从这个csv文件中获取输入并生成一些事务。如何从持续更新的csv文件中获取数据，每5分钟一次的话？ 我试过以下： val csvDF = spark .readStream .opti…
