Path	Lines of Code
flink-optimizer/src/main/java/org/apache/flink/optimizer/CompilerException.java	14
flink-optimizer/src/main/java/org/apache/flink/optimizer/CompilerPostPassException.java	14
flink-optimizer/src/main/java/org/apache/flink/optimizer/DataStatistics.java	20
flink-optimizer/src/main/java/org/apache/flink/optimizer/Optimizer.java	176
flink-optimizer/src/main/java/org/apache/flink/optimizer/costs/CostEstimator.java	144
flink-optimizer/src/main/java/org/apache/flink/optimizer/costs/Costs.java	260
flink-optimizer/src/main/java/org/apache/flink/optimizer/costs/DefaultCostEstimator.java	163
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/AbstractPartialSolutionNode.java	61
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/BinaryUnionNode.java	243
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/BulkIterationNode.java	225
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/BulkPartialSolutionNode.java	57
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/CoGroupNode.java	92
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/CoGroupRawNode.java	44
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/CrossNode.java	87
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/DagConnection.java	136
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/DataSinkNode.java	144
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/DataSourceNode.java	213
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/EstimateProvider.java	6
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/FilterNode.java	37
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/FlatMapNode.java	30
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/GroupCombineNode.java	67
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/GroupReduceNode.java	112
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/InterestingPropertiesClearer.java	16
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/IterationNode.java	5
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/JoinNode.java	126
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/MapNode.java	26
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/MapPartitionNode.java	39
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/NoOpNode.java	17
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java	647
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OuterJoinNode.java	156
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/PartitionNode.java	110
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/PlanCacheCleaner.java	16
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/ReduceNode.java	70
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/SingleInputNode.java	348
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/SinkJoiner.java	64
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/SolutionSetNode.java	53
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/SortPartitionNode.java	77
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/TempMode.java	46
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/TwoInputNode.java	533
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/UnaryOperatorNode.java	43
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/WorksetIterationNode.java	381
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/WorksetNode.java	58
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java	389
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/InterestingProperties.java	109
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/LocalProperties.java	189
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/PartitioningProperty.java	23
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalProperties.java	299
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedLocalProperties.java	129
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AbstractJoinDescriptor.java	122
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AbstractOperatorDescriptor.java	5
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AbstractSortMergeJoinDescriptor.java	51
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupCombineProperties.java	44
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupReduceProperties.java	44
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupWithPartialPreGroupProperties.java	66
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllReduceProperties.java	60
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/BinaryUnionOpDescriptor.java	88
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CartesianProductDescriptor.java	70
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupDescriptor.java	152
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupRawDescriptor.java	125
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupWithSolutionSetFirstDescriptor.java	45
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupWithSolutionSetSecondDescriptor.java	28
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossBlockOuterFirstDescriptor.java	19
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossBlockOuterSecondDescriptor.java	19
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossStreamOuterFirstDescriptor.java	25
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossStreamOuterSecondDescriptor.java	25
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/FilterDescriptor.java	39
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/FlatMapDescriptor.java	46
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupCombineProperties.java	71
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceProperties.java	89
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java	131
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashFullOuterJoinBuildFirstDescriptor.java	37
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashFullOuterJoinBuildSecondDescriptor.java	37
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashJoinBuildFirstProperties.java	54
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashJoinBuildSecondProperties.java	55
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashLeftOuterJoinBuildFirstDescriptor.java	38
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashLeftOuterJoinBuildSecondDescriptor.java	38
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashRightOuterJoinBuildFirstDescriptor.java	38
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashRightOuterJoinBuildSecondDescriptor.java	38
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/MapDescriptor.java	39
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/MapPartitionDescriptor.java	39
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/NoOpDescriptor.java	37
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/OperatorDescriptorDual.java	173
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/OperatorDescriptorSingle.java	41
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/PartialGroupProperties.java	58
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/ReduceProperties.java	95
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SolutionSetDeltaOperator.java	43
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeFullOuterJoinDescriptor.java	16
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeInnerJoinDescriptor.java	20
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeLeftOuterJoinDescriptor.java	19
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeRightOuterJoinDescriptor.java	19
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/UtilSinkJoinOpDescriptor.java	56
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BinaryUnionPlanNode.java	27
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BulkIterationPlanNode.java	104
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BulkPartialSolutionPlanNode.java	79
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/Channel.java	316
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/DualInputPlanNode.java	164
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/IterationPlanNode.java	7
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/NAryUnionPlanNode.java	65
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/NamedChannel.java	16
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/OptimizedPlan.java	42
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/PlanNode.java	311
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SingleInputPlanNode.java	150
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SinkJoinerPlanNode.java	34
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SinkPlanNode.java	17
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SolutionSetPlanNode.java	71
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SourcePlanNode.java	53
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/WorksetIterationPlanNode.java	164
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/WorksetPlanNode.java	79
flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/DumpableConnection.java	6
flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/DumpableNode.java	9
flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/ExecutionPlanJSONGenerator.java	20
flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java	493
flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java	1255
flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JsonMapper.java	227
flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass/ConflictingFieldTypeInfoException.java	21
flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass/JavaApiPostPass.java	215
flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass/MissingFieldTypeInfoException.java	11
flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass/OptimizerPostPass.java	5
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/BinaryUnionReplacer.java	76
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/BranchesVisitor.java	17
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/GraphCreatingVisitor.java	297
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/IdAndEstimatesVisitor.java	31
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/InterestingPropertyVisitor.java	22
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/PlanFinalizer.java	155
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/RangePartitionRewriter.java	187
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/StaticDynamicPathIdentifier.java	25
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/StepFunctionValidator.java	22
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/UnionParallelismAndForwardEnforcer.java	27
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/package-info.java	1
flink-optimizer/src/main/java/org/apache/flink/optimizer/util/NoOpBinaryUdfOp.java	18
flink-optimizer/src/main/java/org/apache/flink/optimizer/util/NoOpUnaryUdfOp.java	25
flink-optimizer/src/main/java/org/apache/flink/optimizer/util/Utils.java	84