| Return | |
| Union | |
| Map (null, null) | |
| Union | |
| Project (#0..=#3) | |
| Negate | |
| Join on=(#0 = #4) | |
| Filter (#0 > #2) | |
| Get l0 | |
| Distinct group_by=[#0] |
| #[derive(Debug)] | |
| struct Container { | |
| x: i32, | |
| y: usize, | |
| } | |
| trait Contains<T> { | |
| fn get(&self) -> &T; | |
| fn set(&mut self, value: T); | |
| } |
| Model { | |
| box B1 = Get { | |
| id: GlobalId::User(0), | |
| unique_keys: [[0], [1]], | |
| columns: [ | |
| base(0): INT NOT NULL, | |
| base(1): INT NOT NULL, | |
| base(2): INT NOT NULL, | |
| ] | |
| } |
| /* | |
| * Copyright © 2014 TU Berlin (emma@dima.tu-berlin.de) | |
| * | |
| * Licensed under the Apache License, Version 2.0 (the "License"); | |
| * you may not use this file except in compliance with the License. | |
| * You may obtain a copy of the License at | |
| * | |
| * http://www.apache.org/licenses/LICENSE-2.0 | |
| * | |
| * Unless required by applicable law or agreed to in writing, software |
| import scala.util.control.TailCalls._ | |
| def time[R](block: => R): (Long, R) = { | |
| val t0 = System.nanoTime() | |
| val result = block // call-by-name | |
| val t1 = System.nanoTime() | |
| (t1 - t0, result) | |
| } | |
| val sin1 = (x: Double) => { |
| <?xml version="1.0" encoding="UTF-8"?> | |
| <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.springframework.org/schema/beans" | |
| xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> | |
| <!-- Preamble: Data Generators, Data Sets, Outputs, Experiments --> | |
| <!--************************************************************************ | |
| * Suites | |
| *************************************************************************--> |
| Copyright 2016, TU Berlin. | |
| This project includes software developed by TU Berlin. | |
| http://www.tu-berlin.de/ | |
| Licensed under the Apache License, Version 2.0 (the | |
| "License"); you may not use this file except in compliance | |
| with the License. You may obtain a copy of the License at: | |
| http://www.apache.org/licenses/LICENSE-2.0 |
| Application | Appears In |
|---|---|
| PageRank (and variations) | 1, 2, 4, 5, 6, 7, 8, 9, 10, 11, 13, 14, 15, 16, 17, 18, 19, 21, 22, 23, 24 |
| Connected Components (and variations) | 1 , 2, 6, 12, 13, 15, 16, 17, 19, 22, 23, 24 |
| SSSP (and variations) | 3, 6, 7, 10, 13, 14, 17, 22, 24 |
| ALS | 7, 14, 21, 23, 24 |
| Belief Propagation (and variations) | 4, 20, 21, 23, 24 |
| Graph Coloring | 7, 10, 12, 20 |
| import org.apache.flink.api.common.functions.RichFlatMapFunction | |
| import org.apache.flink.api.common.typeinfo.BasicTypeInfo | |
| import org.apache.flink.api.java.io.{TypeSerializerInputFormat, TypeSerializerOutputFormat} | |
| import org.apache.flink.api.java.typeutils.TupleTypeInfo | |
| import org.apache.flink.api.java.{ExecutionEnvironment, _} | |
| import org.apache.flink.core.fs.FileSystem.WriteMode | |
| import org.apache.flink.util.Collector | |
| object SerializedFormatExample { |