Hi Ufuk,
Thanks for reply.
The example is at [1]. I have few questions:
If there is no difference between KeyedStream- KeyedStream join by key and
DataStream-DataStream join, then DataStream becomes KeyedStream with
`where` and `equal` clauses. Please correct me If I am wrong.
Is the execution
Hey Adrienne!
On Wed, Oct 12, 2016 at 4:10 PM, Adrienne Kole wrote:
> Hi,
>
> I have 2 streams which are partitioned based on key field. I want to join
> those streams based on key fields on windows. This is an example I saw in
> the flink website:
>
> val firstInput: DataStream[MyType] = ...
>
Hi,
I have 2 streams which are partitioned based on key field. I want to join
those streams based on key fields on windows. This is an example I saw in
the flink website:
val firstInput: DataStream[MyType] = ...
val secondInput: DataStream[AnotherType] = ...
val firstKeyed = firstInput.keyBy("u
