Hazelcast Jet坚持开始工作
Hazelcast Jet是一个分布式的实时流处理和批处理框架，主要用于处理大规模数据流和批量数据任务。它提供了快速、可靠、高性能的数据处理能力，可以轻松应对大数据量、高并发的场景。
Hazelcast Jet的优势在于其高性能和低延迟的数据处理能力。它采用了并行计算的方式，可以将任务分成多个小任务并行处理，以实现更快的计算速度。同时，Hazelcast Jet还支持事件驱动的编程模型，可以实时地处理数据流，并根据需要进行数据转换、过滤、聚合等操作。
Hazelcast Jet适用于各种数据处理场景，包括实时分析、实时报表生成、数据清洗与转换等。它可以用于构建实时的数据流处理系统，实现实时监控、实时推荐、实时预测等功能。此外，Hazelcast Jet还支持批处理任务，可以用于离线数据处理、数据分析等任务。
对于使用Hazelcast Jet进行开发，推荐使用腾讯云的TencentDB作为底层数据库存储，TencentDB提供了高可靠、高性能的云数据库服务，可以满足大规模数据处理的需求。另外，腾讯云的Serverless云函数（SCF）可以用于部署和运行Hazelcast Jet任务，提供了弹性的计算资源和自动扩缩容能力，适应不同规模的数据处理需求。
更多关于Hazelcast Jet的信息，你可以查看腾讯云官方文档：
请注意，以上答案只提供了腾讯云相关产品作为示例，并不代表其他云计算品牌商的产品不适用或不具备相应能力。
相关·内容
我对jet和hazelcast有一些问题，但我的问题是出于逻辑目的，我有一个类，它将带来所有数据，当我们启动客户端时，我们得到了一个队列和两个映射，但另一个映射尚未调用，当我启动hazelcast jet实例并处理所有数据时，我使用Sink：
rulesIntoTransaction.writeTo(Sinks.map(jet.getHazelcastInstance().getMap(RULESRESULT_MAP), Transaction::getTransactionId, Transaction::getRulesResult));
但这是错误的..。我知道当你调用这
浏览 5提问于2021-10-29得票数 0
"mvn clean validate“出现此错误。这个问题和一样吗？有人能帮我解决这个问题吗？我没有改变pom.xml。
Dependency convergence error for com.google.errorprone:error_prone_annotations:2.3.4 paths to dependency are:
+-com.hazelcast:hazelcast-distribution:5.0-SNAPSHOT
+-com.hazelcast.jet:hazelcast-jet-grpc:5.0-20210531.092806-178
浏览 17提问于2021-05-31得票数 0
回答已采纳
我在应用程序中使用Hazelcast IMDG。
我听说Hazelcast Jet提供了比Hazelcast IMDG更快的数据处理。
如果是。
Hazelcast Jet是开源的吗？
Hazelcast Jet提供所有可用的Hazelcast IMDG功能？
浏览 2提问于2020-09-14得票数 0
回答已采纳
我在Hazelcast Jet中遇到了奇怪的行为。我同时启动了多个作业(大约30个，有些是在其他作业之前触发的)。然而，当我的Hazelcast Jet任务数达到26 (魔术数字？)时，所有的处理都被卡住了。 在threadumps中，我看到了以下信息： "hz._hzInstance_1_jet.cached.thread-1" #37 prio=5 os_prio=0 cpu=1093.29ms elapsed=393.62s tid=0x00007f95dc007000 nid=0x6bfc in Object.wait() [0x00007f95e6af4000]
浏览 7提问于2019-03-21得票数 0
回答已采纳
我正在尝试执行以下Hazelcast sql查询：
private static final String SQL_FIND_BY_CLIENT_CODE =
"SELECT c.clientKey " +
"FROM client c " +
"JOIN client2system c2s on c2s.clientId = c.clientId " +
"WHERE c2s.systemId = ? " +
浏览 6提问于2022-09-06得票数 0
回答已采纳
在哈泽尔卡斯特喷气机( hazelcast Jet )工作时，我遇到了一个奇怪的问题。为了检查错误，我彻底地降低了我的方法和:它似乎没有发挥作用，根据本教程。
下面的代码几乎是最简单的。两个顶点(一个源，一个汇)，一个边。
源是从地图上读取的，水槽应该放进地图。
data.addEntryListener正确地告诉我，另一个应用程序填充了100个列表(每个列表有25个400字节的对象).然后什么都没有。地图被填满了，但是守护进程根本不与它交互。
知道在哪里找这个问题吗？
package be.andersch.clusterbench;
import com.fasterxml.jackso
浏览 7提问于2017-03-27得票数 1
回答已采纳
我有一个用例，我需要对一个巨大的csv文件进行排序，比如1000万条记录，然后将结果写到另一个文件中。hazelcast-jet / hazelcast是否在RAM有限的情况下提供了这样的外部排序功能？
浏览 1提问于2020-08-05得票数 3
我正在尝试使用hazelcast jet jdbc的连接池，但它不允许我这样做。我有一个Datasource bean，我正在从中获取连接，但它不工作。下面是我的代码：
Connection conn = ((DataSource)Ds.getBean("dataSourceName").getConnection();
BatchSource<Object> jdbcSource = Sources
.jdbc(() -> conn,
(con, parallelism, index)
浏览 8提问于2021-10-30得票数 1
我在Spring Boot v.2.0.3.RELEASE上运行hazelcast-jet-spring artifact (不是hazelcast-jet) v.0.6.1，并得到以下错误：
Caused by: java.lang.IllegalArgumentException: DataSerializableFactory[-45] is already registered! com.hazelcast.internal.journal.EventJournalDataSerializerHook$1@4a3e1b5d -> com.hazelcast.journal.Eve
浏览 9提问于2018-07-24得票数 0
回答已采纳
我已经测试过在Hazelcast版本5.0.2中运行良好，但是当我尝试将它与Jet管道作业一起使用时，就会得到低于序列化错误的结果。
线程"main“中的ProcessorTasklet{tb-batch-compact/mapSink(mymap1)#0}：com.hazelcast.nio.serialization.HazelcastSerializationException:异常: com.hazelcast.jet.JetException: com.hazelcast.jet.JetException中的异常未能在java.util.concurrent.Completa
浏览 0提问于2022-02-11得票数 0
如何读取Hazelcast喷气机的黑兹拉广播IMDG数据。
在我的例子中，我需要Hazlecast (分布式缓存)来存储将来的数据，还需要jet来执行批处理和流处理。
因此，我将使用Hazelcast IMDG(MapStore)保存数据，并使用Hazelcast jet进行过滤。
public class Test {
HazelcastInstance hz = Hazelcast.newHazelcastInstance();
JetInstance jet = Jet.newJetInstance();
public static void main(Str
浏览 12提问于2021-10-12得票数 0
回答已采纳
我在instructions here之后在亚马逊网络服务的ec2上建立了一个Hazelcast-jet集群。我利用了hazelcast-aws模型，这样节点就可以自动发现彼此。群集已启动并正在运行： [2019-09-26 22:26:26.288] [INFO ] com.hazelcast.config.AbstractConfigLocator - Using configuration file at /home/ec2-user/hazelcast-jet-3.1/config/hazelcast.xml
[2019-09-26 22:26:26.416] [INFO ]
浏览 12提问于2019-09-27得票数 1
回答已采纳
我试图使用RoutingPolicy.ISOLATED在上游和下游之间创建专用的连接，根据这个线程
另外，尝试使用DiagnosticProcessors.peekOutputP来验证来自同一个分区的消息是否被发送到相同的下游处理器。
以下是Jet初始化日志：
45:29,049 Loading hazelcast-jet-default.xml from classpath.
45:29,225 Loading hazelcast-jet-member-default.xml from classpath.
45:30,293 [172.21.0.1]:5701 [jet] [0.5.1]
浏览 1提问于2018-01-30得票数 0
回答已采纳
我是Hazelcast Jet的新手，有一个非常基本的问题。我设置了一个3节点的JET集群。我有一个示例代码从卡夫卡读取，并排出到一个IMap。当我从命令行运行它(使用jet-submit.sh并使用JetBootstrap.getInstance()获取JET客户端实例)时，它工作得非常好。当我运行相同的代码(使用Jet.newJetClient()获取实例并在->上作为Eclipse应用程序运行)时，我得到：
java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambd
浏览 0提问于2018-07-04得票数 0
我正在尝试过滤BatchStage，但它不工作，它给我以下错误： java.lang.IllegalArgumentException: "filterFn" must be serializable
at com.hazelcast.jet.impl.util.Util.checkSerializable(Util.java:203)
at com.hazelcast.jet.impl.pipeline.ComputeStageImplBase.attachFilter(ComputeStageImplBase.java:154)
at com.h
浏览 17提问于2021-07-12得票数 0
我们在一台服务器上托管了Hazelcast集群，在同一区域的不同服务器上的不同应用程序使用Hazelcast Jet客户端实例通过管道聚合来自Kafka源的数据。 在此设置中，Jet客户端实例是否发送从Kafka源Hazelcast集群接收的数据，这将涉及大量IO，或者当我们创建管道时，Hazelcast集群本身创建到Kafka的连接，此连接来自Jet集群而不是客户端应用程序？
浏览 22提问于2019-01-25得票数 0
我正在运行Hazelcast-Jet的3节点嵌入式集群，控制台中经常出现以下错误。可能的原因是什么？ [jet] [3.0] Execution of job '15ba-4fbe-1b73-9ed1', execution 61d7-46eb-5875-8799 failed after 60,112 ms
com.hazelcast.jet.JetException: Exception in ProcessorTasklet{streamKafka#1}: org.apache.kafka.common.errors.TimeoutException: Tim
浏览 14提问于2019-05-13得票数 0
我才刚开始学哈泽尔卡斯特喷气机。我的消息来源是UDP数据报。我希望在Jet的某些节点上并行处理它，并通过“域”将它们重新发送到其他地址。我想使用Hazelcast IMDG IMap与加载程序，以获得‘域’由‘源ip’。
DAG dag = new DAG();
Vertex source = dag.newVertex("datagram-source",
UdpSocketP.supplier("0.0.0.0", 41813));
source.localParallelism(1);
浏览 0提问于2017-07-24得票数 1
回答已采纳
1回答
我在用CDC做我的Postgres数据库。
我使用Hazelcast文档示例创建了一个简单的项目。
public static void main(String[] args) {
StreamSource<ChangeRecord> source = PostgresCdcSources.postgres("source").setDatabaseAddress("127.0.0.1")
.setDatabasePort(5432).setDatabaseUser("postgres"
浏览 6提问于2021-10-13得票数 2
回答已采纳
我正在创建一个spring引导应用程序，在我的应用程序中，我尝试在普通的spring应用程序中使用Hazelcast Jet，它工作正常，但是在尝试spring引导应用程序时，它无法访问bean。Bean是动态创建的，因此我可以通过AppBeans类访问它们。
对于依赖性，我有以下3条：
<dependency>
<groupId>com.hazelcast</groupId>
<artifactId>hazelcast-all</artifactId>
<version>4
浏览 18提问于2022-06-24得票数 0
我在Hazelcast IMDG中使用了下面的配置。 现在我也想对jet使用相同的配置。 @Bean
public static Config config() {
System.err.println("config class");
Config config = new Config();
config.setInstanceName("hazelcast");
MapConfig mapCfg = new MapConfig();
mapCfg.setNam
浏览 26提问于2021-10-12得票数 0
我是Hazelcast Jet的新手，我正在使用Spring来执行我的查询，它在查询中使用了命名参数，但我不确定如何将其与Hazelcast Jet一起使用。 例如，Hazelcast的工作方式如下： Pipeline p = Pipeline.create();
p.readFrom(Sources.jdbc(
() -> DriverManager.getConnection("jdbc:mysql://localhost:3306/mysql"),
(con, parallelism, index) -> {
Prepared
浏览 15提问于2021-05-08得票数 0
Hazelcast 3.9.1，Jet0.5.1
我有一个调用StreamSerializer (Clazz)的ObjectDataInput.readObject(clazz)，它看起来默认的java反序列化器没有实现jet: TypedStreamDeserializer所需的接口。
Caused by: com.hazelcast.nio.serialization.HazelcastSerializationException: StreamSerializerAdapter{serializer=com.hazelcast.internal.serialization.impl.Co
浏览 2提问于2018-01-19得票数 2
回答已采纳
我正在尝试将自定义处理器附加到Hazelcast Jet Pipeline定义。
以下是示例代码。
private Pipeline buildPipeline() {
Pipeline p = Pipeline.create();
p.drawFrom(Sources.<String, Record>remoteMapJournal("record",
getClientConfig(), START_FROM_OLDEST))
.addTimestamps((v) -> getTimeStamp(v), 3000)
浏览 1提问于2018-06-19得票数 0
1回答
在运行分布式流之后，看起来所有这些快照都不会从监视或其他方面删除。
即使作业已经完成，这些仍然是每5秒记录一次。如需执行，请提供咨询意见。
使用：
Hazelcast 3.9.1
0.5.1喷气机
2017-12-14 16:26:22,649 [hz.ttcore.cached.thread-8] DEBUG com.hazelcast.jet.impl.SnapshotRepository - [localhost]:18320 [ttcore] [0.5.1] Deleted all snapshots for job 857d-8e5e-0e20-df3b 2017-1
浏览 2提问于2017-12-14得票数 0
回答已采纳
我有一个现有的应用程序，它使用Hazelcast来跟踪集群成员关系和执行分布式任务。我在想，Jet对于在现有应用程序上添加分析可能很有用，我正在尝试找出如何在现有应用程序的基础上更好地分层Jet。
所以我的第一个问题是，如何在我们现有的Hazelcast配置之上运行Jet？我是否必须单独运行Jet，或者用Jet替换现有的Hazelcast配置(因为Jet确实公开了HazelcastInstance)。
我的第二个问题是，我看到了很多使用IMap和IList的例子，但我没有看到任何使用主题作为源代码的东西(我也不认为这是源代码构建器的一个选项)。我使用Jet的最初想法是从现有代码向主题发出事件(
浏览 15提问于2020-05-27得票数 1
回答已采纳
我有一个OBJECT格式的Hazelcast IMap中的项目，我正在使用一个Jet聚合操作，并将该IMap作为管道源。由于对象格式的原因，我希望在处理过程中避免对IMap中的项进行任何序列化/反序列化，这与原生Hazelcast条目处理和查询的工作方式相同。但是，我可以看到，我的项目实际上正在被序列化，然后在被传递到我的聚合器之前被反序列化。
当以这种方式使用Jet时，是否有可能避免序列化/反序列化步骤？如果是这样的话，是怎么做的？
浏览 2提问于2020-08-18得票数 1
Hazelcast Jet是否可以使用多个客户端访问一个事件日志来处理数百万条记录，并且每个客户端将处理一部分记录？
此外，是否可以将不同客户端处理的结果进行累积？
浏览 2提问于2018-04-09得票数 0
我正试图在一个分布式系统上运行一个Hazelcast-jet 。我的目标是在分布式系统上运行代码，利用多台机器的处理能力。我有两台笔记本电脑通过局域网连接。当我在一台机器上运行这个例子时，它工作得很好，为了同时运行它，我只使用jet实例启动Machine1和Machine2。两台机器上的代码是，
机1
public class PrimeFinder {
public static void main(String[] args) {
System.setProperty("hazelcast.logging.type", "log4j"
浏览 7提问于2019-11-09得票数 1
回答已采纳
我正在尝试形成一个jet集群(不是在客户机-服务器部署策略中，而是在嵌入式策略中)。
已尝试多播和TCP发现，但仍未成功。当我尝试使用docker-compose文件扩展多个容器时，两个容器都出现了，但没有形成集群。
我正在以编程的方式传递集群成员信息。
JetConfig cfg = new JetConfig();
Configuration jsonObject = getJetConfigs();
cfg.getHazelcastConfig().getNetworkConfig().setPortAutoIncrement(true);
浏览 3提问于2020-02-28得票数 0
我们正在使用Hazelcast Jet0.4版本来读取Kafka来源的信息，处理这些消息并将其写入Kafka。由于卡夫卡是由一个外部团队管理的，我们无法控制卡夫卡抛出的各种异常。
例如，我们收到以下异常:无法完成提交，因为组已经重新平衡并分配了分区
当我们收到此错误时，Hazelcast Jet实例将被关闭。因此，我们的应用程序变得不可用，我们必须重新启动应用程序。
我们正在研究在这些错误期间自动重新启动Jet实例的可能性。
谢谢你的帮忙!
浏览 1提问于2018-06-29得票数 0
我一直在浏览hazelcast-jet文档，寻找一些外部进程异步提供的源的引用--在我的例子中是http post。
我确实查看了，因为这似乎是最接近的，但我不知道新到达的事件如何触发任何事情。我假设，这里不会涉及阻塞线程。
我非常感谢任何能更好地理解我如何在一个“stream”元素被点滴输入的环境中使用hazelcast jet的建议。
浏览 3提问于2018-09-24得票数 1
我正在尝试更快地使用Hazelcast Jet作为处理管道，并开始更深入地研究源代码文档 https://jet-start.sh/docs/api/sources-sinks#sources 我非常惊讶地看到Hazelcast Topics和ReliableTopics不是原生支持的源码，但是Kafka和JmsQueue是开箱即用的。我确实看到了一种哈兹卡斯特的reliabletopic is a supported sink。这让我怀疑我是否误解了一个主题作为管道的有效来源。 我是不是误解了什么？
浏览 20提问于2020-12-07得票数 1
回答已采纳
我是哈泽尔卡斯特喷气机的新手，我的用例是从卡夫卡的源代码和过滤器中读取它在hazelcastIMDG中的价值。
我正在获取和加载IMDG地图甚至在创建管道之前。见下文
IMap<String, Policy> policyMap =jet.getHazelcastInstance().getMap(POLICY_MAP_NAME);
Utility.populatePoliciesMap(policyMap);
在policyMap方法中将buildPipeline作为param传递。
我创建了一个管道，如下所示
StreamStage<Timest
浏览 0提问于2019-04-05得票数 1
回答已采纳
我有一个http端点，客户端使用其数据发出请求，计算出的响应将返回到该请求。计算有几个阶段-- data lookup，calculations和少量的transformations。最终结果将作为对请求的响应写入。 我是否可以编写一个Hazelcast Jet作业，它接受在http中接收到的数据，上面定义的所有计算并将结果返回给请求吗？ 我看不到直接的方法，但是，我看到的一种方法是，有一个响应式http服务器，以响应式方式读取请求，将请求写入Ringbuffer或IQueue，并在另一个Ringbuffer中等待结果(在回调的帮助下)。 Hazelcast作业可以从源Ringbuffer读
浏览 28提问于2020-01-08得票数 0
更具体地说，Hazelcast Jet解决了Flink没有解决的问题(同样好)，反之亦然？
浏览 3提问于2017-02-15得票数 11
我正在使用hazelcast jet来聚集数据流 源是kafka，其中我接收整数，而jet stream只是简单地将每个传入数字相加。 我有几个问题1.当它接收到每个数字并将数据保存在IMap中时，我如何访问该快照？
浏览 80提问于2019-01-24得票数 0
我正在尝试使用Hazelcast jet.For分析传感器数据，我需要打开Tcp套接字并处理通过它获得的信息。
浏览 3提问于2017-07-13得票数 0
回答已采纳
我想要运行嵌入在我的spring应用程序中的 (即集群在进程中，而不是远程)。我还希望我的jet作业能够从ApplicationContext访问spring (参见)。我不想在每个jet作业上配置类路径，我想使用JVM的引导类路径。
我认为我需要使用来获得一个，但这不允许我在底层上设置ManagedContext。Jet.bootstrappedInstance()的文档详细介绍了我想要与Jet交互的方式
当您将作业提交给在JVM中本地运行的Jet实例时，它将拥有所有可用的依赖类
我试过这个：
@Bean
public ManagedContext managedContext()
浏览 4提问于2021-10-21得票数 0
hazelcast-jet如何实现与早期通过在IMap中提交密钥上的EntryProcessors有很大不同的结果？
好奇地想知道。
浏览 2提问于2017-02-22得票数 1
我在我的应用程序中使用Hazelcast IMDG。
所以我有两个IMap实例a1和a2。
IMap<Integer, School> a1 = hazelCast.getMap("a1");
//school_id, student_id, highest marks
a1.put(i,new School("1", "101", "99.99"));
IMap<Integer, Student> a1 = hazelCast.getMa
浏览 3提问于2020-09-15得票数 0
你好，我在从github到我的项目中实现一些代码源代码时遇到了问题，所以……我正在尝试构建一个管道，然后创建StreamStage来读取源代码，并使用项目内部的方法构建队列链接，但我总是得到相同的错误"Exception in thread "main“java.lang.IllegalArgumentException："mapFn”必须是可序列化的“ 我正在阅读关于Hazelcast Jet序列化的文档，一切看起来都很完美，我只是不知道项目内部的问题是什么 以下是属性和常量： public class FraudDetectionRun implements Se
浏览 39提问于2021-10-11得票数 1
回答已采纳
我真的很喜欢jazelcast jet与java util流一起工作的方式，但是当我运行这些流时，我搞不懂它是如何以分布式的方式运行的。
public class IstreamHazelcastDemo {
public static void main( String[] args ) {
JetInstance jet = Jet.newJetInstance();
Jet.newJetInstance();
IListJet<String> list = jet.getList("list"
浏览 23提问于2018-07-30得票数 1
回答已采纳
我正在尝试在Spark Structured和Hazelcast Jet之间映射一些概念，并理解其他主题。
Q1 -在Spark中，每个Kafka分区将成为spark中的一个分区，然后它们将由单个任务并行处理。我想我在某处读到过Hazelcast Jet将合并来自kafka的所有消息，而不考虑group.id和主题分区，对吗？
Q2 -我们如何在Jet程序中增加“消费者”的数量，以增加来自kafka的吞吐量消耗？在Spark中，我想我们只需要增加主题分区的数量，以便为新分区分配新的spark任务。
Q3 -如果上面的Q1是真的，有可能避免合并和分发要并行处理的kafka分区吗？一旦消息已经在k
浏览 0提问于2018-01-23得票数 2
我想对一个即时的推特流做一个简单的分析。
如何在不需要DAG的情况下使用Hazelcast Jet中的Twitter流源？
详细信息
Twitter的封装非常适合于。
但是，调用方使用它作为DAG的一部分，c/o：
Vertex twitterSource =
dag.newVertex("twitter", StreamTwitterP.streamTwitterP(properties, terms));
我的用例不需要DAG的功能，所以我宁愿避免不必要的额外复杂性。
为了避免DAG，我希望使用SourceBuilder来为动态的tweet流定义一个新的数据源。
我假
浏览 0提问于2018-11-13得票数 1
回答已采纳
我是新来Hazelcast的。当在HazelCast Jet管道上触发带谓词的Imap filter时，在VDI中，我看到处理器计数只有2，而在我的机器上，我看到12个处理器。
当只有两个处理器时，筛选器作业完成得非常快。但是当我在我的机器上看到12个处理器时，过滤作业会持续运行更长的时间，并持续记录一行Hazelcast healthmonitor日志和超时。我假设这就是问题所在。
根据我的搜索，我了解到Hazelcast基于CPU创建了多个处理器。如何控制此处理器的计数。
下面是创建Hazelcast jet客户端并在管道上应用IMap过滤器时的日志行。
对不起，由于对Hazelcast的
浏览 6提问于2021-06-09得票数 0
我正在使用hazelcast jet对流数据执行聚合。问题是，hazelcast客户端意外关闭。
我已经使用远程映射源实现了简单的管道，然后结果被简单地下沉。
// init pipeline
Pipeline p = Pipeline.create();
// configure source
BatchSource remoteBatchMap = Sources.remoteMap(<my remote map>, <my config>);
// add source and sink to pipeline
p.drawFrom(remoteBatchMa
浏览 0提问于2019-07-25得票数 1
我得到了一个异常，如：
使用Hazelcast: 3.9.1和Jet: 0.5.1
这是在将集群内嵌的jcache bean添加到集群中之后开始的，该集群的客户端也使用具有近缓存的相同缓存。
2018-02-28 15:52:01,904 [hz.ttcore.event-3] ERROR c.h.s.i.e.i.EventServiceImpl - [192.168.70.25]:18320 [ttcore] [0.5.1] hz.ttcore.event-3 caught an exception while processing task:com.hazelcast.spi.impl.e
浏览 1提问于2018-02-28得票数 0
回答已采纳
我正在尝试使用Hazelcast Jet根据最大日期对List<Map<String,Object>>对象进行排序。 下面是我的java 8代码： public static List<Map<String, Object>> extractDate1(List<Map<String, Object>> data) {
return data.stream().map(value -> new Object() {
Map<String, Object> theMap = val
浏览 31提问于2021-04-01得票数 0
回答已采纳
我使用hazelcast jet 0.6.1进行实时分析。有来自不同来源的多个流(主要来自远程日志)。
我想知道，在多个流之间是否支持完全加入。
如果是，请您给我一些链接/示例，以便在多个流之间完全加入。
浏览 0提问于2019-01-07得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
