不带addSink的ScreenCapturerAndroid
是指在Android平台上的屏幕捕获器，它用于捕获设备屏幕上的内容。具体来说，不带addSink的ScreenCapturerAndroid是WebRTC（Web实时通信）库中的一个组件，用于在Android设备上捕获屏幕内容并将其传输到远程端。
该组件的主要功能是捕获Android设备屏幕上的图像和视频，并将其编码为WebRTC支持的格式，以便进行实时传输。它可以用于各种应用场景，如远程会议、屏幕共享、远程教育等。
不带addSink的ScreenCapturerAndroid的优势包括：
- 简单易用：该组件提供了简单的接口和配置选项，方便开发人员集成和使用。
- 高效性能：它使用高效的图像和视频编码算法，以最小化带宽和延迟，并提供流畅的实时传输体验。
- 可定制性：开发人员可以根据自己的需求进行定制和扩展，以满足特定应用场景的要求。
腾讯云提供了一系列与屏幕捕获和实时通信相关的产品和服务，可以与不带addSink的ScreenCapturerAndroid结合使用，以构建完整的解决方案。以下是一些推荐的腾讯云产品和产品介绍链接地址：
- 腾讯云实时音视频（TRTC）：提供了高品质、低延迟的实时音视频通信能力，可用于实现屏幕共享、远程会议等场景。详细信息请参考：https://cloud.tencent.com/product/trtc
- 腾讯云云服务器（CVM）：提供了可靠、安全的云服务器实例，可用于部署和运行不带addSink的ScreenCapturerAndroid等应用程序。详细信息请参考：https://cloud.tencent.com/product/cvm
- 腾讯云对象存储（COS）：提供了可扩展、安全的云存储服务，可用于存储和管理不带addSink的ScreenCapturerAndroid捕获的图像和视频数据。详细信息请参考：https://cloud.tencent.com/product/cos
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行。
相关·内容
当我使用处理器API编写应用程序时，如果我使用addSink将日志推到下游主题，则日志不会按其键进行分区。
我一步一步地调试，DefaultStreamPartitioner没有被执行，我没有在源代码中找到关于接收器streamPartitioner的注释。
那么，当DefaultStreamPartitioner函数中没有指定除法器时，会应用addSink吗？
ie：
topology
.addSource("Source", inputTopic)
.addProcessor("LogToEvents", () -> n
浏览 0提问于2018-09-29得票数 2
回答已采纳
我有一个flink作业，并行度设置为6，很少有简单的转换，问题是当Flink运行超过12小时时，例如机器上的负载开始增加，然后我认为这是因为在一天中的某些小时内进入flink的流量，但问题是当流量下降时，机器上的负载继续增加，比以前低，但仍然更高。
使用案例：
DataStream<Event> from_source = rabbitConsumer
.flatMap(new RabbitMQConsumer())
.assignTimestampsAndWatermarks(new PeriodicExtracto
浏览 84提问于2020-08-01得票数 0
我有一个来自卡夫卡的DataStream，它对MyModel中的一个字段有2个可能的值。MyModel是一个pojo，其域特定字段是从Kafka的消息中解析出来的。
DataStream<MyModel> stream = env.addSource(myKafkaConsumer);
我想分别在每个键a1和a2上应用窗口和操作符。分离他们的好方法是什么？我有两个选项过滤器和选择在脑海中，但不知道哪一个更快。
滤波方法
stream
.filter(<MyModel.a == a1>)
.keyBy()
.window()
浏览 0提问于2018-12-03得票数 9
回答已采纳
我想用两个不同的水槽来消费Source。
简化示例：
val source = Source(1 to 20)
val addSink = Sink.fold[Int, Int](0)(_ + _)
val subtractSink = Sink.fold[Int, Int](0)(_ - _)
val graph = GraphDSL.create() { implicit builder =>
import GraphDSL.Implicits._
val bcast = builder.add(Broadcast[Int](2))
source ~> bc
浏览 15提问于2019-07-09得票数 2
回答已采纳
我正在尝试将Flink中的处理过的字数写到一个kafka主题。错误是
“类型DataStream>中的方法addSink(SinkFunction>)不适用于参数(FlinkKafkaProducer09)”
对于下面的代码-
DataStream<Tuple2<String, Integer>> stream1 = stream.flatMap(new LineSplitter())
.keyBy(0).sum(1);
stream1.print();
env.execute();
stream1.addSink(new FlinkKafkaPr
浏览 1提问于2016-08-01得票数 0
我想从卡夫卡主题读取流数据，并写入S3的avro，或拼图，格式。数据流看起来像json字符串，但我不能转换和写入avro或拼图，格式的S3。
我找到了一些代码片段并尝试
val .forBulkFormat=新路径(OutputS3Path)，val .build()
但是我在addSink得到了“类型不匹配，预期的SinkFunctionString，实际的: StreamingFileSinkTextOut”
val .addSource=环境信宿(MyConsumerSource).addSink(信宿)
请帮帮忙，谢谢！
浏览 46提问于2019-07-11得票数 1
1回答
我想在Apache中实现以下场景：
考虑到有4个分区的Kafka主题，我想使用不同的逻辑在Flink中独立地处理分区内的数据，这取决于事件的类型。
特别是，假设输入的Kafka主题包含前面图像中描述的事件。每个事件都有不同的结构:分区1的字段"a“作为键，分区2的字段"b”作为键，等等。在Flink中，我想根据事件应用不同的业务逻辑，所以我认为应该以某种方式分割流。为了达到图中所描述的目的，我认为只使用一个用户就可以做到这样的事情(我不明白为什么我应该使用更多)：
FlinkKafkaConsumer<..> consumer = ...
DataStre
浏览 2提问于2020-10-03得票数 2
回答已采纳
1回答
我正在建立一个从Kafka到HDFS的flink管道。我想在addSink()步骤之后处理这些元素。这是因为我希望设置触发器文件，指示为某个分区/小时编写数据(到接收器)已经完成。如何才能做到这一点？目前我正在使用水桶水槽。
DataStream messageStream = env .addSource(flinkKafkaConsumer011)；
//将消息流转换为keyedStream的一些聚合
KeyedStream.addSink(汇)；
//如何在3点之后处理元素？
浏览 0提问于2019-01-08得票数 1
1回答
我试图用Flink构建一个流事件相关引擎，并且我有一些关于作业执行的问题。
在我的体系结构中，我需要有不同的数据源，例如：
firewallStream= environment.addSource([FirewalLogsSource]);
proxyStream = environment.addSource([ProxyLogsSource]);
对于每一个来源，我需要应用一套规则。因此，假设我有一个作业，它将代理流数据作为源，其规则如下：
//Abnormal Request Method
stream.[RuleLogic].addSink([output])
//Web S
浏览 5提问于2016-11-02得票数 1
我在Apache Flink 1.10中求和字段如下，我接收RabbitMQ消息并在内存中处理它，最后将其保存到MySQL中，求和操作代码如下： consumeRecord.keyBy("gameType")
.window(TumblingEventTimeWindows.of(Time.seconds(5)))
.sum("realPumpAmount")
.addSink(new SinkFunction<ReportPump>() {
浏览 160提问于2020-04-08得票数 0
回答已采纳
在Flink中，一个作业可以有多个source->process->sink数据处理，例如 val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime) env.addSource(new Source1()).name("Source1").addSink(new Sink1()).name("Sink1").setParallelism(1) env.a
浏览 11提问于2020-08-30得票数 0
2回答
如何在多个变压器之间使用相同的id访问状态，例如，以下内容通过ValueState在OrderMapper类中存储订单对象：
env.addSource(source1()).keyBy(Order::getId).flatMap(new OrderMapper()).addSink(sink1());
现在，我想通过一个SubOrderMapper类访问同一个Order对象：
env.addSource(source2()).keyBy(SubOrder::getOrderId).flatMap(new SubOrderMapper()).addSink(sink2());
编辑:看起来不可
浏览 8提问于2022-12-01得票数 0
我是Flink的新手。我正在尝试使用Flink 1.3.2来读取我们的Kinesis流，并将输出写入Cassandra表。该程序能够从Kinesis流式传输数据。
问题是，当我执行“CassandraSink.addSink(CountsStreaming)”时，它给出“类型不匹配。预期: DataStreamNotInferredIN，实际: DataStream(String，Long)”。我已经阅读了文档和源代码，并注意到addSink使用DataStreamIN。
有没有人能帮我理解一下“IN”类型是什么，以及如何解决这个问题？
提前感谢！
val env = StreamExecut
浏览 0提问于2017-12-01得票数 0
我的事件是这样的：case class Event(user: User, stats: Map[StatType, Int]) 每个事件都包含+1或-1值。我目前的管道运行良好，但每次统计数据的变化都会产生新的事件。 eventsStream
.keyBy(extractKey)
.reduce(reduceFunc)
.map(prepareRequest)
.addSink(sink) 在将这些增量与当前状态合并之前，我希望在一个时间窗口中聚合这些增量。所以我想要相同的滚动缩减，但要有一个时间窗口。 当前的简单滚动reduce： 500 – last r
浏览 32提问于2021-04-22得票数 1
我正在尝试实现一个简单的闪光作业，使用org.apache.flink.streaming.connectors，将一个卡夫卡主题作为输入源和输出到一个卡夫卡接收器。我正在遵循这个指南https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/并编写代码 FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<>(TOPIC_IN, new SimpleStringS
浏览 92提问于2021-08-28得票数 0
1回答
我有一个Flink流程序，在经过长时间转换逻辑之后，它具有分支处理逻辑。长转换逻辑会被多次执行吗？伪码：
env = getEnvironment();
DataStream<Event> inputStream = getInputStream();
tempStream = inputStream.map(very_heavy_computation_func)
output1 = tempStream.map(func1);
output1.addSink(sink1);
output2 = tempStream.map(func2);
output2.addSink(
浏览 0提问于2021-06-02得票数 0
我正在尝试使用Apache Flink来处理使用两种不同算法的数据流。我的伪代码如下：
env = getEnvironment();
DataStream<Event> inputStream = getInputStream();
// How to replicate the input stream?
Array[DataStream<Event>] inputStreams = inputStream.clone()
// apply different operations on the replicated streams
outputOne = inp
浏览 7提问于2017-06-20得票数 2
回答已采纳
stream.addSink(new FlinkKafkaProducer09<String>("Topic-name", new SimpleStringSchema(),
properties));
FlinkkafkaProducer是否有回调或完成操作？
浏览 2提问于2016-08-10得票数 1
1回答
请审查以下代码，让我知道我需要改变显示远程视频。音频播放正常。使用最新的Webrtc.In onAddStream方法库，我得到了1的视频轨道大小，但不是在remoteVideoTrack addSink方法中渲染。
private PeerConnection createPeerConnection(PeerConnectionFactory peerConnectionFactory, boolean isLocal) {
//
PeerConnection.RTCConfiguration rtcConfig = new PeerConnection.RTCConfi
浏览 105提问于2019-11-08得票数 1
我从一个流中读取，并向另一个流中写入。我的代码如下所示 env.addSource(source).addSink(sink) 我还需要发射水印吗？
浏览 14提问于2020-11-19得票数 0
使用kafka流处理器api
场景: streams处理器(使用kafka处理器api实现)读取源主题中的数据，并根据某些buisness逻辑将数据写入目标主题。
代码：
Properties props = new Properties();
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "StreamsProcessor");
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "dev_cluster.org:9092");
props.put(
浏览 2提问于2020-06-26得票数 0
1回答
我正在努力学习Flink，我正在做基本的WordCount教程。我想知道如何对datastream的输出进行排序，以便它按降序输出计数。我不需要将其保存为文本文件，只需按降序输出到控制台。
以下是主要功能中的
DataStream<String> text = env.readTextFile(<PATH TO TEXT>)
DataStream<Tuple2<String, Integer>> counts =
text.flatMap(new Tokenizer())
.keyBy(0)
.sum(1);
c
浏览 11提问于2022-04-06得票数 0
回答已采纳
我有一个来自卡夫卡的flink程序，我打开了三个窗口流:秒，分钟，hours.Then通过AsyncHttpSink扩展RichSinkFunction.But发送窗口结果。我发现同一个窗口，一个卡夫卡消息，同一个结果可能多次调用AsyncHttpSink.invoke()函数，这引起了我的好奇，难道不是在同一个窗口中只发生一次吗，一个卡夫卡消息，同一个结果？
hourOperator.addSink(httpSink(WindowType.h));
minuteOperator.addSink(httpSink(WindowType.m));
secondOperator.addSink(h
浏览 9提问于2022-04-20得票数 0
我使用下面的scala代码来运行我的flink流作业
val mystream = StreamExecutionEnvironment.getExecutionEnvironment
mystream.addSource(new mySource(params))
.map(new myMap(params))
.addSink(new mySink(params)).setParallelism(1)
mystream.setParallelism(1)
mystream.execute("My Streaming")
当我使
浏览 4提问于2020-05-14得票数 0
回答已采纳
1回答
单源多汇v/s平面图
、、、
我在Flink上使用Kinesis Data Analytics进行流处理。
我正在处理的用例是从单个Kinesis流中读取记录，并在经过一些转换后写入多个S3存储桶。一个源记录可能会在多个S3存储桶中结束。我们需要写入多个存储桶，因为源记录包含大量信息，这些信息需要拆分到多个S3存储桶中。
我尝试使用多个接收器来实现这一点。
private static <T> SinkFunction<T> createS3SinkFromStaticConfig(String path, Class<T> type) {
OutputFileConfi
浏览 7提问于2021-01-29得票数 0
我有一个并行度为8的映射DataStream，我在DataStream中添加了两个接收器。一个是缓慢的(弹性搜索)，另一个是快速(HDFS)。但是，我的事件只在被刷新到ES之后才写到HDFS，所以使用ES比使用w/o ES花费的时间更长。
dataStream.setParallelism(8);
dataStream.addSink(elasticsearchSink);
dataStream.addSink(hdfsSink);
在我看来，两个接收器都使用相同的线程。是否可以使用两个接收器使用相同的源，或者我是否需要添加另一个作业(一个用于接收器)来并行编写输出？
我检查了Map(1/8)
浏览 4提问于2016-09-30得票数 6
回答已采纳
首先让我问我的问题，然后请你澄清我关于应用method?Question:的假设，如果我的应用程序每隔一分钟就创建1.500.000条记录，而flink作业用15++不同的操作符从卡夫卡消费者那里读取这些记录，那么这个逻辑会产生延迟、背压等等。(您可以假设并行性是)。
public class Sample{
//op1 =
kafkaSource
.keyBy(something)
.timeWindow(Time.minutes(1))
.apply(new ApplySomet
浏览 1提问于2020-05-27得票数 1
回答已采纳
我想设置Flink kafka生产者semantic.EXACTLY_ONCE，我使用scala代码，如下所示 alertEnrichStream.map(_.toJsonStr)
.addSink(
new FlinkKafkaProducer011(
kafkaBrokers,
kafkaOutputTopic,
new SimpleStringSchema)) 如何编辑代码来设置语义？
浏览 6提问于2019-02-25得票数 0
我有像这样的json {
"name":"someone",
"job":"doctor",
"etc":"etc"
} 在每个json中有不同的“工作”值，如医生、飞行员、司机、看门人等。我想根据“工作”值将每个json分开，并将其存储在不同的位置，如/home/doctor、/home/pilot、/home/driver等。 我已经尝试过SplitStream函数来做这件事，但是我必须指定那些值来匹配条件。 public class MyFlinkJob {
pri
浏览 21提问于2019-04-25得票数 0
回答已采纳
我有一个高度并行化的聚合，我在多个节点上运行了很多密钥。然后，我想对所有类似于下面代码的值进行汇总：
val myStream = sourceStream
.keyBy( 0 )
.window(TumblingProcessingTimeWindows.of(Time.minutes(5)))
.reduce(_ + _)
.addSink(new OtherSink)
val summaryStream = myStream
.map(Row.fromOtherRow(_))
// paralle
浏览 3提问于2017-08-05得票数 3
1回答
我有一些相当简单的流代码，可以通过时间窗口聚合数据。窗口位于较大的一边(1小时，有2小时的限制)，流中的值是来自数百个服务器的度量。我一直没有内存，所以我添加了RocksDBStateBackend。这导致JVM出现分段错误。接下来，我尝试了FsStateBackend。这两个后端从未将任何数据写入磁盘，而只是使用JobID创建了一个目录。我在独立模式下运行这段代码，而不是部署。对于为什么状态后端没有写入数据，以及为什么即使提供了8GB的堆，它也会耗尽内存，有什么想法吗？
final SingleOutputStreamOperator<Metric> metricStre
浏览 1提问于2018-03-14得票数 1
回答已采纳
我想像getVertices(), ColocationGroup()一样修改jobGraph，我尝试了以下几种方式： val s = StreamExecutionEnvironment.getExecutionEnvironment
val p = new Param()
s.addSource(new MySource(p))
.map(new MyMap(p))
.addSink(new MySink(p))
val g = s.getStreamGraph.getJobGraph()
val v = g.getVert
浏览 49提问于2020-08-11得票数 0
回答已采纳
有没有人可以分享写回收流到kafka接收器的工作示例？
我试过了，如下所示，不起作用。
DataStream<Tuple2<Boolean, User>> resultStream =
tEnv.toRetractStream(result, User.class);
resultStream.addsink(new FlinkKafkaProducer(OutputTopic, new ObjSerializationSchema(OutputTopic),
props, FlinkKafkaProducer.Sema
浏览 1提问于2021-04-03得票数 0
我跟随使用mysql数据库作为Flink的接收器。代码编译成功，但在Flink群集中执行作业失败，错误为
The program finished with the following exception:
The implementation of the AbstractJdbcOutputFormat is not serializable. The object probably contains or references non serializable fields.
org.apache.flink.api.java.ClosureCleaner.clean(
浏览 2提问于2020-09-23得票数 2
1回答
我正在阅读Kafka的多个主题，然后进行状态操作，然后再次保存到Kafka。这就是流程； val stream1 = topic1.map(prepareData())
val stream2 = topic2.map(prepareData1())
val delayStream = delayqueue.map(prepareData2()) // these messages comes from delay
val enrichedResults = stream1.union(stream2).union(delayStream).map(stateOperation)
val
浏览 35提问于2021-04-24得票数 1
我的Flink应用程序从一个kafka源读取数据，将其映射到一个对象并写入另一个kafka主题。如果我使用MapFunction进行转换，一切都很好，但一旦我使用了extends ProcessFunction or RichFlatMapFunction类的实现，接收器就不会被调用(写入卡夫卡主题代码不会被执行)。我之所以使用ProcessFunction或RichFlatMapFunction，是因为我需要RuntimeConext()来读写ValueState。在这种情况下，我应该如何实现对接收器的调用？
env.addSource(新FlinkKafkaConsumer<>
浏览 15提问于2022-11-26得票数 0
回答已采纳
从代码块中
CassandraSink.addSink(result)
.setHost("127.0.0.1")
.setMapperOptions(() -> new Mapper.Option[]{Mapper.Option.saveNullFields(true)})
.build();
如所示。怎样才能
.setMapperOptions(() -> new Mapper.Option[]{Mapper.Option.saveNullFields(true)})
被翻译成scala？
地图是从com.dat
浏览 3提问于2022-07-07得票数 0
1回答
我有一个流是由FlinkKafkaConsumer消耗的，它将与另一个定义窗口大小的流结合，如Time.milliseconds(10000)。 如何在运行时将窗口大小更改为Time.milliseconds(20000)？ Stream1.join(Stream2)
.where(new SingleValueSensorKeySelector())
.equalTo(new GPSKeySelector())
.window(TumblingEventTimeWindows.of(Time.milliseconds(10000)))
.ap
浏览 48提问于2019-01-03得票数 1
1回答
Flink是否处理无序元组，即使在一个不使用窗口运算符的情况下也是如此。
例如：
withTimestampsAndWatermarks
.keyBy(...)
.map(...) // some stateful function
.addSink(...);
map将等待处理元素直到接收到正确的水印，还是它将处理元素而不等待？
问题是，map持有的分区状态可能会受到元组的无序处理的影响。
提前谢谢你
浏览 3提问于2016-11-05得票数 0
回答已采纳
使用kafka处理器API(而不是DSL)读取源主题并将其写入目标主题它适用于单个kafka集群设置(也就是说，如果源主题和目标主题驻留在同一集群上)，但是当源主题和目标主题驻留在不同的kafka集群上时，我将获得目标处理器上下文的NullPointerException
Topology
topology.addSource("mySource", "SourceTopic");
topology.addProcessor("SourceStreamProcessor",()->new SourceStreamProcessor(), &
浏览 1提问于2020-06-18得票数 0
我正在使用flink消费kafka并写入redis。
下面是我对redis的接收器函数：
.addSink(new RichSinkFunction<MobilePageEvent>() {
@Override
public void invoke(MobilePageEvent event, Context context) {
JEDIS_CLUSTER.zadd(..);
}
})
浏览 98提问于2019-02-28得票数 0
回答已采纳
这是我在这里发表的第一篇文章，我不确定以前是否在这里讨论过这个问题，但这里是这样的:我有一个使用处理器API的Kafka Streams应用程序，遵循以下拓扑结构： 1. Consume data from an input topic (processor.addSource())
2. Inserts data into a DB (processor.addProcessor())
3. Produce its process status to an output topic (processor.addSink()) 然而，为了可追溯性的目的，我需要在日志中记录kstreams向输
浏览 47提问于2020-04-30得票数 1
回答已采纳
我正在尝试编写一个流应用程序，它既可以读取卡夫卡，也可以写入卡夫卡。我现在有这个，但我必须toString我的元组类。
object StreamingJob {
def main(args: Array[String]) {
// set up the streaming execution environment
val env = StreamExecutionEnvironment.getExecutionEnvironment
val properties = new Properties()
properties.setProperty(
浏览 0提问于2018-10-05得票数 0
回答已采纳
当使用处理器API的Kafka流从源读取并写入主题列表时，我想测试一个或两个主题是不可访问的(失败测试:试图通过添加集群中不存在的1/2主题来模拟它)。
topology.addSource("mysource","source_topic");
topology.addProcessor("STREAM_PROCESSOR",()->new SourceProcessor(),"mysource");
topology.addSink("SINK_1","TOPIC_1
浏览 4提问于2020-06-23得票数 0
回答已采纳
我使用gocraft/health来检查我的服务的健康状况，并获得每个endPoint的指标。但是我有一个问题:在启动我的服务仅仅5个小时之后，CPU就达到了100%，我不知道为什么。不使用"gocraft/health“，它只需要0,7%的CPU，以前有人使用过这个包吗？
var stream = health.NewStream()
func main() {
// Log to stdout! (can also use WriterSink to write to a log file, Syslog, etc)
stream.AddSink(&
浏览 0提问于2015-06-10得票数 2
dataStream.map(func1).keyBy("key") //(1)
.process(func2).keyBy("key") //(2)
.timeWindow().aggregate(func3).addSink(sink)
process()方法不会更改记录的字段(键)值。假设所有运算符的并行度都是2，那么(2)上的keyBy()是否也会导致网络洗牌？也许(2)处的keyBy()具有转发策略的效果，避免了由于密钥值不变而产生的网络通信成本？
太感谢你了~
浏览 8提问于2019-11-09得票数 1
回答已采纳
1回答
测试闪烁窗口
、、
我有一个简单的Flink应用程序，它汇总了最近一分钟内具有相同id和时间戳的事件：
DataStream<String> input = env
.addSource(consumerProps)
.uid("app");
DataStream<Pixel> pixels = input.map(record -> mapper.readValue(record, Pixel.class));
pixels
.keyBy("id", "tim
浏览 16提问于2020-02-27得票数 0
回答已采纳
在使用rocksdb的flink v1.13.2中，我使用grafana中的以下命令测量任务压力：sum by (task_name)(flink_taskmanager_job_task_backPressuredTimeMsPerSecond{job="..."})
一些滤波函数(ProcessFilter_A，ProcessFilter_B，C，D)受背压的影响。但是下面的进程函数运行良好(没有背压-both进程和mongodb接收器-)。我也不知道如何解决过滤函数中的背压问题
，可能的原因是什么？
，而且我还想知道，由于我在聚合函数中使用rocksdb，所以KafkaO
浏览 5提问于2022-04-18得票数 0
回答已采纳
我目前正在尝试为我们的flink流处理编写一些测试，并且有如下内容
env.fromCollection(events)
.assignTimestampsAndWatermarks(new BoundedOutOfOrdernessTimestampExtractor<>(Time.milliseconds(1000)) {
@Override
public long extractTimestamp(CallEvent element) {
retur
浏览 4提问于2022-07-21得票数 1
我看过stream.addSink(new PrintSinkFunction<>())和stream.print()，不知道它们之间有什么不同。 基于https://github.com/apache/flink/blob/b2a342c6a6ef154ed3c1a44826ce2be14e538386/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java#L972-L973，除了.name("Print to Std. Out")
浏览 118提问于2020-10-30得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
