Skip to content

Instantly share code, notes, and snippets.

@okram
Created June 27, 2014 22:08
Show Gist options
  • Save okram/c17d17a0bd5759310174 to your computer and use it in GitHub Desktop.
Save okram/c17d17a0bd5759310174 to your computer and use it in GitHub Desktop.
$ bin/gremlin.sh
\,,,/
(o o)
─────oOOo─(3)─oOOo─────
gremlin> :use install com.tinkerpop giraph-gremlin 3.0.0-SNAPSHOT
==>loaded: [com.tinkerpop, giraph-gremlin, 3.0.0-SNAPSHOT] - restart the console to use [giraph]
gremlin> :q
$ bin/gremlin.sh
\,,,/
(o o)
─────oOOo─(3)─oOOo─────
loaded: giraph
gremlin> :remote connect giraph ../../../giraph-gremlin/conf/giraph-kryo.properties g
==>giraphgraph[kryovertexinputformat->kryovertexoutputformat]
gremlin> g.V.pageRank()
INFO com.tinkerpop.gremlin.giraph.process.computer.GiraphGraphRunner - GiraphGremlin: com.tinkerpop.gremlin.process.computer.ranking.PageRankVertexProgram@71aaddd3
INFO org.apache.giraph.job.GiraphJob - run: Since checkpointing is disabled (default), do not allow any task retries (setting mapred.map.max.attempts = 0, old value = 4)
WARN org.apache.hadoop.mapred.JobClient - Use GenericOptionsParser for parsing the arguments. Applications should implement Tool for the same.
INFO org.apache.hadoop.mapred.JobClient - Running job: job_201406270954_0009
INFO org.apache.hadoop.mapred.JobClient - map 0% reduce 0%
INFO org.apache.hadoop.mapred.JobClient - map 33% reduce 0%
INFO org.apache.hadoop.mapred.JobClient - map 66% reduce 0%
INFO org.apache.hadoop.mapred.JobClient - map 100% reduce 0%
INFO org.apache.hadoop.mapred.JobClient - Job complete: job_201406270954_0009
INFO org.apache.hadoop.mapred.JobClient - Counters: 57
INFO org.apache.hadoop.mapred.JobClient - Map-Reduce Framework
INFO org.apache.hadoop.mapred.JobClient - Spilled Records=0
INFO org.apache.hadoop.mapred.JobClient - Map input records=3
INFO org.apache.hadoop.mapred.JobClient - SPLIT_RAW_BYTES=132
INFO org.apache.hadoop.mapred.JobClient - Map output records=0
INFO org.apache.hadoop.mapred.JobClient - Total committed heap usage (bytes)=598736896
INFO org.apache.hadoop.mapred.JobClient - Giraph Timers
INFO org.apache.hadoop.mapred.JobClient - Shutdown (milliseconds)=72
INFO org.apache.hadoop.mapred.JobClient - Superstep 1 (milliseconds)=66
INFO org.apache.hadoop.mapred.JobClient - Superstep 23 (milliseconds)=30
INFO org.apache.hadoop.mapred.JobClient - Input superstep (milliseconds)=1002
INFO org.apache.hadoop.mapred.JobClient - Superstep 27 (milliseconds)=26
INFO org.apache.hadoop.mapred.JobClient - Superstep 10 (milliseconds)=33
INFO org.apache.hadoop.mapred.JobClient - Superstep 5 (milliseconds)=43
INFO org.apache.hadoop.mapred.JobClient - Superstep 22 (milliseconds)=36
INFO org.apache.hadoop.mapred.JobClient - Superstep 14 (milliseconds)=29
INFO org.apache.hadoop.mapred.JobClient - Total (milliseconds)=3100
INFO org.apache.hadoop.mapred.JobClient - Superstep 2 (milliseconds)=42
INFO org.apache.hadoop.mapred.JobClient - Superstep 18 (milliseconds)=30
INFO org.apache.hadoop.mapred.JobClient - Superstep 11 (milliseconds)=39
INFO org.apache.hadoop.mapred.JobClient - Superstep 24 (milliseconds)=34
INFO org.apache.hadoop.mapred.JobClient - Superstep 28 (milliseconds)=27
INFO org.apache.hadoop.mapred.JobClient - Superstep 15 (milliseconds)=29
INFO org.apache.hadoop.mapred.JobClient - Superstep 6 (milliseconds)=38
INFO org.apache.hadoop.mapred.JobClient - Superstep 19 (milliseconds)=29
INFO org.apache.hadoop.mapred.JobClient - Superstep 25 (milliseconds)=28
INFO org.apache.hadoop.mapred.JobClient - Superstep 8 (milliseconds)=33
INFO org.apache.hadoop.mapred.JobClient - Superstep 12 (milliseconds)=31
INFO org.apache.hadoop.mapred.JobClient - Superstep 20 (milliseconds)=27
INFO org.apache.hadoop.mapred.JobClient - Superstep 16 (milliseconds)=26
INFO org.apache.hadoop.mapred.JobClient - Superstep 9 (milliseconds)=34
INFO org.apache.hadoop.mapred.JobClient - Setup (milliseconds)=788
INFO org.apache.hadoop.mapred.JobClient - Superstep 3 (milliseconds)=42
INFO org.apache.hadoop.mapred.JobClient - Superstep 7 (milliseconds)=38
INFO org.apache.hadoop.mapred.JobClient - Superstep 13 (milliseconds)=29
INFO org.apache.hadoop.mapred.JobClient - Superstep 29 (milliseconds)=29
INFO org.apache.hadoop.mapred.JobClient - Superstep 26 (milliseconds)=29
INFO org.apache.hadoop.mapred.JobClient - Superstep 0 (milliseconds)=258
INFO org.apache.hadoop.mapred.JobClient - Superstep 21 (milliseconds)=27
INFO org.apache.hadoop.mapred.JobClient - Superstep 17 (milliseconds)=28
INFO org.apache.hadoop.mapred.JobClient - Superstep 4 (milliseconds)=41
INFO org.apache.hadoop.mapred.JobClient - File Input Format Counters
INFO org.apache.hadoop.mapred.JobClient - Bytes Read=0
INFO org.apache.hadoop.mapred.JobClient - Giraph Stats
INFO org.apache.hadoop.mapred.JobClient - Aggregate finished vertices=0
INFO org.apache.hadoop.mapred.JobClient - Aggregate edges=0
INFO org.apache.hadoop.mapred.JobClient - Sent messages=6
INFO org.apache.hadoop.mapred.JobClient - Current workers=2
INFO org.apache.hadoop.mapred.JobClient - Last checkpointed superstep=0
INFO org.apache.hadoop.mapred.JobClient - Current master task partition=0
INFO org.apache.hadoop.mapred.JobClient - Superstep=30
INFO org.apache.hadoop.mapred.JobClient - Aggregate vertices=6
INFO org.apache.hadoop.mapred.JobClient - FileSystemCounters
INFO org.apache.hadoop.mapred.JobClient - HDFS_BYTES_READ=1023
INFO org.apache.hadoop.mapred.JobClient - FILE_BYTES_WRITTEN=250695
INFO org.apache.hadoop.mapred.JobClient - HDFS_BYTES_WRITTEN=1197
INFO org.apache.hadoop.mapred.JobClient - Job Counters
INFO org.apache.hadoop.mapred.JobClient - Launched map tasks=3
INFO org.apache.hadoop.mapred.JobClient - SLOTS_MILLIS_REDUCES=0
INFO org.apache.hadoop.mapred.JobClient - Total time spent by all reduces waiting after reserving slots (ms)=0
INFO org.apache.hadoop.mapred.JobClient - SLOTS_MILLIS_MAPS=29685
INFO org.apache.hadoop.mapred.JobClient - Total time spent by all maps waiting after reserving slots (ms)=0
INFO org.apache.hadoop.mapred.JobClient - File Output Format Counters
INFO org.apache.hadoop.mapred.JobClient - Bytes Written=0
gremlin> g = g.getOutputGraph()
==>giraphgraph[kryovertexinputformat->kryovertexoutputformat]
gremlin> g.V.value(PageRankVertexProgram.PAGE_RANK)
==>0.15000000000000002
==>0.23181250000000003
==>0.4018125
==>0.19250000000000003
==>0.19250000000000003
==>0.15000000000000002
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment