CREATE (alice:User{name:'Alice'})
CREATE (bob:User{name:'Bob'})
CREATE (eve:User{name:'Eve'})
CREATE (mallory:User {name:'Mallory'})
CREATE (peggy:User{name:'Peggy'})
CREATE (java:Product{name:'Java'})
Martin Junghanns s1ck
🦀
s1ck
/ overlap.adoc
Last active
December 26, 2015 05:18
s1ck
/ ConnectedComponentsExample.java
Last active
November 16, 2015 12:00
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.apache.flink.api.common.functions.FilterFunction; | |
| import org.apache.flink.api.common.functions.MapFunction; | |
| import org.apache.flink.api.java.DataSet; | |
| import org.apache.flink.api.java.ExecutionEnvironment; | |
| import org.apache.flink.api.java.functions.FunctionAnnotation; | |
| import org.apache.flink.graph.Edge; | |
| import org.apache.flink.graph.Graph; | |
| import org.apache.flink.graph.Vertex; | |
| import org.apache.flink.graph.library.ConnectedComponents; | |
| import org.apache.flink.types.NullValue; |
s1ck
/ SerializationIssue.java
Last active
November 27, 2015 17:31
Serialization Issue in Collection Environment
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.apache.flink.api.common.functions.GroupReduceFunction; | |
| import org.apache.flink.api.java.DataSet; | |
| import org.apache.flink.api.java.ExecutionEnvironment; | |
| import org.apache.flink.api.java.tuple.Tuple1; | |
| import org.apache.flink.runtime.StreamingMode; | |
| import org.apache.flink.test.util.ForkableFlinkMiniCluster; | |
| import org.apache.flink.test.util.TestBaseUtils; | |
| import org.apache.flink.test.util.TestEnvironment; | |
| import org.apache.flink.util.Collector; | |
| import org.apache.hadoop.io.WritableComparable; |
s1ck
/ PageRankWithConf.java
Last active
March 14, 2016 16:52
Example PageRank with custom scatter gather conf
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // your code to create vertices and edges | |
| Graph<Long, Double, Double> graph = Graph.fromDataSet(vertices, edges, env); | |
| ScatterGatherConfiguration conf = new ScatterGatherConfiguration(); | |
| conf.setSolutionSetUnmanagedMemory(true); | |
| long vertexCount = graph.numberOfVertices(); | |
| Graph<Long, Double, Double> ranks = graph.runScatterGatherIteration( | |
| new PageRank.VertexRankUpdater<>(0.85, vertexCount), |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ------------------------------------------------------------ | |
| The program finished with the following exception: | |
| org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Job execution failed. | |
| at org.apache.flink.client.program.Client.runBlocking(Client.java:381) | |
| at org.apache.flink.client.program.Client.runBlocking(Client.java:355) | |
| at org.apache.flink.client.program.Client.runBlocking(Client.java:315) | |
| at org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:60) | |
| at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855) | |
| at org.gradoop.model.impl.GraphBase.writeAsJson(GraphBase.java:264) |
s1ck
/ TypeProblem.java
Created
October 10, 2016 11:26
TypeProblem when using RichFlatMapFunction on GenericArray Types
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.apache.flink.api.common.functions.FlatJoinFunction; | |
| import org.apache.flink.api.common.functions.RichFlatJoinFunction; | |
| import org.apache.flink.api.java.DataSet; | |
| import org.apache.flink.api.java.ExecutionEnvironment; | |
| import org.apache.flink.api.java.operators.DataSource; | |
| import org.apache.flink.api.java.tuple.Tuple2; | |
| import org.apache.flink.util.Collector; | |
| public class TypeProblem { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.apache.flink.api.common.functions.MapFunction; | |
| import org.apache.flink.api.java.DataSet; | |
| import org.apache.flink.api.java.ExecutionEnvironment; | |
| import org.apache.flink.api.java.tuple.Tuple1; | |
| import java.lang.reflect.Array; | |
| public class Problem { | |
| public static class Pojo { |
s1ck
/ Neo4jGraphXExample.scala
Created
March 8, 2018 20:13
Demonstrates loading a graph from Neo4j into CAPS and running a GraphX algorithm
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // 1) Create CAPS session | |
| implicit val session: CAPSSession = CAPSSession.local() | |
| // 2) Load a graph from a running Neo4j instance. | |
| implicit val neo4jConfig = Neo4jConfig(uri = URI.create("bolt://localhost"), password = Some("password")) | |
| // 3) Create a data source | |
| val neo4jSource = new Neo4jPropertyGraphDataSource(neo4jConfig) | |
| // 4) Load the whole Neo4j DB |
s1ck
/ AuthorExample.java
Created
May 12, 2018 11:21
Author-Publication-Graph to CoAuthor-Graph Example
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.neo4j.minigds.connected_components; | |
| import org.neo4j.minigds.api.Algorithm; | |
| import org.neo4j.minigds.api.AlgorithmResult; | |
| import org.neo4j.minigds.api.Graph; | |
| import org.neo4j.minigds.utils.DirectToUndirectedGraphConverter; | |
| import java.util.ArrayList; | |
| import java.util.Collections; | |
| import java.util.LinkedList; |
OlderNewer