首页
A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
Q
R
S
T
U
V
W
X
Y
Z
> flink-tests-0.6-hadoop2-incubating-tests.jar
标签:flink-tests-0.6-hadoop2-incubating-tests.jar,flink,tests,0.6,hadoop2,incubating,tests,jar包下载,依赖包
  • 云盘下载
  • Group
  • Artifact
  • Version
  • Download
  • >> Package Explorer
  • >>> Java Explorer <2.6.8>
    • META-INF
      • DEPENDENCIES
      • LICENSE
      • MANIFEST.MF
      • maven
        • org.apache.flink
          • flink-tests
            • pom.properties
            • pom.xml
      • NOTICE
    • org
      • apache
        • flink
          • test
            • accumulators
              • AccumulatorITCase.java
              • AccumulatorIterativeITCase.java
            • broadcastvars
              • BroadcastBranchingITCase.java
              • BroadcastVarsNepheleITCase.java
              • KMeansIterativeNepheleITCase.java
            • cancelling
              • CancellingTestBase.java
              • MapCancelingITCase.java
              • MatchJoinCancelingITCase.java
            • clients
              • examples
                • LocalExecutorITCase.java
            • compiler
              • examples
                • KMeansSingleStepTest.java
                • RelationalQueryCompilerTest.java
                • WordCountCompilerTest.java
              • iterations
                • ConnectedComponentsCoGroupTest.java
                • ConnectedComponentsTest.java
                • IterativeKMeansTest.java
                • MultipleJoinsWithSolutionSetCompilerTest.java
                • PageRankCompilerTest.java
              • plandump
                • DumpCompiledPlanTest.java
                • PreviewPlanDumpTest.java
            • distributedCache
              • DistributedCacheTest.java
            • exampleJavaPrograms
              • ConnectedComponentsITCase.java
              • EnumTriangleBasicITCase.java
              • EnumTriangleOptITCase.java
              • PageRankITCase.java
              • TransitiveClosureITCase.java
              • WebLogAnalysisITCase.java
              • WordCountITCase.java
              • WordCountWithCollectionITCase.java
            • exampleScalaPrograms
              • ComputeEdgeDegreesITCase.java
              • ConnectedComponentsITCase.java
              • EnumTrianglesOnEdgesWithDegreesITCase.java
              • IterativeKMeansITCase.java
              • RelationalQueryITCase.java
              • TransitiveClosureNaiveITCase.java
              • WebLogAnalysisITCase.java
              • WordCountITCase.java
              • WordCountPactValueITCase.java
              • WordCountWithCountFunctionITCase.java
            • failingPrograms
              • TaskFailureITCase.java
            • iterative
              • aggregators
                • AggregatorsITCase.java
                • ConnectedComponentsWithParametrizableAggregatorITCase.java
                • ConnectedComponentsWithParametrizableConvergenceITCase.java
              • BulkIterationWithAllReducerITCase.java
              • CoGroupConnectedComponentsITCase.java
              • CoGroupConnectedComponentsSecondITCase.java
              • ConnectedComponentsITCase.java
              • ConnectedComponentsWithDeferredUpdateITCase.java
              • ConnectedComponentsWithSolutionSetFirstITCase.java
              • DanglingPageRankITCase.java
              • DeltaPageRankITCase.java
              • DependencyConnectedComponentsITCase.java
              • IterationTerminationWithTerminationTail.java
              • IterationTerminationWithTwoTails.java
              • IterationWithAllReducerITCase.java
              • IterationWithChainingITCase.java
              • IterationWithUnionITCase.java
              • IterativeKMeansITCase.java
              • KMeansITCase.java
              • LineRankITCase.java
              • MultipleSolutionSetJoinsITCase.java
              • nephele
                • ConfigUtils.java
                • ConnectedComponentsNepheleITCase.java
                • customdanglingpagerank
                  • CustomCompensatableDanglingPageRank.java
                  • CustomCompensatableDanglingPageRankWithCombiner.java
                  • CustomCompensatableDotProductCoGroup.java
                  • CustomCompensatableDotProductMatch.java
                  • CustomCompensatingMap.java
                  • CustomImprovedAdjacencyListInputFormat.java
                  • CustomImprovedDanglingPageRankInputFormat.java
                  • CustomPageWithRankOutFormat.java
                  • CustomRankCombiner.java
                  • types
                    • VertexWithAdjacencyList.java
                    • VertexWithAdjacencyListComparator.java
                    • VertexWithAdjacencyListComparatorFactory.java
                    • VertexWithAdjacencyListSerializer.java
                    • VertexWithAdjacencyListSerializerFactory.java
                    • VertexWithRank.java
                    • VertexWithRankAndDangling.java
                    • VertexWithRankAndDanglingComparator.java
                    • VertexWithRankAndDanglingComparatorFactory.java
                    • VertexWithRankAndDanglingSerializer.java
                    • VertexWithRankAndDanglingSerializerFactory.java
                    • VertexWithRankComparator.java
                    • VertexWithRankComparatorFactory.java
                    • VertexWithRankDanglingToVertexWithAdjacencyListPairComparatorFactory.java
                    • VertexWithRankDanglingToVertexWithRankPairComparatorFactory.java
                    • VertexWithRankSerializer.java
                    • VertexWithRankSerializerFactory.java
                • danglingpagerank
                  • AsciiLongArrayView.java
                  • BooleanValue.java
                  • CompensatableDanglingPageRank.java
                  • CompensatableDotProductCoGroup.java
                  • CompensatableDotProductMatch.java
                  • CompensatingMap.java
                  • DanglingPageGenerateRankInputFormat.java
                  • DiffL1NormConvergenceCriterion.java
                  • ImprovedAdjacencyListInputFormat.java
                  • ImprovedDanglingPageRankInputFormat.java
                  • LongArrayView.java
                  • PageRankStats.java
                  • PageRankStatsAggregator.java
                  • PageWithRankOutFormat.java
                • DanglingPageRankNepheleITCase.java
                • DanglingPageRankWithCombinerNepheleITCase.java
                • IterationWithChainingNepheleITCase.java
                • JobGraphUtils.java
              • PageRankITCase.java
            • javaApiOperators
              • AggregateITCase.java
              • CoGroupITCase.java
              • CrossITCase.java
              • DistinctITCase.java
              • FilterITCase.java
              • FlatMapITCase.java
              • GroupReduceITCase.java
              • JoinITCase.java
              • MapITCase.java
              • ProjectITCase.java
              • ReduceITCase.java
              • SumMinMaxITCase.java
              • UnionITCase.java
              • util
                • CollectionDataSets.java
            • localDistributed
              • PackagedProgramEndToEndITCase.java
            • operators
              • CoGroupITCase.java
              • CrossITCase.java
              • io
                • ContractITCaseIOFormats.java
              • JoinITCase.java
              • MapITCase.java
              • ReduceITCase.java
              • UnionITCase.java
              • UnionSinkITCase.java
            • recordJobs
              • graph
                • ComputeEdgeDegrees.java
                • ConnectedComponentsWithCoGroup.java
                • DanglingPageRank.java
                • DeltaPageRankWithInitialDeltas.java
                • EnumTrianglesOnEdgesWithDegrees.java
                • EnumTrianglesRdfFoaf.java
                • EnumTrianglesWithDegrees.java
                • pageRankUtil
                  • AsciiLongArrayView.java
                  • DanglingPageRankInputFormat.java
                  • DiffL1NormConvergenceCriterion.java
                  • DotProductCoGroup.java
                  • DotProductMatch.java
                  • ImprovedAdjacencyListInputFormat.java
                  • LongArrayView.java
                  • PageRankStats.java
                  • PageRankStatsAggregator.java
                  • PageWithRankOutFormat.java
                • PairwiseSP.java
                • SimplePageRank.java
                • triangleEnumUtil
                  • EdgeInputFormat.java
                  • EdgeWithDegreesInputFormat.java
                  • EdgeWithDegreesOutputFormat.java
                  • TriangleOutputFormat.java
                • WorksetConnectedComponents.java
              • kmeans
                • KMeansBroadcast.java
                • KMeansCross.java
                • KMeansSingleStep.java
                • udfs
                  • ComputeDistance.java
                  • ComputeDistanceParameterized.java
                  • CoordVector.java
                  • FindNearestCenter.java
                  • PointInFormat.java
                  • PointOutFormat.java
                  • RecomputeClusterCenter.java
              • relational
                • MergeOnlyJoin.java
                • query1Util
                  • GroupByReturnFlag.java
                  • LineItemFilter.java
                  • LineItemFilterTest.java
                • query9Util
                  • AmountAggregate.java
                  • FilteredPartsJoin.java
                  • IntPair.java
                  • LineItemMap.java
                  • OrderedPartsJoin.java
                  • OrderMap.java
                  • PartFilter.java
                  • PartJoin.java
                  • PartListJoin.java
                  • PartsuppMap.java
                  • StringIntPair.java
                  • StringIntPairStringDataOutFormat.java
                  • SupplierMap.java
                  • SuppliersJoin.java
                • TPCHQuery1.java
                • TPCHQuery10.java
                • TPCHQuery3.java
                • TPCHQuery3Unioned.java
                • TPCHQuery4.java
                • TPCHQuery9.java
                • TPCHQueryAsterix.java
                • WebLogAnalysis.java
              • sort
                • ReduceGroupSort.java
                • TeraSort.java
                • tsUtil
                  • TeraDistribution.java
                  • TeraInputFormat.java
                  • TeraKey.java
                  • TeraOutputFormat.java
                  • TeraValue.java
              • util
                • ConfigUtils.java
                • DiscardingOutputFormat.java
                • InfiniteIntegerInputFormat.java
                • InfiniteIntegerInputFormatWithDelay.java
                • IntTupleDataInFormat.java
                • StringTupleDataOutFormat.java
                • Tuple.java
                • UniformIntInput.java
              • wordcount
                • WordCount.java
                • WordCountAccumulators.java
            • recordJobTests
              • CollectionSourceTest.java
              • CollectionValidationTest.java
              • ComputeEdgeDegreesITCase.java
              • EnumTrianglesOnEdgesWithDegreesITCase.java
              • EnumTrianglesRDFITCase.java
              • GlobalSortingITCase.java
              • GlobalSortingMixedOrderITCase.java
              • GroupOrderReduceITCase.java
              • MergeOnlyJoinITCase.java
              • PairwiseSPITCase.java
              • TeraSortITCase.java
              • TPCHQuery10ITCase.java
              • TPCHQuery3ITCase.java
              • TPCHQuery3WithUnionITCase.java
              • TPCHQuery4ITCase.java
              • TPCHQuery9ITCase.java
              • TPCHQueryAsterixITCase.java
              • WebLogAnalysisITCase.java
              • WordCountITCase.java
              • WordCountUnionReduceITCase.java
            • runtime
              • NetworkStackThroughput.java
            • testdata
              • WebLogAnalysisData.java
            • testPrograms
              • util
                • tests
                  • IntTupleDataInFormatTest.java
                  • TupleTest.java
            • util
              • FailingTestBase.java
              • testjar
      • testdata
        • terainput.txt