angularjs和bootstrap 更多内容
  • Kafka源表

    topic 是 kafka topic名。该参数“connector.topic-pattern”两个参数只能使用其中一个。 connector.topic-pattern 否 匹配读取kafka topic名称的正则表达式。该参数“connector.topic”两个参数只能使用其中一个。

    来自:帮助中心

    查看更多 →

  • 使用Kafka客户端SSL加密

    properties”“consumer.properties”中的“security.protocol”的值,同时修改“producer.properties”中的“bootstrap.servers”的值,确保security.protocol协议类型bootstrap.servers中的端口号匹配。

    来自:帮助中心

    查看更多 →

  • Flink Join样例程序(Java)

    jar,该jar包可在client目录下获取。 下面列出producerconsumer,以及Flink Stream SQL Join使用主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafkacom.huawei.bigdata.flink

    来自:帮助中心

    查看更多 →

  • Flink Join样例程序(Scala)

    jar,该jar包可在Kafka客户端目录下获取。 下面列出producerconsumer,以及Flink Stream SQL Join使用主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafkacom.huawei.bigdata.flink

    来自:帮助中心

    查看更多 →

  • MRS Kafka输出流

    ka中。 kafka_bootstrap_servers 是 Kafka的连接端口,需要确保能连通(需要通过增强型跨源开通 DLI 队列Kafka集群的连接)。 kafka_topic 是 写入的topic。 encode 是 编码格式,当前支持“json”“user_defined”。

    来自:帮助中心

    查看更多 →

  • 创建函数

    创建函数 能否在函数代码中使用线程进程? FunctionGraph函数工程打包有哪些规范(限制)? FunctionGraph如何隔离代码? HTTP函数bootstrap启动文件如何创建?

    来自:帮助中心

    查看更多 →

  • JBoss Standalone模式如何接入APM?

    APM支持JBoss 服务器 ,JBoss在使用Java探针时,需要特殊的设置。 下面举例对JBoss 6.2.0、JBoss 8.1.0 JBoss 12.0.0的Standalone模式接入APM进行说明,其他JBoss的版本类似操作。 JBoss 6.2.0: 将standalone模式下的eap-6

    来自:帮助中心

    查看更多 →

  • 添加Kafka的Ranger访问权限策略

    be”“Describe Configs”。 说明: 目前Kafka内核支持"--zookeeper""--bootstrap-server"两种方式查询Topic,社区将会在后续的版本中删掉对"--zookeeper"的支持,所以建议用户使用"--bootstrap-server"的方式查询Topic。

    来自:帮助中心

    查看更多 →

  • Kafka源表

    topic 是 kafka topic名。该参数“connector.topic-pattern”两个参数只能使用其中一个。 connector.topic-pattern 否 匹配读取kafka topic名称的正则表达式。该参数“connector.topic”两个参数只能使用其中一个。

    来自:帮助中心

    查看更多 →

  • Kafka结果表

    DLI将Flink作业的输出数据输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统,具有高吞吐量、内置分区、支持数据副本容错的特性,适合在大规模消息处理场景中使用。 前提条件 Kafka是线下集群,需要通过增强型跨源连接功能将Flink作业与Kafka进行对接

    来自:帮助中心

    查看更多 →

  • 开源Kafka输出流

    区、支持数据副本容错的特性,适合在大规模消息处理场景中使用。 前提条件 Kafka服务端的端口如果监听在hostname上,则需要将Kafka Broker节点的hostnameIP的对应关系添加到DLI队列中。Kafka Broker节点的hostnameIP请联系Kaf

    来自:帮助中心

    查看更多 →

  • 编译并调测Flink应用

    例,否则可能会导致任务失败,并可能导致应用部分临时数据无法清空。 请确保Jar包配置文件的用户权限与Flink客户端一致,例如都是omm用户,且权限为755。 运行DataStream(ScalaJava)样例程序。 在终端另开一个窗口,进入Flink客户端目录,调用bin/flink

    来自:帮助中心

    查看更多 →

  • Upsert Kafka结果表

    Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统,具有高吞吐量、内置分区、支持数据副本容错的特性,适合在大规模消息处理场景中使用。 前提条件 Kafka是线下集群,需要通过增强型跨源连接功能将Flink作业与Kafka进行对接

    来自:帮助中心

    查看更多 →

  • 开发HTTP函数

    架同理。相关约束条件请参考Base64解码返回结构体的说明。 HTTP函数默认开放端口为8000。 Context类中提供了许多上下文方法供用户使用,其声明功能请参见表1。 创建bootstrap文件。 把项目文件bootstrap文件打包成zip包。以koa框架为例: 父主题:

    来自:帮助中心

    查看更多 →

  • KafkaConfig类说明

    a客户端进行配置。 构造器详情 public KafkaConfig() 构造一个无参数的KafkaConfig 方法列表 返回类型 方法说明 static KafkaConfig getConfig(String servers, String groupId) 获取一个配置

    来自:帮助中心

    查看更多 →

  • Flink Join样例程序(Java)

    running = false; } } } 生成Table1Table2,并使用Join对Table1Table2进行联合查询,打印输出结果。 下面代码片段仅为演示,完整代码参见FlinkStreamSqlJoinExample样例工程下的com

    来自:帮助中心

    查看更多 →

  • MRS Kafka输出流

    ka中。 kafka_bootstrap_servers 是 Kafka的连接端口,需要确保能连通(需要通过增强型跨源开通DLI队列Kafka集群的连接)。 kafka_topic 是 写入的topic。 encode 是 编码格式,当前支持“json”“user_defined”。

    来自:帮助中心

    查看更多 →

  • Flink Join样例程序(Java)

    jar,该jar包可在Kafka客户端目录下获取。 下面列出producerconsumer,以及Flink Stream SQL Join使用主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafkacom.huawei.bigdata.flink

    来自:帮助中心

    查看更多 →

  • 编译并调测Flink应用

    指本地文件系统中文件路径,每个节点都需要放一份/opt/log1.txt/opt/log2.txt。可以默认,也可以设置。 <windowTime> 指窗口时间大小,以分钟为单位。可以默认,也可以设置。 运行向Kafka生产并消费数据样例程序(ScalaJava语言)。 生产数据的执行命令启动程序。 bin/flink

    来自:帮助中心

    查看更多 →

  • 开源Kafka输入流

    区、支持数据副本容错的特性,适合在大规模消息处理场景中使用。 前提条件 Kafka服务端的端口如果监听在hostname上,则需要将Kafka Broker节点的hostnameIP的对应关系添加到DLI队列中。Kafka Broker节点的hostnameIP请联系Kaf

    来自:帮助中心

    查看更多 →

  • 编译并调测Flink应用

    临时数据无法清空。 请确保Jar包配置文件的用户权限与Flink客户端一致,例如都是omm用户,且权限为755。 MRS 3.2.1及以后版本使用-tm指定taskmanager内存不能小于4096MB。 运行DataStream(ScalaJava)样例程序。 在终端另开一

    来自:帮助中心

    查看更多 →

共105条
看了本文的人还看了