flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From AndreaKinn <kinn6...@hotmail.it>
Subject Re: Load distribution through the cluster
Date Tue, 19 Sep 2017 15:38:37 GMT
If I apply a sharing slot as in the example:

DataStream<Event> LTzAccStream = env
				.addSource(new FlinkKafkaConsumer010<>("topic", new
CustomDeserializer(), properties))
				.assignTimestampsAndWatermarks(new CustomTimestampExtractor())
				.map(new MapFunction<Tuple2&lt;String, String>, Event>(){ 
                                      @Override 
					public Event map(Tuple2<String, String> value) throws Exception { 
						return new Event(value.f0, value.f1); 
					} 
				}).slotSharingGroup("group1");

just the map operator is assigned to the shared slot or it happens for the
entire block (addSource + assignTimestamp + map)?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Mime
View raw message