Some algorithm example implementation using Apache Flink (
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Type Name Latest commit message Commit time
Failed to load latest commit information.

Apache Flink Example

This repository contains some example implementation of algorithm using Apache Flink ( Must be compiled with Eclipse JDT compiler for using lambda expressions.

Currently Implemented

How to Build and Run

  1. Use mvn package command to build. This command will compile whole source code using Eclipse JDT Compiler.
  2. Submit to Apache Flink cluster with proper arguments.
    • Example for PageRank - ./bin/flink run flink-example-1.0-SNAPSHOT.jar pagerank <INPUT> <OUTPUT> <NUM_OF_VERTICES>