首页
•
知识库
•
资源下载
•
在线工具
•
索引
•
Jar
•
Java
•
关键词
•
常用命令
•
口令服务
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.1-hadoop2-incubating-tests.jar
标签:flink-tests-0.6.1-hadoop2-incubating-tests.jar,flink,tests,0.6.1,hadoop2,incubating,tests,jar包下载,依赖包
云盘下载
Group
Artifact
Version
Download
>> Package Explorer
>>> Java Explorer
<2.6.8>
Repositories
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