:23 PM Dongwoo Kim
> wrote:
>
>> Hi community, I’m new to flink and trying to learn about the concepts of
>> flink to prepare migrating heron application to flink.
>> I have a quick question about this flink document.
>> (
>> https://nightlies.apache.org/flink/flink
2023 at 10:23 PM Dongwoo Kim
> wrote:
>
>> Hi community, I’m new to flink and trying to learn about the concepts of
>> flink to prepare migrating heron application to flink.
>> I have a quick question about this flink document.
>> (
>> https://nightlies.apache
m new to flink and trying to learn about the concepts of
> flink to prepare migrating heron application to flink.
> I have a quick question about this flink document.
> (
> https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/concepts/stateful-stream-processing/#snapsho
Hi community, I’m new to flink and trying to learn about the concepts of flink
to prepare migrating heron application to flink.
I have a quick question about this flink document.
(https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/concepts/stateful-stream-processing/#snapshotting
Thx for the quick answer
Get Outlook for iOS<https://aka.ms/o0ukef>
From: Chesnay Schepler
Sent: Thursday, June 22, 2017 12:13:23 PM
To: user@flink.apache.org
Subject: Re: Quick Question...
Hello,
in the DataSet API you can do this when specifyin
and
store it in a field.
Regards,
Chesnay
On 22.06.2017 19:56, Steve Jerman wrote:
Hi,
I have a quick question…
How do I set the Configuration passed into RichFunction.open?
I *thought* that setting GlobalJobParameters would do it ...
env.getConfig().setGlobalJobParameters(jobParameters
Hi,
I have a quick question…
How do I set the Configuration passed into RichFunction.open?
I *thought* that setting GlobalJobParameters would do it ...
env.getConfig().setGlobalJobParameters(jobParameters);
But it seems not…
Steve
The only thing you need to be aware of (in the batch API) is that you
cannot simply gather elements in a list any more.
The following does not work when enabling object reuse:
class MyReducer implements GroupReduceFunction {
public void reduceGroup(Iterable values, Collector out) {
Yes, you're right Arnaud.
Cheers,
Till
On Tue, Feb 9, 2016 at 10:42 AM, LINZ, Arnaud
wrote:
> Hi,
>
>
>
> I just want to be sure : when I set enableObjectReuse, I don’t need to
> create copies of objects that I get as input and return as output but which
> I don’t keep inside my user function ?
Hi,
I just want to be sure : when I set enableObjectReuse, I don’t need to create
copies of objects that I get as input and return as output but which I don’t
keep inside my user function ?
For instance, if I want to join Tuple2(A,B) with C into Tuple3(A,B,C) using a
Join function, I can write
10 matches
Mail list logo
