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

#source#

已有1人关注此标签

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

Flink idea启动WEBSERVER问题

环境: win10, idea2016, FLink1.7.1maven已经导入 <dependency> <groupId>org.apache.flink</groupId>…

Apache API string class source thread WebServer IDEA unit flink

如何检查python中最长的子串

我有一个文本和一个概念列表如下。 concepts = ["data mining", "data", "data source"]text = "levels and data mining of dna data source met…

python source

Flink 如何支持动态sql ?

flnk 新手一枚。。我理解flink stream = 动态table, 但是sql里的 where语句条件能否使用stream/source的值。 example: DataStream<String> input…

云栖社区 分布式系统与计算 SQL url stream source input flink

如何使用描述和不同的fill_color数组在散景图上绘制散点图?

我试过以下,但颜色仍然是蓝色。 from bokeh.plotting import figure, show, output_file, ColumnDataSource TOOLS="hover,crosshair,pan,wheel…

python open index source html 数组

flink1.7.1 写es6外部表没数据问题

用的是flink1.7.1,测试代码为 import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, _} import org.apache.flink…

Json Apache API string Elasticsearch schema index timestamp source type flink

我本地ide接入kafka数据源,source的并行度一直是4(和我电脑核数一样)怎么控制

我本地ide接入kafka数据源,source的并行度一直是4(和我电脑核数一样)怎么控制

source flink

可视化编程,你怎么看

可视化编程语言可以让程序员从键盘中解脱,通过拖动一个个图形组件完成程序。典型的例子有 Scratch,Node Red 等。阿里云物联网开发平台使用了可视化编程语言,无码化开发 Web 应用、移动应用甚至是 API。 但是也有人质疑可视化…

编程语言 程序员 aliyun 物联网 IOT 编程 source

如何在两个数组列中查找公共元素?

我有两个以逗号分隔的字符串列(sourceAuthors和targetAuthors)。 val df = Seq( ("Author1,Author2,Author3","Author2,Author3,Author1")).toDF…

java 线程 spark string UDF source unit 数组

如何在Spark Scala中读取嵌套JSON?

这是我的嵌套JSON文件。 {"dc_id": "dc-101","source": { "sensor-igauge": { "id": 10, "ip": "68.28.91.22", "description": "Se…

Json spark scala DataFrame IP source 数组

如何在spark-jdbc应用程序中提供表名来读取RDBMS数据库中的数据?

我正在尝试使用spark读取greenplum数据库中的表格,如下所示: val execQuery = s"select ${allColumns}, 0 as ${flagCol} from schema.table where pe…

java PostgreSQL Greenplum Apache 数据库 spark scala JDBC Core source

如何使用密钥中的ssh密钥将私有git存储库克隆到kubernetes pod?

我正在尝试使用SSH密钥进行身份验证,将私有git存储库(gitLab)克隆到kubernetes pod中。我秘密存储了我的钥匙。这是执行所需任务的作业的yaml文件。 执行后初始化容器的日志: fetch http://dl-cdn.…

SSH Image git metadata source 存储 k8s

将数据集<行>导出为CSV

我正在尝试根据一些Spark SQL结果生成CSV文件。 我试图填补所有空值,但徒劳无功。似乎与我正在配置它的方式有关。 这是我正在运行的代码。 SparkSession spark = SparkSession.builder().ap…

java hadoop SQL Apache shell spark scala Create source csv

如何在Homebrew中找到Apache Spark包的安装目录?

我用自制软件在我的mac上安装了spark。我正在尝试找到我安装它的目录。我需要在mac终端或spark shell中运行,以找到spark的安装目录? 更新: 码: brew info apache-spark输出: apache-sp…

mac Apache shell Processing spark source github brew

kafka conect cassandra source -error为十进制数据类型

我正在使用kafka connect cassandra source connector 1.0版本。我在cassandra表中有一个十进制数据类型列(价格),并将其作为json从源连接器写入kafka主题,它正在以类似的字符串格式写入十…

Json spark Cassandra source 数据类型

使用AvroParquetWriter将flink接收到parquet文件不会将数据写入文件

我正在尝试使用AvroParquetWriter将parquet文件写为接收器。文件已创建但长度为0(未写入数据)。无法清楚问题在哪里? import io.eels.component.parquet.ParquetWriterConf…

hadoop Apache path scala stream PUT schema source flink

具有多并行性的Flink Map功能,以及如何确保最终接收器的顺序

管道简单代码是研究员: source = env.addSource(kafkaConsumer).map(func).setParallelism(2).sink()如何确定顺序?

source flink

使用Table AggregateFunction和ResultTypeQueryable时的ValidationException

我正在使用配置为使用flink-tablejar 的本地Flink 1.6集群(意味着我的程序的jar不包括在内flink-table)。使用以下代码 import org.apache.flink.api.common.typeinfo…

java Apache API string static class void source type list arraylist flink

窗口操作员行为澄清后的Apache Flink KeyedStream

我要求澄清Apache Flink(1.6.0)在通过窗口发送事件后如何处理来自KeyedStreams的事件,并且已经应用​​了某些运算符(例如reduce()或process())。 假设单个节点集群在执行了键控窗口流上的运算符之后,…

Apache events reduce 集群 source list flink

适用于所有输入

我FlinkKafkaConsumer011订阅了一个主题。我希望apply在每个kafka consumer消息上进行process(),因此custom FooTrigger会返回TriggerResult.FIRE每个元素。 下面的…

Consumer Create source flink

5
GO