我正在尝试将我的Scala (scala.collection.immutable.map)的Map[String,String]对象输出映射到表API中的一些有效数据类型，即通过Java (java.util.Map)，如这里所建议的：。如果是，是否有一种将转换为Map[String,Any]类型的(嵌套) Scala对象的方法？码class dummyMa
浏览 3提问于2020-11-06得票数 0
回答已采纳
我尝试使用外部JAR在Pyflink中注册一个Scala UDF，如下所示，但得到下面的错误。Scala UDF： package com.dummy
class dummyTransform/target/scala-2.12/hello_scala_for_flink-a
浏览 20提问于2020-10-27得票数 1
回答已采纳
根据这一汇合点页面：python位于Flink 1.11中，可用于SQL函数中。/bin/python --pyFiles /Users/jonathanfigueroa/Desktop/pyflink&
浏览 1提问于2020-07-09得票数 0
我正在使用PyFlink，我想对用Python编写的UDF进行单元测试。要测试以下简单的udf：from pyflink.table import DataTypes return i + jfrom tasks.he
浏览 4提问于2021-03-23得票数 2
回答已采纳
我试图在SQL中执行python函数(1.14.0)from pyflink.table import DataTypes启动sql-client：
PYFLINK_CLIENT_EXECUTABLE=/usr/bin/python3 .4，我
浏览 6提问于2021-12-03得票数 3
我在pyflink非常新，并且尝试使用python注册一个自定义的UDF函数。目前，我在服务器env和本地IDE环境中都遇到了一个问题。可以使用配置键'taskmanager.memory.task.off-heap.size配置任务堆外内存。当然，我已经将必需的属性添加到我的flink-conf.yaml中，并检查pyflink-shell.sh是否使用</em
浏览 5提问于2020-10-12得票数 0
1回答
我在一个项目中使用PyFlink 1.13，我试图做以下工作：
我使用PyFlink的Table，我的两个表都是使用SQL声明的。我的查询执行如下：
SELECT UserId, Time
浏览 2提问于2021-10-29得票数 0
回答已采纳
1回答
在通过将用户定义的函数(UDF)提交到本地集群来启动涉及用户定义函数(UDF)的之后，它会与py4j.protocol.Py4JJavaError一起崩溃。我已经尝试遵循以下链接中的所有说明：
我用classloader.parent-first-patterns-additional配置选项尝试了很多不同的配置。使用org.apache.beam.sdk.[...]的不同条目导致了不同的附加错误消
浏览 3提问于2020-05-05得票数 1
回答已采纳
我在Py4j的PyFlink端有一个错误。：
在代码中添加env.add_jars("file:/" + os.getcwd() + "/jar_files/" + "kafka-clients-3.2.0.jar")。在`import_flink_view‘方法中添加另一个java_import作为java_import(gateway.jvm
浏览 10提问于2022-07-01得票数 1
回答已采纳
2回答
我创建了如下所示的蜂巢udf，def evaluate(col : String): String = {}然后我在sparksession注册了udf，
sparksession.sql("""CREATE TEMPORARY FUNCTION testUDF AS 'testpkg.customUdf'""&
浏览 3提问于2022-05-13得票数 0
下面是我的java udf代码， return false; return true;}
我正在用这个类作为SparkUdf-1.0-SNAPSHOT.jar构建Jar我在单元中有一个表名作为示例，并希望在shell上运行
浏览 2提问于2019-02-19得票数 1
1回答
我想知道我们是否可以在运行时将Scala中定义的方法转换为Python中的方法。我正在学习Apache Spark Scala API，作为我的项目的一部分，并寻找一种方法来将Scala方法转换为Python语言可识别的格式。我的目标是将方法从Scala程序发送到外部Python程序，并且Python程序应该能够使用或执行它。Scala代码=> Lambda
line =&g
浏览 0提问于2017-10-19得票数 1
1回答
我有过这样的场景:我定义了一个kafka源，UDF \ UDTF，用于处理并接收到Kafka接收器。不管我做什么，如果我运行作业，输出会被单个输入记录的处理输出淹没。为了说明起见，这是关于已定义的kafka接收器主题的输出：
通过尝试找出我阅读过的任何flink文档中的问题(以及链接
浏览 6提问于2022-03-14得票数 0
我有一个PyFlink作业，它从文件中读取、基于条件进行筛选和打印。这是我工作目录的tree视图。StreamTableEnvironment, DataTypes# https:&#x
浏览 2提问于2021-03-18得票数 1
回答已采纳
2回答
创建了一个项目‘spark udf’&编写的单元udf如下所示：import org.apache.hadoop.hive.ql.exec.UDF
spark.sql("CREATE OR REPLACE FUNCTION uppercase AS 'com.spark.udf.UpperCase'
浏览 4提问于2018-09-04得票数 5
回答已采纳
问题：我的envTaskManagerRunner # flink- 15705 ConsoleProducer- 31454 Kafka
我的代码_2.12-1.14.2.ja
浏览 48提问于2022-01-14得票数 0
回答已采纳
我是新来的。Im编写一个python程序来读取kafka主题的数据，并将数据打印到stdout。我跟踪了链接。但由于版本错配，我一直看到NoSuchMethodError。我添加了在上可用的flink-sql连接器。有人能帮我举个合适的例子来做这个吗？以下是我的代码import os
from pyflink.datastreamkafkaSource
浏览 23提问于2022-02-03得票数 0
我试图连接到windows上带有pyflink的postgresql，并使用以下代码：
from pyflink.table import EnvironmentSettings, TableEnvironment
浏览 16提问于2022-01-26得票数 1
1回答
这是使用apache (Pyflink)从kafka源代码中计算每个chx平均值的代码，我想我已经导入了所有必需的库。from pyflink.datastream import StreamExecutionEnvironment, TimeCharacteristicfrom pyflink.table.<
浏览 17提问于2022-04-29得票数 0
回答已采纳
我在注册一个java文件中的一些udfs时遇到了问题。scala_udf_similarity_0_0_7-35e3b.jar')
sc = SparkContext.getOrCreate(conf=confspark.jars dbfs:/FileStore/jars/4b129434_12cd_4f2a_ab27_baaefe904857-scala_<e
浏览 11提问于2021-01-14得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
