samoa-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From senorcarbone <>
Subject [GitHub] incubator-samoa pull request: Flink integration
Date Mon, 02 Mar 2015 11:55:31 GMT
GitHub user senorcarbone opened a pull request:

    Flink integration

    This PR includes support for Apache Flink as an adapter. We haven't updated the documentation
yet but we could perhaps do it in a follow up PR, since it seems you are already working on
a docs redesign. 

You can merge this pull request into a Git repository by running:

    $ git pull flink-integration

Alternatively you can review and apply these changes as the patch at:

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #11
commit 3e0545a5c63382a86c0e245cf1f421215f60f286
Author: senorcarbone <>
Date:   2014-12-04T23:01:33Z

    [flink] Initial commit for Flink Integration

commit 9219a26a8d47df5f9cc05fbebe21a7aa928b074a
Author: carbone <>
Date:   2015-01-12T22:41:49Z

    [flink] pom fix and license headers added

commit 96cde4719d20119bf0963804bf48eea57af62c10
Author: Paris Carbone <>
Date:   2015-01-15T11:06:11Z

    [flink] Added Flink stream composition and basic topology primitives
    [Flink] added the missing license
    [flink] Changes to Flink integration to SAMOA
    [flink] changes in order to debug
    [flink] Change Utils class
    [flink] minor refactorings
    [flink] StreamExecutionEnvironment passed through the factory
    Removed .iml files from git
    Add algorithm for detecting circles in the topology

commit 173c815dc687e8a769f87da41d944e5c37011e44
Author: fobeligi <>
Date:   2015-01-26T15:52:28Z

    [flink] Circle detection and circlular component initialization
    Added more checkes in the circleCanBeInitialised function. Added setters/getter
    change kryo version to pom file
    added debug printouts in FlinkProcessingItem class

commit 54de1b016706b1c8289fb681ec188626289ae53e
Author: Paris Carbone <>
Date:   2015-01-29T14:11:00Z

    [flink] minor refactorings added for debugging

commit 5602663aed05cc0829bc83c11865e1b55a2b8ff7
Author: fobeligi <>
Date:   2015-01-30T15:46:28Z

    [flink] SamoaTypeInfo and Serializer added.

commit 6bf26954a8fcda56fc82b60c07d454ab962c985a
Author: Paris Carbone <>
Date:   2015-02-02T15:53:07Z

    [flink] made a fix for grouped datastreams

commit 4fb7e83ac59fedec9186b812fd67de6ca6421246
Author: Paris Carbone <>
Date:   2015-02-04T09:40:59Z

    [flink] replaced output splitting with filters

commit 2b57f8365b27ae1aa48649aebd103e0c9b9c9069
Author: Paris Carbone <>
Date:   2015-02-04T16:43:32Z

    [flink] made proper samoatype serialization

commit e7507580034cb08f4b4915d44199377bd0cc151d
Author: fobeligi <>
Date:   2015-02-06T13:08:01Z

    [flink] Minor refactoring of code-change FlinkStream Ids getters/setters

commit 590eb4b1a6e914aa0bac4a92b5ddbf1cfbc64846
Author: Paris Carbone <>
Date:   2015-02-08T17:06:41Z

    [flink] typeinformation fix and rich functions for proper component initialisation

commit faffce77ddea5be696842570448b1516d505fb78
Author: fobeligi <>
Date:   2015-02-10T13:35:07Z

    [flink]updated circle initialization and detection

commit b9d053e7c95385c0a4330ed4376a7da803b4525c
Author: fobeligi <>
Date:   2015-02-11T14:16:34Z

    [flink] Modify Samoa executable and Refactoring of Utils file

commit 0f36d672b27c6b441638e6698d6f44f7197f25cb
Author: Paris Carbone <>
Date:   2015-02-16T18:49:56Z

    [flink] minor changes

commit c81ff5b3e90da35494a78f8b6a54bb91b5f65270
Author: fobeligi <>
Date:   2015-02-17T15:27:35Z

    [flink]Minor changes to execution parameters

commit 6d82de052d827fdae1db859178d62a3d4463c8fd
Author: fobeligi <>
Date:   2015-02-17T19:15:11Z

    [flink]Minor change to arguments

commit 18250dafc8204f1fffec1f0446b555d6c3534d14
Author: fobeligi <>
Date:   2015-02-18T15:08:16Z

    [flink] Fixed serialization exception in SamoaTypeSerializer
    [flink] minor refactorings added
    [flink] removed test main

commit 188b685ba990fd72ff70927fb0b87978ad04dc6e
Author: Paris Carbone <>
Date:   2015-02-23T23:00:34Z

    [flink] add fix for potential redundant filters and duplicate iteration heads
    [flink] small fixes
    [flink] removed iterativeDataStream

commit 10eed354dc53ba112d1e18cf82bcffb15b506ee9
Author: Fay Beligianni <>
Date:   2015-02-24T19:36:44Z

    [flink] Change SamoaType serialization
    [flink] removed unused types
    [flink] removed more unused methods

commit 50818be47cb19488c194187b243f5eb84070fce2
Author: Paris Carbone <>
Date:   2015-02-25T08:30:26Z

    [flink] repackaging for flink helper files


If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at or file a JIRA ticket
with INFRA.

View raw message