Path	Lines of Code
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java	190
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvOutputFormat.java	115
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializerSnapshot.java	60
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaEitherSerializerSnapshot.java	29
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaOptionSerializerConfigSnapshot.java	26
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaOptionSerializerSnapshot.java	28
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaTrySerializerConfigSnapshot.java	29
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaTrySerializerSnapshot.java	30
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/TraversableSerializerConfigSnapshot.java	33
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/TraversableSerializerSnapshot.java	62
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/Tuple2CaseClassSerializerSnapshot.java	64
flink-scala/src/main/scala/org/apache/flink/api/scala/AggregateDataSet.scala	36
flink-scala/src/main/scala/org/apache/flink/api/scala/ClosureCleaner.scala	382
flink-scala/src/main/scala/org/apache/flink/api/scala/CoGroupDataSet.scala	158
flink-scala/src/main/scala/org/apache/flink/api/scala/CrossDataSet.scala	65
flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala	781
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala	296
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala	266
flink-scala/src/main/scala/org/apache/flink/api/scala/PartitionSortedDataSet.scala	30
flink-scala/src/main/scala/org/apache/flink/api/scala/SelectByMaxFunction.scala	31
flink-scala/src/main/scala/org/apache/flink/api/scala/SelectByMinFunction.scala	31
flink-scala/src/main/scala/org/apache/flink/api/scala/UnfinishedCoGroupOperation.scala	40
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/Counter.scala	13
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/MacroContextHolder.scala	13
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TreeGen.scala	191
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala	391
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeDescriptors.scala	107
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeInformationGen.scala	325
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnCoGroupDataSet.scala	13
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnCrossDataSet.scala	10
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnDataSet.scala	35
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnGroupedDataSet.scala	27
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnHalfUnfinishedKeyPairOperation.scala	9
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnJoinFunctionAssigner.scala	10
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnUnfinishedKeyPairOperation.scala	9
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/package.scala	29
flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala	199
flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala	10
flink-scala/src/main/scala/org/apache/flink/api/scala/package.scala	104
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassComparator.scala	127
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassSerializer.scala	99
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassTypeInfo.scala	205
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EitherSerializer.scala	100
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EitherTypeInfo.scala	59
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EnumValueComparator.scala	61
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EnumValueSerializer.scala	121
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EnumValueTypeInfo.scala	49
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/NothingSerializer.scala	41
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala	81
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionTypeComparator.scala	116
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionTypeInfo.scala	59
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializer.scala	72
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/ScalaEnumSerializerSnapshot.scala	75
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/ScalaNothingTypeInfo.scala	31
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TraversableSerializer.scala	169
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TraversableTypeInfo.scala	45
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TrySerializer.scala	94
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TryTypeInfo.scala	49
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TypeUtils.scala	12
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/Types.scala	85
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/UnitSerializer.scala	42
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/UnitTypeInfo.scala	31
flink-scala/src/main/scala/org/apache/flink/api/scala/unfinishedKeyPairOperation.scala	88
flink-scala/src/main/scala/org/apache/flink/api/scala/utils/package.scala	101