| Call Tree | Time (ms) | |
| (...) (13/18) Group: 'Flink Task Threads' | 22,929 | 100 % |
| <...> java.lang. Thread.run () | 22,929 | 100 % |
<5 calls> StreamFlatMap.java:50 (...)function. (...).flatMap (Object, Collector) | 22,929 | 100 % |
| (...).scala:10 (...)function. (...).flatMap (DataSet, Collector) | 22,929 | 100 % |
| (...).scala:51 org.apache.flink.streaming.api.operators. TimestampedCollector.collect (Object) | 22,929 | 100 % |
| TimestampedCollector.java:51 org.apache.flink.streaming.api.operators. AbstractStreamOperator$CountingOutput.collect (Object) | 22,929 | 100 % |
| AbstractStreamOperator.java:657 org.apache.flink.streaming.api.operators. AbstractStreamOperator$CountingOutput.collect (StreamRecord) | 22,929 | 100 % |
| AbstractStreamOperator.java:679 org.apache.flink.streaming.runtime.tasks. OperatorChain$CopyingBroadcastingOutputCollector.collect (Object) | 22,929 | 100 % |
| OperatorChain.java:653 org.apache.flink.streaming.runtime.tasks. OperatorChain$CopyingBroadcastingOutputCollector.collect (StreamRecord) | 22,929 | 100 % |
| OperatorChain.java:667 org.apache.flink.streaming.runtime.io. RecordWriterOutput.collect (Object) | 22,929 | 100 % |
| RecordWriterOutput.java:45 org.apache.flink.streaming.runtime.io. RecordWriterOutput.collect (StreamRecord) | 22,929 | 100 % |
| RecordWriterOutput.java:89 org.apache.flink.streaming.runtime.io. RecordWriterOutput.pushToRecordWriter (StreamRecord) | 22,929 | 100 % |
| RecordWriterOutput.java:107 org.apache.flink.streaming.runtime.io. StreamRecordWriter.emit (IOReadableWritable) | 22,929 | 100 % |
| StreamRecordWriter.java:81 org.apache.flink.runtime.io.network.api.writer. RecordWriter.emit (IOReadableWritable) | 22,929 | 100 % |
| RecordWriter.java:105 org.apache.flink.runtime.io.network.api.writer. RecordWriter.sendToTarget (IOReadableWritable, int) | 22,929 | 100 % |
| RecordWriter.java:129 org.apache.flink.runtime.io.network.api.serialization. SpanningRecordSerializer.addRecord (IOReadableWritable) | 22,929 | 100 % |
| SpanningRecordSerializer.java:88 org.apache.flink.runtime.plugable. SerializationDelegate.write (DataOutputView) | 22,929 | 100 % |
| SerializationDelegate.java:54 org.apache.flink.streaming.runtime.streamrecord. StreamElementSerializer.serialize (Object, DataOutputView) | 22,929 | 100 % |
| StreamElementSerializer.java:49 org.apache.flink.streaming.runtime.streamrecord. StreamElementSerializer.serialize (StreamElement, DataOutputView) | 22,929 | 100 % |
| StreamElementSerializer.java:177 org.apache.flink.api.scala.typeutils. TraversableSerializer.serialize (Object, DataOutputView) | 22,929 | 100 % |
| TraversableSerializer.scala:33 org.apache.flink.api.scala.typeutils. TraversableSerializer.serialize (TraversableOnce, DataOutputView) | 22,929 | 100 % |
| TraversableSerializer.scala:93 scala.collection.mutable. ArrayBuffer.foreach (Function1) | 22,929 | 100 % |
| ArrayBuffer.scala:48 scala.collection.mutable. ResizableArray$class.foreach (ResizableArray, Function1) | 22,929 | 100 % |
| ResizableArray.scala:59 org.apache.flink.api.scala.typeutils. TraversableSerializer$$anonfun$serialize$1.apply (Object) | 22,929 | 100 % |
| TraversableSerializer.scala:93 org.apache.flink.api.scala.typeutils. TraversableSerializer$$anonfun$serialize$1.apply (Object) | 22,929 | 100 % |
| TraversableSerializer.scala:98 org.apache.flink.api.scala.typeutils. CaseClassSerializer.serialize (Object, DataOutputView) | 22,929 | 100 % |
| CaseClassSerializer.scala:32 org.apache.flink.api.scala.typeutils. CaseClassSerializer.serialize (Product, DataOutputView) | 22,929 | 100 % |
| CaseClassSerializer.scala:113 org.apache.flink.api.scala.typeutils. TraversableSerializer.serialize (Object, DataOutputView) | 22,929 | 100 % |
| TraversableSerializer.scala:33 org.apache.flink.api.scala.typeutils. TraversableSerializer.serialize (TraversableOnce, DataOutputView) | 22,929 | 100 % |
| TraversableSerializer.scala:93 scala.collection.mutable. ArrayBuffer.foreach (Function1) | 22,929 | 100 % |
| ArrayBuffer.scala:48 scala.collection.mutable. ResizableArray$class.foreach (ResizableArray, Function1) | 22,929 | 100 % |
| ResizableArray.scala:59 org.apache.flink.api.scala.typeutils. TraversableSerializer$$anonfun$serialize$1.apply (Object) | 22,929 | 100 % |
| TraversableSerializer.scala:93 org.apache.flink.api.scala.typeutils. TraversableSerializer$$anonfun$serialize$1.apply (Object) | 22,929 | 100 % |
| TraversableSerializer.scala:98 org.apache.flink.api.scala.typeutils. CaseClassSerializer.serialize (Object, DataOutputView) | 22,929 | 100 % |
| CaseClassSerializer.scala:32 org.apache.flink.api.scala.typeutils. CaseClassSerializer.serialize (Product, DataOutputView) | 22,929 | 100 % |
| CaseClassSerializer.scala:113 org.apache.flink.api.scala.typeutils. CaseClassSerializer.serialize (Object, DataOutputView) | 9,292 | 41 % |
| CaseClassSerializer.scala:32 org.apache.flink.api.scala.typeutils. CaseClassSerializer.serialize (Product, DataOutputView) | 9,292 | 41 % |
| CaseClassSerializer.scala:113 org.apache.flink.api.common.typeutils.base. StringSerializer.serialize (Object, DataOutputView) | 7,136 | 31 % |
| StringSerializer.java:28 org.apache.flink.api.common.typeutils.base. StringSerializer.serialize (String, DataOutputView) | 7,136 | 31 % |
| StringSerializer.java:64 org.apache.flink.types. StringValue.writeString (CharSequence, DataOutput) | 7,136 | 31 % |
| StringValue.java:812 org.apache.flink.core.memory. DataOutputSerializer.write (int) | 5,401 | 24 % |
| DataOutputSerializer.java:133 org.apache.flink.core.memory. DataOutputSerializer.resize (int) | 2,066 | 9 % |
DataOutputSerializer.java:330 java.nio. ByteBuffer.wrap (byte[]) | 185 | 1 % |
ByteBuffer.java:396 java.nio. ByteBuffer.wrap (byte[], int, int) | 185 | 1 % |
| StringValue.java:802 <...> org.apache.flink.core.memory. DataOutputSerializer.write (int) | 1,734 | 8 % |
| CaseClassSerializer.scala:113 <...> org.apache.flink.api.common.typeutils.base. IntSerializer.serialize (Object, DataOutputView) | 1,726 | 8 % |
CaseClassSerializer.scala:113 <...> org.apache.flink.api.scala.typeutils. TraversableSerializer.serialize (Object, DataOutputView) | 429 | 2 % |
| CaseClassSerializer.scala:113 org.apache.flink.api.common.typeutils.base. StringSerializer.serialize (Object, DataOutputView) | 8,238 | 36 % |
| StringSerializer.java:28 org.apache.flink.api.common.typeutils.base. StringSerializer.serialize (String, DataOutputView) | 8,238 | 36 % |
| StringSerializer.java:64 org.apache.flink.types. StringValue.writeString (CharSequence, DataOutput) | 8,238 | 36 % |
| StringValue.java:812 org.apache.flink.core.memory. DataOutputSerializer.write (int) | 6,526 | 28 % |
| DataOutputSerializer.java:133 org.apache.flink.core.memory. DataOutputSerializer.resize (int) | 2,546 | 11 % |
DataOutputSerializer.java:330 java.nio. ByteBuffer.wrap (byte[]) | 336 | 1 % |
ByteBuffer.java:396 java.nio. ByteBuffer.wrap (byte[], int, int) | 336 | 1 % |
| StringValue.java:802 <...> org.apache.flink.core.memory. DataOutputSerializer.write (int) | 1,712 | 7 % |
| CaseClassSerializer.scala:113 <...> org.apache.flink.api.common.typeutils.base. IntSerializer.serialize (Object, DataOutputView) | 3,245 | 14 % |
| CaseClassSerializer.scala:113 <...> org.apache.flink.api.scala.typeutils. TraversableSerializer.serialize (Object, DataOutputView) | 1,617 | 7 % |
CaseClassSerializer.scala:113 <...> org.apache.flink.api.common.typeutils.base. LongSerializer.serialize (Object, DataOutputView) | 535 | 2 % |