Hello everybody,
I am using Flink (0.10.1) with a streaming source (Kafka) , and I write results
of flatMap/keyBy/timeWindow/reduce to a HBase table.
I have try with a class (Sinkclass) who implements SinkFunction, and
a class (HBaseOutputFormat) who implements OutputFormat. For you,
it's bett
Hi Thomas,
You can use both of the suggested solutions.
The benefit that you might get from HBaseOutputformat that it is already
tested and integrated with Flink as opposed to you having to connect to
HBase in a general SinkFunction.
Best,
Marton
On Dec 22, 2015 1:04 PM, "Thomas Lamirault"
wro
Hello,
I have just started testing out Flink and would like to migrate one of my
Spark Streaming jobs (Kafka->Spark->C*) to Flink.
- Is there anyone using with Flink with Cassandra?
- Does there exist a working Cassandra Sink, the only thing I have found is:
https://github.com/rzvoncek/flink/tree
Hello,
There is a way for define a EventTimeSourceFunction with anonymous
functions from the scala api? Like that:
env.addSource[Int] {
ctx => {
...
ctx.collectWithTimestamp(i, System.currentTimeMillis())
...
}
}
Thanks in advance!
Hi Niels,
Very good question! The config file which is written serves as a hint
for the client. When the YARN session is started without high
availability mode, i.e. no high availability settings have been found
in the client's config, the client will try to look up the job manager
using the hostn
