登录注册

Jar文件详情内容

flink-java-1.1.1-hadoop1.jar

所在目录：/org/apache/flink/flink-java/1.1.1-hadoop1 查看flink-java所有版本文件

组织ID:	org.apache.flink
项目ID:	flink-java
版本:	1.1.1-hadoop1
最后修改时间:	2020-04-05 20:28:52
包类型:	jar
标题:	flink-java
大小:	744.96KB

Maven引入代码:	`<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.1.1-hadoop1</version> </dependency>`
Gradle引入代码:	`org.apache.flink:flink-java:1.1.1-hadoop1`
下载Jar包:	flink-java-1.1.1-hadoop1.jar
POM文件内容:	展开复制 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <parent> <artifactId>flink-parent</artifactId> <groupId>org.apache.flink</groupId> <version>1.1.1-hadoop1</version> <relativePath>../../pom.xml</relativePath> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>flink-java</artifactId> <name>flink-java</name> <build> <plugins> <plugin> <artifactId>maven-jar-plugin</artifactId> <executions> <execution> <goals> <goal>test-jar</goal> </goals> </execution> </executions> </plugin> </plugins> </build> <dependencies> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-core</artifactId> <version>1.1.1-hadoop1</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-shaded-hadoop1_2.10</artifactId> <version>1.1.1-hadoop1</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-math3</artifactId> <version>3.5</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.google.guava</groupId> <artifactId>guava</artifactId> <version>18.0</version> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-test-utils-junit</artifactId> <version>1.1.1-hadoop1</version> <scope>test</scope> </dependency> <dependency> <groupId>com.google.code.findbugs</groupId> <artifactId>jsr305</artifactId> <version>1.3.9</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.3.2</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.7</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.7</version> <scope>compile</scope> </dependency> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>1.2.17</version> <scope>compile</scope> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.11</version> <scope>test</scope> <exclusions> <exclusion> <artifactId>hamcrest-core</artifactId> <groupId>org.hamcrest</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.mockito</groupId> <artifactId>mockito-all</artifactId> <version>1.9.5</version> <scope>test</scope> </dependency> <dependency> <groupId>org.powermock</groupId> <artifactId>powermock-module-junit4</artifactId> <version>1.5.5</version> <scope>test</scope> <exclusions> <exclusion> <artifactId>powermock-module-junit4-common</artifactId> <groupId>org.powermock</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.powermock</groupId> <artifactId>powermock-api-mockito</artifactId> <version>1.5.5</version> <scope>test</scope> <exclusions> <exclusion> <artifactId>powermock-api-support</artifactId> <groupId>org.powermock</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.hamcrest</groupId> <artifactId>hamcrest-all</artifactId> <version>1.3</version> <scope>test</scope> </dependency> <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-testkit_2.10</artifactId> <version>2.3.7</version> <scope>provided</scope> <exclusions> <exclusion> <artifactId>scala-library</artifactId> <groupId>org.scala-lang</groupId> </exclusion> <exclusion> <artifactId>akka-actor_2.10</artifactId> <groupId>com.typesafe.akka</groupId> </exclusion> </exclusions> </dependency> </dependencies> </project>
Jar包内容:	展开复制 META-INF/MANIFEST.MF org.apache.flink.api.java.ClosureCleaner.class org.apache.flink.api.java.RemoteEnvironment.class org.apache.flink.api.java.functions.FunctionAnnotation$ForwardedFields.class org.apache.flink.api.java.functions.FirstReducer.class org.apache.flink.api.java.functions.FunctionAnnotation$ReadFieldsSecond.class org.apache.flink.api.java.functions.FunctionAnnotation$SkipCodeAnalysis.class org.apache.flink.api.java.functions.SampleInCoordinator.class org.apache.flink.api.java.functions.FunctionAnnotation$ReadFieldsFirst.class org.apache.flink.api.java.functions.SampleInPartition.class org.apache.flink.api.java.functions.SampleWithFraction.class org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFieldsFirst.class org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFields.class org.apache.flink.api.java.functions.SelectByMaxFunction.class org.apache.flink.api.java.functions.FlatMapIterator.class org.apache.flink.api.java.functions.FunctionAnnotation$ForwardedFieldsSecond.class org.apache.flink.api.java.functions.FunctionAnnotation$ForwardedFieldsFirst.class org.apache.flink.api.java.functions.IdPartitioner.class org.apache.flink.api.java.functions.FunctionAnnotation$ReadFields.class org.apache.flink.api.java.functions.SemanticPropUtil.class org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFieldsSecond.class org.apache.flink.api.java.functions.SelectByMinFunction.class org.apache.flink.api.java.functions.FunctionAnnotation.class org.apache.flink.api.java.functions.FormattingMapper.class org.apache.flink.api.java.functions.GroupReduceIterator.class org.apache.flink.api.java.sampling.RandomSampler$1.class org.apache.flink.api.java.sampling.ReservoirSamplerWithoutReplacement.class org.apache.flink.api.java.sampling.BernoulliSampler.class org.apache.flink.api.java.sampling.PoissonSampler.class org.apache.flink.api.java.sampling.DistributedRandomSampler$1.class org.apache.flink.api.java.sampling.DistributedRandomSampler$2.class org.apache.flink.api.java.sampling.DistributedRandomSampler.class org.apache.flink.api.java.sampling.RandomSampler.class org.apache.flink.api.java.sampling.BernoulliSampler$1.class org.apache.flink.api.java.sampling.PoissonSampler$1.class org.apache.flink.api.java.sampling.IntermediateSampleData.class org.apache.flink.api.java.sampling.SampledIterator.class org.apache.flink.api.java.sampling.ReservoirSamplerWithReplacement.class org.apache.flink.api.java.ExecutionEnvironmentFactory.class org.apache.flink.api.java.LocalEnvironment$ExecutorReaper.class org.apache.flink.api.java.Utils.class org.apache.flink.api.java.CollectionEnvironment.class org.apache.flink.api.java.This0AccessFinder$1.class org.apache.flink.api.java.summarize.ObjectColumnSummary.class org.apache.flink.api.java.summarize.NumericColumnSummary.class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator$MaxFloatAggregator.class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator$MaxShortAggregator.class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator$MinFloatAggregator.class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator$SumShortAggregator.class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator$MinShortAggregator.class org.apache.flink.api.java.summarize.aggregation.CompensatedSum.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator$StringValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.StringSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator$ShortValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.Aggregator.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator$IntegerValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator$DoubleValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator$MinDoubleAggregator.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator$BooleanValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator$SumIntegerAggregator.class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator$SumDoubleAggregator.class org.apache.flink.api.java.summarize.aggregation.TupleSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator$MaxLongAggregator.class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator$SumLongAggregator.class org.apache.flink.api.java.summarize.aggregation.SummaryAggregatorFactory.class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.BooleanSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator$MaxIntegerAggregator.class org.apache.flink.api.java.summarize.aggregation.ObjectSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator$FloatValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.DoubleSummaryAggregator$MaxDoubleAggregator.class org.apache.flink.api.java.summarize.aggregation.IntegerSummaryAggregator$MinIntegerAggregator.class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.ShortSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.LongSummaryAggregator$MinLongAggregator.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator$LongValueSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator.class org.apache.flink.api.java.summarize.aggregation.FloatSummaryAggregator$SumFloatAggregator.class org.apache.flink.api.java.summarize.ColumnSummary.class org.apache.flink.api.java.summarize.StringColumnSummary.class org.apache.flink.api.java.summarize.BooleanColumnSummary.class org.apache.flink.api.java.ExecutionEnvironment.class org.apache.flink.api.java.utils.DataSetUtils$3.class org.apache.flink.api.java.utils.RequiredParametersException.class org.apache.flink.api.java.utils.RequiredParameters.class org.apache.flink.api.java.utils.DataSetUtils$2.class org.apache.flink.api.java.utils.DataSetUtils$2$1.class org.apache.flink.api.java.utils.DataSetUtils$4.class org.apache.flink.api.java.utils.ParameterTool.class org.apache.flink.api.java.utils.DataSetUtils$1.class org.apache.flink.api.java.utils.Option.class org.apache.flink.api.java.utils.OptionType.class org.apache.flink.api.java.utils.DataSetUtils$5.class org.apache.flink.api.java.utils.DataSetUtils.class org.apache.flink.api.java.utils.DataSetUtils$2$1$1.class org.apache.flink.api.java.utils.Option$1.class org.apache.flink.api.java.LocalEnvironment$ShutdownThread.class org.apache.flink.api.java.sca.TaggedValue$Input.class org.apache.flink.api.java.sca.ModifiedASMAnalyzer.class org.apache.flink.api.java.sca.TaggedValue.class org.apache.flink.api.java.sca.UdfAnalyzer.class org.apache.flink.api.java.sca.TaggedValue$Tag.class org.apache.flink.api.java.sca.CodeAnalyzerException.class org.apache.flink.api.java.sca.CodeErrorException.class org.apache.flink.api.java.sca.UdfAnalyzerUtils.class org.apache.flink.api.java.sca.ModifiedASMFrame.class org.apache.flink.api.java.sca.NestedMethodAnalyzer.class org.apache.flink.api.java.LocalEnvironment.class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat.class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase.class org.apache.flink.api.java.hadoop.mapred.utils.HadoopUtils.class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyProgressable.class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit.class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter.class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase.class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat.class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase.class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase.class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormat.class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase.class org.apache.flink.api.java.hadoop.mapreduce.utils.HadoopUtils.class org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit.class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase.class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat.class org.apache.flink.api.java.operators.CustomUnaryOperation.class org.apache.flink.api.java.operators.JoinOperator$JoinOperatorSets$JoinOperatorSetsPredicate.class org.apache.flink.api.java.operators.CoGroupOperator$1.class org.apache.flink.api.java.operators.DeltaIteration$1.class org.apache.flink.api.java.operators.PartitionOperator.class org.apache.flink.api.java.operators.CoGroupOperator.class org.apache.flink.api.java.operators.SingleInputUdfOperator.class org.apache.flink.api.java.operators.OperatorTranslation.class org.apache.flink.api.java.operators.join.JoinType.class org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.class org.apache.flink.api.java.operators.join.JoinFunctionAssigner.class org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase.class org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase$DefaultJoinFunctionAssigner.class org.apache.flink.api.java.operators.Operator.class org.apache.flink.api.java.operators.DataSink.class org.apache.flink.api.java.operators.UnsortedGrouping.class org.apache.flink.api.java.operators.GroupCombineOperator.class org.apache.flink.api.java.operators.CrossOperator$DefaultCross.class org.apache.flink.api.java.operators.CoGroupOperator$CoGroupOperatorSets$CoGroupOperatorSetsPredicate.class org.apache.flink.api.java.operators.ProjectOperator$Projection.class org.apache.flink.api.java.operators.UdfOperator.class org.apache.flink.api.java.operators.CrossOperator.class org.apache.flink.api.java.operators.BulkIterationResultSet.class org.apache.flink.api.java.operators.DeltaIteration$SolutionSetPlaceHolder.class org.apache.flink.api.java.operators.FilterOperator.class org.apache.flink.api.java.operators.MapPartitionOperator.class org.apache.flink.api.java.operators.CrossOperator$ProjectCross.class org.apache.flink.api.java.operators.DistinctOperator.class org.apache.flink.api.java.operators.Grouping.class org.apache.flink.api.java.operators.JoinOperator$1.class org.apache.flink.api.java.operators.UdfOperatorUtils.class org.apache.flink.api.java.operators.AggregateOperator$AggregatingUdf.class org.apache.flink.api.java.operators.SortedGrouping.class org.apache.flink.api.java.operators.KeyFunctions.class org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction.class org.apache.flink.api.java.operators.JoinOperator$ProjectJoin.class org.apache.flink.api.java.operators.JoinOperator$JoinOperatorSets.class org.apache.flink.api.java.operators.DistinctOperator$DistinctFunction.class org.apache.flink.api.java.operators.TwoInputOperator.class org.apache.flink.api.java.operators.CoGroupOperator$CoGroupOperatorSets$CoGroupOperatorSetsPredicate$CoGroupOperatorWithoutFunction.class org.apache.flink.api.java.operators.JoinOperator$JoinProjection.class org.apache.flink.api.java.operators.FlatMapOperator.class org.apache.flink.api.java.operators.ProjectOperator.class org.apache.flink.api.java.operators.DeltaIterationResultSet.class org.apache.flink.api.java.operators.CrossOperator$ProjectCrossFunction.class org.apache.flink.api.java.operators.SortPartitionOperator.class org.apache.flink.api.java.operators.AggregateOperator.class org.apache.flink.api.java.operators.CrossOperator$1.class org.apache.flink.api.java.operators.CoGroupOperator$CoGroupOperatorSets.class org.apache.flink.api.java.operators.CrossOperator$DefaultCrossFunction.class org.apache.flink.api.java.operators.JoinOperator$DefaultFlatJoinFunction.class org.apache.flink.api.java.operators.DataSource.class org.apache.flink.api.java.operators.JoinOperator$DefaultJoin$WrappingFlatJoinFunction.class org.apache.flink.api.java.operators.DeltaIteration$WorksetPlaceHolder.class org.apache.flink.api.java.operators.DeltaIteration.class org.apache.flink.api.java.operators.JoinOperator.class org.apache.flink.api.java.operators.TwoInputUdfOperator.class org.apache.flink.api.java.operators.CoGroupRawOperator.class org.apache.flink.api.java.operators.translation.KeyRemovingMapper.class org.apache.flink.api.java.operators.translation.PlanLeftUnwrappingCoGroupOperator$1.class org.apache.flink.api.java.operators.translation.PlanProjectOperator$1.class org.apache.flink.api.java.operators.translation.PlanFilterOperator$FlatMapFilter.class org.apache.flink.api.java.operators.translation.CombineToGroupCombineWrapper.class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator$TupleUnwrappingGroupCombinableGroupReducer.class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedReduceGroupOperator$TupleUnwrappingGroupCombinableGroupReducer.class org.apache.flink.api.java.operators.translation.WrappingFunction.class org.apache.flink.api.java.operators.translation.KeyExtractingMapper.class org.apache.flink.api.java.operators.translation.Tuple3WrappingCollector.class org.apache.flink.api.java.operators.translation.TupleUnwrappingIterator.class org.apache.flink.api.java.operators.translation.PlanRightUnwrappingCoGroupOperator.class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceOperator$1.class org.apache.flink.api.java.operators.translation.PlanUnwrappingGroupCombineOperator.class org.apache.flink.api.java.operators.translation.PlanLeftUnwrappingCoGroupOperator.class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedReduceGroupOperator$1.class org.apache.flink.api.java.operators.translation.TupleLeftUnwrappingJoiner.class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceOperator.class org.apache.flink.api.java.operators.translation.PlanLeftUnwrappingCoGroupOperator$TupleLeftUnwrappingCoGrouper.class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedGroupCombineOperator.class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator$1.class org.apache.flink.api.java.operators.translation.PlanBothUnwrappingCoGroupOperator$TupleBothUnwrappingCoGrouper.class org.apache.flink.api.java.operators.translation.RichCombineToGroupCombineWrapper.class org.apache.flink.api.java.operators.translation.PlanUnwrappingGroupCombineOperator$1.class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedReduceGroupOperator$TupleUnwrappingNonCombinableGroupReducer.class org.apache.flink.api.java.operators.translation.PlanRightUnwrappingCoGroupOperator$TupleRightUnwrappingCoGrouper.class org.apache.flink.api.java.operators.translation.PlanBothUnwrappingCoGroupOperator$1.class org.apache.flink.api.java.operators.translation.PlanRightUnwrappingCoGroupOperator$1.class org.apache.flink.api.java.operators.translation.TwoKeyExtractingMapper.class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator$TupleUnwrappingNonCombinableGroupReducer.class org.apache.flink.api.java.operators.translation.PlanProjectOperator.class org.apache.flink.api.java.operators.translation.PlanProjectOperator$MapProjector.class org.apache.flink.api.java.operators.translation.TupleUnwrappingJoiner.class org.apache.flink.api.java.operators.translation.TupleWrappingCollector.class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator.class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedGroupCombineOperator$TupleUnwrappingGroupReducer.class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceOperator$ReduceWrapper.class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedGroupCombineOperator$1.class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedReduceGroupOperator.class org.apache.flink.api.java.operators.translation.TupleRightUnwrappingJoiner.class org.apache.flink.api.java.operators.translation.PlanUnwrappingGroupCombineOperator$TupleUnwrappingGroupCombiner.class org.apache.flink.api.java.operators.translation.PlanBothUnwrappingCoGroupOperator.class org.apache.flink.api.java.operators.translation.PlanFilterOperator$1.class org.apache.flink.api.java.operators.translation.Tuple3UnwrappingIterator.class org.apache.flink.api.java.operators.translation.PlanFilterOperator.class org.apache.flink.api.java.operators.JoinOperator$EquiJoin.class org.apache.flink.api.java.operators.JoinOperator$EquiJoin$JoinOperatorBaseBuilder.class org.apache.flink.api.java.operators.UnionOperator.class org.apache.flink.api.java.operators.GroupReduceOperator.class org.apache.flink.api.java.operators.ReduceOperator.class org.apache.flink.api.java.operators.IterativeDataSet.class org.apache.flink.api.java.operators.JoinOperator$DefaultJoin.class org.apache.flink.api.java.operators.MapOperator.class org.apache.flink.api.java.operators.SingleInputOperator.class org.apache.flink.api.java.operators.CrossOperator$CrossProjection.class org.apache.flink.api.java.RemoteEnvironment$1.class org.apache.flink.api.java.ExecutionEnvironment$1.class org.apache.flink.api.java.Utils$CountHelper.class org.apache.flink.api.java.DataSet.class org.apache.flink.api.java.aggregation.MinAggregationFunction$MinAggregationFunctionFactory.class org.apache.flink.api.java.aggregation.MinAggregationFunction$MutableMinAgg.class org.apache.flink.api.java.aggregation.MinAggregationFunction$ImmutableMinAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$ShortValueSumAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$IntValueSumAgg.class org.apache.flink.api.java.aggregation.MaxAggregationFunction$ImmutableMaxAgg.class org.apache.flink.api.java.aggregation.MaxAggregationFunction$MutableMaxAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$ByteSumAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$FloatValueSumAgg.class org.apache.flink.api.java.aggregation.MaxAggregationFunction.class org.apache.flink.api.java.aggregation.SumAggregationFunction$DoubleValueSumAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$IntSumAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$FloatSumAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$ByteValueSumAgg.class org.apache.flink.api.java.aggregation.MaxAggregationFunction$MaxAggregationFunctionFactory.class org.apache.flink.api.java.aggregation.SumAggregationFunction$DoubleSumAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$LongValueSumAgg.class org.apache.flink.api.java.aggregation.SumAggregationFunction$SumAggregationFunctionFactory.class org.apache.flink.api.java.aggregation.SumAggregationFunction.class org.apache.flink.api.java.aggregation.SumAggregationFunction$ShortSumAgg.class org.apache.flink.api.java.aggregation.AggregationFunction.class org.apache.flink.api.java.aggregation.UnsupportedAggregationTypeException.class org.apache.flink.api.java.aggregation.Aggregations.class org.apache.flink.api.java.aggregation.MinAggregationFunction.class org.apache.flink.api.java.aggregation.AggregationFunctionFactory.class org.apache.flink.api.java.aggregation.SumAggregationFunction$LongSumAgg.class org.apache.flink.api.java.Utils$CollectHelper.class org.apache.flink.api.java.Utils$ChecksumHashCode.class org.apache.flink.api.java.io.TextOutputFormat.class org.apache.flink.api.java.io.CsvReader.class org.apache.flink.api.java.io.TupleCsvInputFormat.class org.apache.flink.api.java.io.TypeSerializerOutputFormat.class org.apache.flink.api.java.io.TextInputFormat.class org.apache.flink.api.java.io.TypeSerializerInputFormat.class org.apache.flink.api.java.io.TextOutputFormat$TextFormatter.class org.apache.flink.api.java.io.SplitDataProperties$SourcePartitionerMarker.class org.apache.flink.api.java.io.DiscardingOutputFormat.class org.apache.flink.api.java.io.SplitDataProperties.class org.apache.flink.api.java.io.LocalCollectionOutputFormat.class org.apache.flink.api.java.io.ParallelIteratorInputFormat.class org.apache.flink.api.java.io.CsvInputFormat.class org.apache.flink.api.java.io.PojoCsvInputFormat.class org.apache.flink.api.java.io.TextValueInputFormat.class org.apache.flink.api.java.io.CsvOutputFormat.class org.apache.flink.api.java.io.PrintingOutputFormat.class org.apache.flink.api.java.io.IteratorInputFormat.class org.apache.flink.api.java.io.CollectionInputFormat.class org.apache.flink.api.java.io.PrimitiveInputFormat.class org.apache.flink.api.java.DataSet$1.class org.apache.flink.api.java.Utils$ChecksumHashCodeHelper.class org.apache.flink.api.java.This0AccessFinder.class META-INF/DEPENDENCIES META-INF/NOTICE META-INF/LICENSE META-INF/maven/org.apache.flink/flink-java/pom.xml META-INF/maven/org.apache.flink/flink-java/pom.properties org.apache.flink.shaded.org.objectweb.asm.AnnotationVisitor.class org.apache.flink.shaded.org.objectweb.asm.AnnotationWriter.class org.apache.flink.shaded.org.objectweb.asm.Attribute.class org.apache.flink.shaded.org.objectweb.asm.ByteVector.class org.apache.flink.shaded.org.objectweb.asm.ClassReader.class org.apache.flink.shaded.org.objectweb.asm.ClassVisitor.class org.apache.flink.shaded.org.objectweb.asm.ClassWriter.class org.apache.flink.shaded.org.objectweb.asm.Context.class org.apache.flink.shaded.org.objectweb.asm.Edge.class org.apache.flink.shaded.org.objectweb.asm.FieldVisitor.class org.apache.flink.shaded.org.objectweb.asm.FieldWriter.class org.apache.flink.shaded.org.objectweb.asm.Frame.class org.apache.flink.shaded.org.objectweb.asm.Handle.class org.apache.flink.shaded.org.objectweb.asm.Handler.class org.apache.flink.shaded.org.objectweb.asm.Item.class org.apache.flink.shaded.org.objectweb.asm.Label.class org.apache.flink.shaded.org.objectweb.asm.MethodVisitor.class org.apache.flink.shaded.org.objectweb.asm.MethodWriter.class org.apache.flink.shaded.org.objectweb.asm.Opcodes.class org.apache.flink.shaded.org.objectweb.asm.Type.class org.apache.flink.shaded.org.objectweb.asm.TypePath.class org.apache.flink.shaded.org.objectweb.asm.TypeReference.class org.apache.flink.shaded.org.objectweb.asm.commons.AdviceAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.AnalyzerAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.CodeSizeEvaluator.class org.apache.flink.shaded.org.objectweb.asm.commons.GeneratorAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.InstructionAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.JSRInlinerAdapter$Instantiation.class org.apache.flink.shaded.org.objectweb.asm.commons.JSRInlinerAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.LocalVariablesSorter.class org.apache.flink.shaded.org.objectweb.asm.commons.Method.class org.apache.flink.shaded.org.objectweb.asm.commons.Remapper.class org.apache.flink.shaded.org.objectweb.asm.commons.RemappingAnnotationAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.RemappingClassAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.RemappingFieldAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.RemappingMethodAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.RemappingSignatureAdapter.class org.apache.flink.shaded.org.objectweb.asm.commons.SerialVersionUIDAdder$Item.class org.apache.flink.shaded.org.objectweb.asm.commons.SerialVersionUIDAdder.class org.apache.flink.shaded.org.objectweb.asm.commons.SimpleRemapper.class org.apache.flink.shaded.org.objectweb.asm.commons.StaticInitMerger.class org.apache.flink.shaded.org.objectweb.asm.commons.TableSwitchGenerator.class org.apache.flink.shaded.org.objectweb.asm.commons.TryCatchBlockSorter$1.class org.apache.flink.shaded.org.objectweb.asm.commons.TryCatchBlockSorter.class org.apache.flink.shaded.org.objectweb.asm.signature.SignatureReader.class org.apache.flink.shaded.org.objectweb.asm.signature.SignatureVisitor.class org.apache.flink.shaded.org.objectweb.asm.signature.SignatureWriter.class org.apache.flink.shaded.org.objectweb.asm.tree.AbstractInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.AnnotationNode.class org.apache.flink.shaded.org.objectweb.asm.tree.ClassNode.class org.apache.flink.shaded.org.objectweb.asm.tree.FieldInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.FieldNode.class org.apache.flink.shaded.org.objectweb.asm.tree.FrameNode.class org.apache.flink.shaded.org.objectweb.asm.tree.IincInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.InnerClassNode.class org.apache.flink.shaded.org.objectweb.asm.tree.InsnList$InsnListIterator.class org.apache.flink.shaded.org.objectweb.asm.tree.InsnList.class org.apache.flink.shaded.org.objectweb.asm.tree.InsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.IntInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.InvokeDynamicInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.JumpInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.LabelNode.class org.apache.flink.shaded.org.objectweb.asm.tree.LdcInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.LineNumberNode.class org.apache.flink.shaded.org.objectweb.asm.tree.LocalVariableAnnotationNode.class org.apache.flink.shaded.org.objectweb.asm.tree.LocalVariableNode.class org.apache.flink.shaded.org.objectweb.asm.tree.LookupSwitchInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.MethodInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.MethodNode$1.class org.apache.flink.shaded.org.objectweb.asm.tree.MethodNode.class org.apache.flink.shaded.org.objectweb.asm.tree.MultiANewArrayInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.ParameterNode.class org.apache.flink.shaded.org.objectweb.asm.tree.TableSwitchInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.TryCatchBlockNode.class org.apache.flink.shaded.org.objectweb.asm.tree.TypeAnnotationNode.class org.apache.flink.shaded.org.objectweb.asm.tree.TypeInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.VarInsnNode.class org.apache.flink.shaded.org.objectweb.asm.tree.analysis.Analyzer.class org.apache.flink.shaded.org.objectweb.asm.tree.analysis.AnalyzerException.class org.apache.flink.shaded.org.objectweb.asm.tree.analysis.BasicInterpreter.class org.apache.flink.shaded.org.objectweb.asm.tree.analysis.BasicValue.class org.apache.flink.shaded.org.objectweb.asm.tree.analysis.BasicVerifier.class org.apache.flink.shaded.org.objectweb.asm.tree.analysis.Frame.class #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	flink-core-1.1.1-hadoop1.jar /org.apache.flink/flink-core/1.1.1-hadoop1 查看flink-core所有版本文件 flink-shaded-hadoop1_2.10-1.1.1-hadoop1.jar /org.apache.flink/flink-shaded-hadoop1_2.10/1.1.1-hadoop1 查看flink-shaded-hadoop1_2.10所有版本文件 commons-math3-3.5.jar /org.apache.commons/commons-math3/3.5 查看commons-math3所有版本文件 guava-18.0.jar /com.google.guava/guava/18.0 查看guava所有版本文件 flink-test-utils-junit-1.1.1-hadoop1.jar /org.apache.flink/flink-test-utils-junit/1.1.1-hadoop1 查看flink-test-utils-junit所有版本文件 jsr305-1.3.9.jar /com.google.code.findbugs/jsr305/1.3.9 查看jsr305所有版本文件 commons-lang3-3.3.2.jar /org.apache.commons/commons-lang3/3.3.2 查看commons-lang3所有版本文件 slf4j-api-1.7.7.jar /org.slf4j/slf4j-api/1.7.7 查看slf4j-api所有版本文件 slf4j-log4j12-1.7.7.jar /org.slf4j/slf4j-log4j12/1.7.7 查看slf4j-log4j12所有版本文件 log4j-1.2.17.jar /log4j/log4j/1.2.17 查看log4j所有版本文件 junit-4.11.jar /junit/junit/4.11 查看junit所有版本文件 mockito-all-1.9.5.jar /org.mockito/mockito-all/1.9.5 查看mockito-all所有版本文件 powermock-module-junit4-1.5.5.jar /org.powermock/powermock-module-junit4/1.5.5 查看powermock-module-junit4所有版本文件 powermock-api-mockito-1.5.5.jar /org.powermock/powermock-api-mockito/1.5.5 查看powermock-api-mockito所有版本文件 hamcrest-all-1.3.jar /org.hamcrest/hamcrest-all/1.3 查看hamcrest-all所有版本文件 akka-testkit_2.10-2.3.7.jar /com.typesafe.akka/akka-testkit_2.10/2.3.7 查看akka-testkit_2.10所有版本文件