clear query| facets| time Search criteria: .   Results from 1 to 10 from 22 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - Usage of "onTime" in ProcessFunction - Flink - [mail # user]
...Thanks AndreyI do not have event time, dealing only with process time.My process gets 2 types of messages:1. Start processing, which starts the timer, creates a GUID and outputs event to ano...
   Author: Boris Lublinsky , 2018-08-31, 12:36
Using Managed Keyed State - Flink - [mail # user]
...Documentation https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/state/state.html#using-managed-keyed-state  lists ValueState and List, but their semantics seems to ...
   Author: Boris Lublinsky , 2018-08-31, 10:18
MapState Initializion - Flink - [mail # user]
...Any response to this?List State is created usingcheckpointedState = context.getOperatorStateStore.getListState (checkPointDescriptor)But there is no similar APIs for MapStateBoris LublinskyF...
   Author: Boris Lublinsky , 2018-01-16, 00:54
[expand - 1 more] - Questions about managed operator state - Flink - [mail # user]
...Thanks Fabian,After I switched to var it compiles, but its not initialized. @transient private var currentModels : MapState[String, Model] = _Assignes null to MapState.Do I create an empty h...
   Author: Boris Lublinsky , 2018-01-15, 01:39
[expand - 2 more] - Keyed State - Flink - [mail # user]
...Thanks FabianCan you also explain a thread model?What is the paralelization between multiple keys? Is it hash based?And also are processElement 1 and 2 are executed on different threads?More...
   Author: Boris Lublinsky , 2018-01-13, 19:34
user Digest 11 Jan 2018 11:24:06 -0000 Issue 2610 - Flink - [mail # user]
...Hi Timo "You don't need to specify the type in .flatMap() explicitly. It will be automatically extracted using the generic signature of DataDataConverter.”It does not. That is the reason why...
   Author: Boris Lublinsky , 2018-01-11, 14:55
[expand - 1 more] - Java types - Flink - [mail # user]
...More questionsIn Scala my DataProcessor is defined asclass DataProcessorKeyed extends CoProcessFunction[WineRecord, ModelToServe, Double] with CheckpointedFunction {And it is used as follows...
   Author: Boris Lublinsky , 2018-01-11, 04:13
[expand - 1 more] - Queryable State in Flink 1.4 - Flink - [mail # user]
...Thanks This was it.It would help to have this in documentation along with `flink-queryable-state-client`Boris LublinskyFDP Architect[EMAIL PROTECTED]https://www.lightbend.com/> On Jan 5, ...
   Author: Boris Lublinsky , 2018-01-05, 18:52
[expand - 1 more] - Custom Kryo serializer - Flink - [mail # user]
...Thanks Chesney,Can you, please, point me to any example? Boris LublinskyFDP Architect[EMAIL PROTECTED]https://www.lightbend.com/> On Jul 24, 2017, at 9:27 AM, Chesnay Schepler  wrote...
   Author: Boris Lublinsky , 2017-07-24, 14:31
Flink Beam runner - Flink - [mail # user]
...Current runner for Beam 2.0.0 is still on Scala version 2.10.Are there any plans (and dates) to provide runner for Scala 2.11  Boris LublinskyFDP Architect[EMAIL PROTECTED]https://www.l...
   Author: Boris Lublinsky , 2017-07-24, 14:16