META-INF/MANIFEST.MF
org.apache.flink.api.java.TypeExtractionTest$1.class
org.apache.flink.api.java.TypeExtractionTest.class
org.apache.flink.api.java.TypeExtractionTest$VertexTyped.class
org.apache.flink.api.java.operators.NamesTest.class
org.apache.flink.api.java.operators.translation.ReduceTranslationTests$2.class
org.apache.flink.api.java.operators.translation.CoGroupSortTranslationTest$1.class
org.apache.flink.api.java.operators.translation.UnionTranslationTest$2.class
org.apache.flink.api.java.operators.translation.ReduceTranslationTests$4.class
org.apache.flink.api.java.operators.translation.UnionTranslationTest$4.class
org.apache.flink.api.java.operators.translation.UnionTranslationTest$3.class
org.apache.flink.api.java.operators.translation.CoGroupSortTranslationTest.class
org.apache.flink.api.java.operators.translation.CoGroupSortTranslationTest$2.class
org.apache.flink.api.java.operators.translation.ReduceTranslationTests$1.class
org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest$1.class
org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest$NextWorksetMapper.class
org.apache.flink.api.java.operators.translation.AggregateTranslationTest.class
org.apache.flink.api.java.operators.translation.CoGroupSortTranslationTest$TestPoJo.class
org.apache.flink.api.java.operators.translation.DistinctTranslationTest$CustomType.class
org.apache.flink.api.java.operators.translation.ReduceTranslationTests$3.class
org.apache.flink.api.java.operators.translation.DistinctTranslationTest.class
org.apache.flink.api.java.operators.translation.UnionTranslationTest$1.class
org.apache.flink.api.java.operators.translation.UnionTranslationTest.class
org.apache.flink.api.java.operators.translation.UnionTranslationTest$5.class
org.apache.flink.api.java.operators.translation.BulkIterationTranslationTest$IdentityMapper.class
org.apache.flink.api.java.operators.translation.DistinctTranslationTest$1.class
org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest$SolutionWorksetCoGroup2.class
org.apache.flink.api.java.operators.translation.BulkIterationTranslationTest.class
org.apache.flink.api.java.operators.translation.ReduceTranslationTests.class
org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest.class
org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest$IdentityMapper.class
org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest$SolutionWorksetJoin.class
org.apache.flink.api.java.operators.translation.BulkIterationTranslationTest$1.class
org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest$SolutionWorksetCoGroup1.class
org.apache.flink.api.java.operators.NamesTest$1.class
org.apache.flink.api.java.operators.NamesTest$3.class
org.apache.flink.api.java.operators.NamesTest$5.class
org.apache.flink.api.java.operators.NamesTest$2.class
org.apache.flink.api.java.operators.NamesTest$4.class
org.apache.flink.api.java.tuple.TupleGenerator.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce7.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map1.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$PointParser.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Join2.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$Edge.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map27.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$MyPojo.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map25.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map18.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$MyPojo2.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map3.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce5.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce4Javac.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map38.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map7.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce1.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$NullReturnFlatMapper.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$ExtendingTuple.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map40.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map21.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map23.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce3.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$NullReturnMapper1.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$DocumentWithFreq.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$BuildOutgoingEdgeList.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$DocumentReducer.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map5.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Join1.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map19.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$1.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$UndirectEdge.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map24.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce4.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map2.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce6.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map26.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$CentroidAccumulator.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$MessageBOW.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$TriadBuilder.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map22.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$SumGradient.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$MapToCenter.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map4.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce2.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$NullReturnMapper2.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map41.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map39.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map6.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map20.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$DegreeCounter.class
org.apache.flink.api.java.sca.UdfAnalyzerTest.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map11.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$PointWithLabel.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map35.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$TupleEdgeConverter.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$FilterMod2.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map37.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map8.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map13.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$AntiJoinVisits.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$FlatMap3.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map17.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$CentroidAverager.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$RecordToDocConverter.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map33.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$DuplicateValue.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$ComponentIdFilter.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map31.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$PutStaticMapper.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce8.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Reduce2.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map28.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$FlatMap1.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map15.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce10.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map36.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map9.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map12.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$1.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map10.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$Gradient.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map34.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$FilterMod1.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$Vector.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$GroupReduce9.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map30.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$Triad.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$EdgeDuplicator.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$Centroid.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$Point.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map14.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$Document.class
org.apache.flink.api.java.sca.UdfAnalyzerExamplesTest$NeighborWithComponentIDJoin.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map29.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map16.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$FlatMap2.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Map32.class
org.apache.flink.api.java.sca.UdfAnalyzerTest$Reduce1.class
org.apache.flink.api.java.TypeExtractionTest$Vertex.class
org.apache.flink.api.java.io.CollectionInputFormatTest$ElementType.class
org.apache.flink.api.java.io.CollectionInputFormatTest$TestException.class
org.apache.flink.api.java.io.TypeSerializerFormatTest.class
org.apache.flink.api.java.io.CSVReaderTest.class
org.apache.flink.api.java.io.CSVReaderTest$FinalItem.class
org.apache.flink.api.java.io.FromElementsTest$SubType.class
org.apache.flink.api.java.io.CsvInputFormatTest$PrivatePojoItem.class
org.apache.flink.api.java.io.CSVReaderTest$ValueItem.class
org.apache.flink.api.java.io.CollectionInputFormatTest.class
org.apache.flink.api.java.io.CSVReaderTest$1.class
org.apache.flink.api.java.io.PrimitiveInputFormatTest.class
org.apache.flink.api.java.io.CollectionInputFormatTest$TestSerializer.class
org.apache.flink.api.java.io.RowCsvInputFormatTest.class
org.apache.flink.api.java.io.CSVReaderTest$SubItem.class
org.apache.flink.api.java.io.FromElementsTest.class
org.apache.flink.api.java.io.CsvInputFormatTest$PojoItem.class
org.apache.flink.api.java.io.FromElementsTest$ParentType.class
org.apache.flink.api.java.io.TextInputFormatTest.class
org.apache.flink.api.java.io.CSVReaderTest$PartialItem.class
org.apache.flink.api.java.io.CollectionInputFormatTest$1.class
org.apache.flink.api.java.io.CsvInputFormatTest$POJO.class
org.apache.flink.api.java.io.CsvInputFormatTest$TwitterPOJO.class
org.apache.flink.api.java.io.CsvOutputFormatTest.class
org.apache.flink.api.java.io.CSVReaderTest$Item.class
org.apache.flink.api.java.io.CsvInputFormatTest.class
org.apache.flink.api.java.summarize.aggregation.DoubleValueSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.CompensatedSumTest.class
org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.FloatValueSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.StringSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.IntegerValueSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.StringValueSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.StringValueSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.BooleanValueSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.SummaryAggregatorFactoryTest.class
org.apache.flink.api.java.summarize.aggregation.BooleanValueSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.IntegerValueSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.ShortValueSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.FloatValueSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.LongValueSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.StringSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.AggregateCombineHarness.class
org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.DoubleValueSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.LongValueSummaryAggregatorTest$1.class
org.apache.flink.api.java.summarize.aggregation.ShortValueSummaryAggregatorTest.class
org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregatorTest$1.class
org.apache.flink.api.java.sampling.RandomSamplerTest.class
org.apache.flink.api.java.utils.ParameterToolTest.class
org.apache.flink.api.java.utils.RequiredParametersTest.class
org.apache.flink.api.java.utils.AbstractParameterToolTest.class
org.apache.flink.api.java.utils.OptionsTest.class
org.apache.flink.api.java.MultipleInvokationsTest.class
org.apache.flink.api.java.functions.SemanticPropertiesProjectionTest.class
org.apache.flink.api.java.functions.NestedSerializableMapCreator$InnerSerializableMapCreator$1.class
org.apache.flink.api.java.functions.SemanticPropertiesPrecedenceTest$WildcardForwardedMapperWithSkipAnnotation.class
org.apache.flink.api.java.functions.SemanticPropUtilTest$NestedTestPojo.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$NoAnnotationJoin.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$NoAnnotationMapper.class
org.apache.flink.api.java.functions.MapCreator.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$ForwardedFirstAnnotationJoin.class
org.apache.flink.api.java.functions.SemanticPropertiesPrecedenceTest$WildcardForwardedMapper.class
org.apache.flink.api.java.functions.NestedNonSerializableMapCreator.class
org.apache.flink.api.java.functions.SerializableMapCreator$1.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$ReadSetJoin.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$ShufflingMapper.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$ForwardedBothAnnotationJoin.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$AllForwardedExceptMapper.class
org.apache.flink.api.java.functions.SerializableMapCreator.class
org.apache.flink.api.java.functions.SemanticPropUtilTest$TestPojo.class
org.apache.flink.api.java.functions.NestedNonSerializableMapCreator$InnerSerializableMapCreator$1.class
org.apache.flink.api.java.functions.NonSerializableMapCreator$1.class
org.apache.flink.api.java.functions.NestedSerializableMapCreator.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$AllForwardedExceptJoin.class
org.apache.flink.api.java.functions.SemanticPropertiesPrecedenceTest$WildcardForwardedMapperWithForwardAnnotation.class
org.apache.flink.api.java.functions.NonSerializableMapCreator.class
org.apache.flink.api.java.functions.ClosureCleanerTest.class
org.apache.flink.api.java.functions.SemanticPropUtilTest.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$1.class
org.apache.flink.api.java.functions.NestedSerializableMapCreator$InnerSerializableMapCreator.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$WildcardForwardedMapper.class
org.apache.flink.api.java.functions.NestedNonSerializableMapCreator$InnerSerializableMapCreator.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$ReadSetMapper.class
org.apache.flink.api.java.functions.SemanticPropertiesPrecedenceTest$1.class
org.apache.flink.api.java.functions.SelectByFunctionsTest.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$IndividualForwardedMapper.class
org.apache.flink.api.java.functions.SemanticPropUtilTest$TestPojo2.class
org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest$ForwardedSecondAnnotationJoin.class
org.apache.flink.api.java.functions.SemanticPropertiesPrecedenceTest.class
org.apache.flink.api.java.operator.GroupingTest$3.class
org.apache.flink.api.java.operator.JoinOperatorTest$5.class
org.apache.flink.api.java.operator.GroupReduceOperatorTest.class
org.apache.flink.api.java.operator.ReduceOperatorTest$DummyTestKeySelector.class
org.apache.flink.api.java.operator.PartitionOperatorTest.class
org.apache.flink.api.java.operator.FullOuterJoinOperatorTest$1.class
org.apache.flink.api.java.operator.GroupingTest$CustomType.class
org.apache.flink.api.java.operator.FullOuterJoinOperatorTest.class
org.apache.flink.api.java.operator.SortPartitionTest.class
org.apache.flink.api.java.operator.AggregateOperatorTest.class
org.apache.flink.api.java.operator.GroupCombineOperatorTest$1.class
org.apache.flink.api.java.operator.JoinOperatorTest$CustomTypeWithTuple.class
org.apache.flink.api.java.operator.PartitionOperatorTest$2.class
org.apache.flink.api.java.operator.GroupingTest$1.class
org.apache.flink.api.java.operator.JoinOperatorTest$7.class
org.apache.flink.api.java.operator.FullOuterJoinOperatorTest$DummyJoin.class
org.apache.flink.api.java.operator.CrossOperatorTest$CustomType.class
org.apache.flink.api.java.operator.GroupingTest$5.class
org.apache.flink.api.java.operator.JoinOperatorTest$3.class
org.apache.flink.api.java.operator.PartitionOperatorTest$6.class
org.apache.flink.api.java.operator.JoinOperatorTest$CustomType.class
org.apache.flink.api.java.operator.SortPartitionTest$CustomType.class
org.apache.flink.api.java.operator.PartitionOperatorTest$4.class
org.apache.flink.api.java.operator.MinByOperatorTest.class
org.apache.flink.api.java.operator.GroupingTest$7.class
org.apache.flink.api.java.operator.JoinOperatorTest$1.class
org.apache.flink.api.java.operator.PartitionOperatorTest$NestedPojo.class
org.apache.flink.api.java.operator.RightOuterJoinOperatorTest.class
org.apache.flink.api.java.operator.ReduceOperatorTest.class
org.apache.flink.api.java.operator.PartitionOperatorTest$3.class
org.apache.flink.api.java.operator.RightOuterJoinOperatorTest$LongKeySelector.class
org.apache.flink.api.java.operator.JoinOperatorTest$6.class
org.apache.flink.api.java.operator.JoinOperatorTest$Nested.class
org.apache.flink.api.java.operator.GroupingTest$2.class
org.apache.flink.api.java.operator.JoinOperatorTest$4.class
org.apache.flink.api.java.operator.SortPartitionTest$CustomType$Nest.class
org.apache.flink.api.java.operator.PartitionOperatorTest$1.class
org.apache.flink.api.java.operator.RightOuterJoinOperatorTest$1.class
org.apache.flink.api.java.operator.PartitionOperatorTest$5.class
org.apache.flink.api.java.operator.OperatorTest.class
org.apache.flink.api.java.operator.FullOuterJoinOperatorTest$LongKeySelector.class
org.apache.flink.api.java.operator.GroupingTest$6.class
org.apache.flink.api.java.operator.GroupingTest$4.class
org.apache.flink.api.java.operator.JoinOperatorTest$2.class
org.apache.flink.api.java.operator.ProjectionOperatorTest.class
org.apache.flink.api.java.operator.PartitionOperatorTest$CustomPojo.class
org.apache.flink.api.java.operator.GroupCombineOperatorTest$DummyTestKeySelector.class
org.apache.flink.api.java.operator.RightOuterJoinOperatorTest$IntKeySelector.class
org.apache.flink.api.java.operator.PartitionOperatorTest$7.class
org.apache.flink.api.java.operator.LeftOuterJoinOperatorTest$LongKeySelector.class
org.apache.flink.api.java.operator.DistinctOperatorTest$NotComparable.class
org.apache.flink.api.java.operator.CrossOperatorTest.class
org.apache.flink.api.java.operator.GroupingTest$CustomType2.class
org.apache.flink.api.java.operator.GroupReduceOperatorTest$DummyGroupReduceFunction3.class
org.apache.flink.api.java.operator.CoGroupOperatorTest$5.class
org.apache.flink.api.java.operator.JoinOperatorTest$DummyTestJoinFunction1.class
org.apache.flink.api.java.operator.GroupingTest$8.class
org.apache.flink.api.java.operator.MaxByOperatorTest$CustomType.class
org.apache.flink.api.java.operator.SortPartitionTest$4.class
org.apache.flink.api.java.operator.JoinOperatorTest$NestedCustomType.class
org.apache.flink.api.java.operator.GroupReduceOperatorTest$DummyGroupReduceFunction1.class
org.apache.flink.api.java.operator.GroupCombineOperatorTest$DummyGroupCombineFunction2.class
org.apache.flink.api.java.operator.LeftOuterJoinOperatorTest$DummyJoin.class
org.apache.flink.api.java.operator.JoinOperatorTest$DummyTestKeySelector.class
org.apache.flink.api.java.operator.DistinctOperatorTest$1.class
org.apache.flink.api.java.operator.CoGroupOperatorTest.class
org.apache.flink.api.java.operator.JoinOperatorTest$8.class
org.apache.flink.api.java.operator.CoGroupOperatorTest$3.class
org.apache.flink.api.java.operator.ReduceOperatorTest$DummyReduceFunction3.class
org.apache.flink.api.java.operator.MinByOperatorTest$CustomType.class
org.apache.flink.api.java.operator.GroupReduceOperatorTest$DummyTestKeySelector.class
org.apache.flink.api.java.operator.GroupingTest$11.class
org.apache.flink.api.java.operator.ReduceOperatorTest$1.class
org.apache.flink.api.java.operator.JoinOperatorTest$10.class
org.apache.flink.api.java.operator.CoGroupOperatorTest$DummyTestCoGroupFunction1.class
#内容未全部加载,请点击展开加载全部代码(NowJava.com)
|