clear query| facets| time Search criteria: .   Results from 1 to 10 from 45 (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
[expand - 1 more] - Java API to read metrics via JMX - Kafka - [mail # user]
...Yea, this is just a simple snippet of how to do this.Boker with JMX is how to get broker from zkBoris LublinskyFDP Architect[EMAIL PROTECTED]https://www.lightbend.com/> On Aug 8, 2018, at...
   Author: Boris Lublinsky , 2018-08-09, 02:37
[expand - 1 more] - Http streaming using Kafka+Akka - Kafka - [mail # user]
...Yes, reactive KafkaBoris LublinskyFDP Architect[EMAIL PROTECTED]https://www.lightbend.com/> On Jul 11, 2018, at 9:46 AM, Pulkit Manchanda  wrote:> > Thanks Boris.> Are you u...
   Author: Boris Lublinsky , 2018-07-11, 15:06
[expand - 1 more] - Some interesting use case - Beam - [mail # user]
...Ron,If you are talking about Tensorflow Saved model format, I personally think that it is overkill for model serving. My preferred option is to used traditional TF export, which can be optim...
   Author: Boris Lublinsky , 2018-01-17, 14:10
Strata Conference this March 6-8 - Beam - [mail # user]
...All for itBoris LublinskyFDP Architect[EMAIL PROTECTED]https://www.lightbend.com/> On Jan 16, 2018, at 7:01 PM, Ted Yu  wrote:> > +1 to BoF> > On Tue, Jan 16, 2018 at 5:0...
   Author: Boris Lublinsky , 2018-01-17, 01:06
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