Hi
I am a CS PhD student at UMN Twin Cities. I am trying to use Flink for
implementing some very specific use-cases: (They may not seem relevant but I
need to implement them or I at least need to know if it is possible to
implement them in Flink)
Assumptions:
1. Data stream is of the form
Stephan,
That would be helpful. On job manager side, entry class provides such an
entry point hook. The problem is on the task manager side, where we don't
have such an initialization/entry point.
I have brought up the same question 3 months ago in this list with subject
"entrypoint for
Hi All,
i have table containing usage which is counter data type. every time i get
usage for a id and would like to user counter data time to increment it.
https://docs.datastax.com/en/cql/3.1/cql/cql_using/use_counter_t.html
Is it support POJO approach of cassandra sync or i have use SQL
