1回答
我为KSQL实现了一个自定义函数，并根据https://docs.confluent.io/current/ksql/docs/developer-guide/udf.html配置了Maven pom.xml当我尝试用mvn clean package创建jar文件时，我遇到了以下错误： [ERROR] Failed to execute goal on project CustomUDF: Could notresolve depen
浏览 11提问于2019-06-21得票数 1
回答已采纳
在尝试使用UDF设置ETL管道时，我遇到了KSQL的问题。在ETL过程的某个时候，我需要从数据中的描述字段(VARCHAR)中分离特定的信息。看起来是这样的：import io.confluent.ksql.function.udf.Udf;
import io.confluent.ksql.function.udf.UdfDescription> list f
浏览 2提问于2020-11-02得票数 1
我在3个节点上运行独立的ksql-server，与一个由3节点组成的Kafka集群进行对话。从Stream创建了一个具有15个分区的Topic，数据在流中进行了一些充实。有一段代码作为UDF来查找IP2Location.bin文件，UDF类如下所示：import java.util.Map;
import io.conflu
浏览 0提问于2019-04-10得票数 1
回答已采纳
我正在尝试创建一个流作为select (CSAS)，这个流是成功创建的，但是当我试图推送消息时，我得到了下面的异常。的主流、持久流和udf函数的详细信息，不确定模式为什么不兼容，正如您在processed流下面看到的，有一个名为article的字段，其模式与UDF函数返回的值完全相同，这里是不是遗漏了什么。> describe function test;
Overview : test udfJar<
浏览 11提问于2019-11-10得票数 0
回答已采纳
1回答
我正在尝试创建一个UDF函数，它接受一个STRUCT作为param，并在对输入字段进行一些修改(更新现有字段+添加新字段)之后返回一个结构，如下所示：public class MyCustomUdf {
public Struct MyCustomUdf(@UdfParametertoUpperCase();
struct.put
浏览 2提问于2019-10-27得票数 0
回答已采纳
1回答
我也一直在使用udf，直到我停止服务器并重新启动它们为止，一切看起来都很好。:106) at io.confluent.ksql.KsqlEngine我已经从.jar文件夹中取出了udf (Udf)，服务器也启动了，尽管日志打印的udf函数(我正在使用)不可用。这是我的ksql
浏览 0提问于2019-04-03得票数 0
回答已采纳
我可以创建两个流并合并它们，但是我的错误日志将被不相关的错误所污染。我是不是遗漏了什么？
浏览 6提问于2022-12-01得票数 0
1回答
我正在实现一个KSQL UDF，它将检测给定的(经度，经度)对是否位于geofence (形成多边形的许多经度对)内。org.locationtech.jts.io.ParseException;import io.confluent.ksql.function.udf.Udf;
import io.confluent.ksql.function.udf.UdfDescription;
浏览 14提问于2020-03-24得票数 0
回答已采纳
1回答
实现KSQL UDF "NOW()“
创建流my_notification_stream作为select *来自my_event_stream，其中occurTime +阈值< NOW()
浏览 0提问于2018-06-18得票数 0
在Ksql中创建自定义的UDAF时，我面临着一些问题。用例是在滚动的窗口中找到列的“第一”和“最后”值。在非洲发展新议程()中没有这样的构建，所以我试图创建自定义的联非新议程。我根据这个文档执行了以下步骤addAggregateFunctionFactory(new MyAggFunctionFactory());
在下面的路径$ confluent / ii.Build /j
浏览 0提问于2018-05-23得票数 1
回答已采纳
2回答
我在IntelliJ中创建了一个Maven项目，添加了.java文件，并允许IDE导入依赖项。然后运行mvn package，将生成的.jar复制到集群节点，并在Hive中添加.jar资源：Addedresources: [udf-row-sequence-1.0-SNAPSHOT.jar]hi
浏览 12提问于2015-08-05得票数 1
回答已采纳
我有一个名为getCityStats(string，double string)的自定义UDF，它接受2个参数并返回一个JSON字符串(对象)数组，如下所示
我想在KSQL表创建查询中将
浏览 0提问于2018-09-18得票数 0
1回答
我正在尝试设置kafka和ksql使用汇合平台，但ksql无法启动。(#------ Endpoint config -------)
listeners=http://0.0.0.0:8088: 15: 07 Mayank-Vostro-347
浏览 0提问于2019-08-27得票数 0
回答已采纳
1回答
当我试图从我的自定义导入jar注册一个UDF时，我的问题就出现了。这就是我如何在我的自定义jar中创建th的方式：import org.apache.spark.sql.api.java.UDF1;public class/test.udf.jar")或者像这样
spark.sparkContext.addJar("/user/
浏览 2提问于2021-01-28得票数 1
: "http://0.0.0.0:8088" KSQL_KSQL_SCHEMA_REGISTRY_URLKSQL_CONNECT_GROUP_ID: "ksql-connect-cluster"
KSQL_CONNECT_BOOTSTRAP_SERVERS: "b
浏览 13提问于2021-07-20得票数 2
CREATE FUNCTION hello AS 'com.dtstack.main.udf.HelloUDF' USING JAR 'hdfs:///172.16.1.151:9000/user/spark/sparkUDF.jar'select hello(xcval) from xctable
错误: org.apache.spark.sql.AnalysisException:未定义函数
浏览 0提问于2017-04-07得票数 0
回答已采纳
1回答
我正在尝试使用KSQL在一个时限内进行任何处理，并在那个时间限制中得到结果。请参阅“处理时间定时器”下面的，以获得使用Apache演示的相同想法。从概念上讲，我正在考虑创建第一个流的KTable，以保存事务的最新状态，并使用KSQL创建一个输出流，方法是使用(create_time +超时值)< current_time查询KTable中的键。(并将超时作为“更新”添加到第一个流中，这样我就可以从KTable中筛选出这些超时)
我还没有在KSQL文档中找到这样的方法，即使有一个内置的current_
浏览 1提问于2018-11-14得票数 1
回答已采纳
因此，我修改了我的撰写文件以直接下载ojdbc jar，但是在添加了这段代码之后，我无法启动Kafka-connect。-o ojdbc8-12.2.0.1.jar我也尝试过手动启动Kafka-connect容器，但它也不起作用。如果您在下面的屏幕截图中看到，所有服务都已成功创建。 KSQL</e
浏览 1提问于2020-06-06得票数 0
我创建了UDF来返回VARCHAR数组。在终端上创建函数的语法是什么，特别是如果返回是VARCHAR数组类型的话。例如，如果UDF返回VARCHAR：
CREATE FUNCTION "return_VARCHAR"(varchar) returns VARCHAR as 'GetNumbersFunction'USING JAR 'hdfs://127.0.0.1:2181/tmp/local/j
浏览 0提问于2018-03-22得票数 0
回答已采纳
1回答
KSQL表无法查看数据
、、、
合流平台: 6.1.1 问题:无法查看ksql表上的数据:- 1.)第一次创建的主题:- .COUNTRY-CSV --property parse.key=true --property key.separator=:>IN:IN,India 3.)已创建KSQL表:- ksql> CREATE TABLE COUNTRY_TABLE (countrycode VARCHAR PRIMARY KEY, countrynam
浏览 34提问于2021-05-09得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
