cascading:级联是功能丰富的API，用于在本地或集群上定义和执行复杂且容错的数据处理流。 见https （1162个子文件） 
.gitignore 181B build.gradle 11KB build.gradle 5KB build.gradle 3KB build.gradle 2KB build.gradle 2KB version.gradle 2KB build.gradle 2KB s3Upload.gradle 2KB build.gradle 2KB build.gradle 2KB build.gradle 2KB testing.gradle 2KB build.gradle 2KB properties.gradle 2KB build.gradle 1KB testingPlatform.gradle 1KB settings.gradle 1KB build.gradle 1KB build.gradle 1KB gradlew 6KB
unexpectedEndOfFile.gz 912B
gradle-wrapper.jar 58KB test-classpath.jar 856B JoinFieldedPipesPlatformTest.java 89KB BuildJobsHadoopPlatformTest.java 65KB CoGroupFieldedPipesPlatformTest.java 62KB Fields.java 58KB AssemblyHelpersPlatformTest.java 52KB TextDelimited.java 45KB BaseFlow.java 45KB Splice.java 45KB TextDelimited.java 42KB Util.java 37KB Hadoop2TezFlowStep.java 37KB FieldsTest.java 36KB MergePipesPlatformTest.java 36KB FieldedPipesPlatformTest.java 35KB ElementGraphs.java 35KB Tap.java 34KB BaseFlowStep.java 32KB TupleEntry.java 32KB HadoopUtil.java 31KB TupleSerialization.java 30KB FlowPlanner.java 30KB Hfs.java 28KB HadoopTapPlatformTest.java 28KB Tuple.java 27KB CoGroup.java 26KB BaseCascade.java 26KB CountBy.java 25KB JSONCopyIntoFunctionTest.java 25KB State.java 23KB CascadingStats.java 22KB RegressionPipesPlatformTest.java 21KB BasePartitionTap.java 21KB SerializedPipesPlatformTest.java 21KB Flow.java 21KB JSONCopyAsFunctionTest.java 20KB RuleExec.java 19KB FlowConnector.java 19KB AverageBy.java 19KB CascadingTestCase.java 19KB Scheme.java 18KB TrapPlatformTest.java 18KB FlowPlatformTest.java 17KB HadoopFlowStep.java 17KB FlowProcess.java 17KB TextLine.java 17KB BaseFlowNode.java 17KB DelimitedParser.java 16KB TraceWriter.java 16KB TapPlatformTest.java 16KB CountByLocally.java 16KB Unique.java 16KB FlowDef.java 16KB IsomorphismTest.java 16KB TupleEntryTest.java 15KB BaseProcessGraph.java 15KB FlowStepJob.java 15KB CascadePlatformTest.java 15KB SumBy.java 15KB Scope.java 15KB TezNodeStats.java 15KB AppProps.java 15KB AggregateBy.java 15KB FlowElementGraph.java 14KB Each.java 14KB DirTap.java 14KB RiffleCascadePlatformTest.java 14KB Hadoop2TezStreamGraph.java 14KB Operator.java 14KB CheckpointPlatformTest.java 14KB Hadoop2TezFlowStepJob.java 13KB ProcessFlow.java 13KB Pipe.java 13KB ScriptOperation.java 13KB CompositeFunction.java 13KB GroupBy.java 13KB BasicPipesPlatformTest.java 13KB共 1162 条
- 1
- 2
- 3
- 4
- 5
- 6
- 12
资源评论
