java8stream源码-trembita:轻松建模复杂的数据转换管道
需积分: 5 77 浏览量
2021-06-04
16:57:29
上传
评论
收藏 2.54MB ZIP 举报
java8stream源码-trembita:轻松建模复杂的数据转换管道 （185个子文件） 
.scalafmt.conf 328B .gitignore 58B scalavista.json 36KB settings.kts 1KB LICENSE 1KB README.md 11KB README.md 2KB README.md 1KB README.md 25B
bench-result.png 55KB trembita-p.png 13KB build.properties 18B build.sbt 10KB sonatype.sbt 973B plugins.sbt 418B agg22.scala 37KB groupBy22.scala 27KB OutputDslAkka.scala 18KB OutputDsl.scala 18KB pipelines.scala 17KB GroupingCriteria.scala 17KB aggregationInstances.scala 14KB spark.scala 11KB operations.scala 11KB SequentialSpec.scala 10KB ParallelSpec.scala 9KB KeepLeft.scala 9KB EnvironmentDependentOps.scala 9KB FSM.scala 9KB JstreamsSeqSpec.scala 7KB JstreamsParSpec.scala 7KB StreamingSpec.scala 6KB Environment.scala 6KB SizedAtLeast.scala 6KB streaming.scala 6KB rewrite.scala 6KB CanFSM.scala 5KB SparkSpec.scala 5KB EnvironmentIndependentOps.scala 5KB AkkaFSM.scala 5KB MapPipelineT.scala 5KB CanPauseAkkaFlow.scala 5KB CachingSpec.scala 4KB TrembitaQLSpec.scala 4KB SerializableMonad.scala 4KB package.scala 4KB IterableInput.scala 4KB package.scala 4KB package.scala 4KB package.scala 4KB CompleteFuture.scala 4KB OutputSpec.scala 4KB InfinispanDefaultCacheSpec.scala 4KB Dependencies.scala 4KB PauseSpec.scala 4KB operations.scala 4KB SparkStreamingFSM.scala 4KB JavaStreams.scala 3KB trembitaql.scala 3KB CanPause.scala 3KB CanCombineByKey.scala 3KB LocalCachingSpec.scala 3KB ReduceOutput.scala 3KB collections.scala 3KB ZipPipelineT.scala 3KB trembitaqlForSparkStreaming.scala 3KB MagnetF.scala 3KB DataPipelineT.scala 3KB OutputWithPropsT.scala 3KB WordsCountFiles.scala 3KB ToHList.scala 3KB SpanByFlow.scala 3KB FSMSample.scala 3KB KernelWordsCountBench.scala 3KB Keep.scala 3KB trembitaqlForSpark.scala 3KB RunAkka.scala 3KB FSMSample.scala 3KB FSMSample.scala 2KB Akka.scala 2KB Input.scala 2KB SparkFSM.scala 2KB QLSample.scala 2KB MagnetlessOps.scala 2KB Caching.scala 2KB JoinSpec.scala 2KB Main.scala 2KB InfinispanAkkaCaching.scala 2KB CanJoin.scala 2KB JoinFlow.scala 2KB Basic.scala 2KB FileInput.scala 2KB QLExample.scala 2KB MagnetlessSparkBasicOps.scala 2KB SparkStreaming.scala 2KB package.scala 2KB RDDSink.scala 2KB QLExample.scala 2KB CanSpanBy.scala 2KB LiftPipeline.scala 2KB共 185 条
- 1
- 2
资源评论
