Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-160650903
Ok great
---
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
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45747661
--- Diff: flink-staging/flink-ml/src/test/resources/LabeledSequenceData ---
@@ -0,0 +1,118
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45747298
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/BaumWelch.scala
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45717149
--- Diff: flink-staging/flink-ml/src/test/resources/LabeledSequenceData ---
@@ -0,0 +1,118
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45717108
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/BaumWelch.scala
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45716899
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/BaumWelch.scala
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45716863
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/BaumWelch.scala
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45716474
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Viterbi.scala
---
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45716370
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala
---
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45716083
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala
---
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45714216
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala
---
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1350#discussion_r45713681
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala
---
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1350#issuecomment-156363272
I have renamed the pull request and adapted the source code so that all
checks have passed.
---
If your project is set up for it, you can reply to this email and
GitHub user HilmiYildirim opened a pull request:
https://github.com/apache/flink/pull/1350
Implemented a parallel version of Hidden Markov Models. It uses a parâ¦
Implemented a parallel version of Hidden Markov Models. It uses a parallel
version of the Baum-Welch algorithm to
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-155820098
Unfortunately, I do not know a simple way to run an embedded RabbitMQ broker
---
If your project is set up for it, you can reply to this email and have your
reply
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-149248114
Somehow there was an error in the push. I fixed it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-149195168
I adapted the code and pushed it to my repo.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/1243#discussion_r42360149
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-148726397
Done. I hope this is ok.
---
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
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-147963553
There are test failures. But it seems this is not my fault.
Furthermore, I have not synchronized by the checkpointingLock when calling
addId. I think it is
GitHub user HilmiYildirim opened a pull request:
https://github.com/apache/flink/pull/1243
[FLINK-2624]: RabbitMQSource now extends MessageAcknowledgingSourceBase.
It now participates in checkpointing.
You can merge this pull request into a Git repository by running:
$ git
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-107551663
I think it is good.
---
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
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-105884995
Done. I hope every thing works fine.
---
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
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/706#discussion_r31007499
--- Diff:
flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java
---
@@ -0,0 +1,114
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-105415577
The problem is as follows. While I was working on the commit, the interface
SourceFunction has changed and was merged with the master. Now, it has the
methods
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-104243817
The problem was that the TwitterSource.next method was not implemented
properly. There were also dead code. I fixed it and now it is working.
---
If your project
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-104230142
TwitterSource does not work after the last update. Now, it sends null
messages. I try to fix it.
---
If your project is set up for it, you can reply to this email
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/702#issuecomment-104220763
I had some merging conflicts. Therefore, I did a new Pull Request
https://github.com/apache/flink/pull/706
---
If your project is set up for it, you can reply to
GitHub user HilmiYildirim opened a pull request:
https://github.com/apache/flink/pull/706
From stream to Hbase
See (https://github.com/apache/flink/pull/702)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/HilmiYildirim/flink
Github user HilmiYildirim closed the pull request at:
https://github.com/apache/flink/pull/702
---
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
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/702#issuecomment-104171850
Good idea. I am working on it.
---
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
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-104165135
I renamed the TwitterFilterSourceTest to TwitterFilterSourceExample because
it is more an example instead of a test. Further, I added JavaDoc comments and
I also
GitHub user HilmiYildirim opened a pull request:
https://github.com/apache/flink/pull/702
From stream to h base
I changed DataStream.writeToFile to DataStream.write and changed visibility
from private to public. Further, I implemented an example how to use
DataStream.write to
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/695#discussion_r30677156
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/695#discussion_r30622734
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/695#discussion_r30622577
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-103597087
Unfortunately, it is not possible ti implement this as Junit Tests. The
stream connection needs access keys of a twitter account and the maximum number
of parallel
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/695#discussion_r30621383
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSource.java
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-103499923
It is possible to implement an integration test. For example, I can
track a term and then I has to check if all tweets contain the term. If
you want I can
GitHub user HilmiYildirim opened a pull request:
https://github.com/apache/flink/pull/695
Implemented TwitterSourceFilter and adapted TwitterSource
I implemented the class TwitterFilterSource which inherits from
TwitterSource. It enables to filter twitter streams, for example, by
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/687#issuecomment-103460862
I do another Pull Request
---
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
Github user HilmiYildirim closed the pull request at:
https://github.com/apache/flink/pull/687
---
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
GitHub user HilmiYildirim opened a pull request:
https://github.com/apache/flink/pull/687
Implemented the class TwitterFilterSource
I implemented the class TwitterFilterSource which inherits from
TwitterSource. It enables to filter twitter streams by keywords, language,
location
43 matches
Mail list logo
