gt; >
> > > > -- Jingguo
> > > >
> > > > Matthias J. Sax 于2019年1月2日周三 下午10:27写道：
> > > > >
> > > > > > After some time, the window closes.
> > > > >
> > > > > This is not correct. Windows are based on event-
ome time, the window closes.
> > > >
> > > > This is not correct. Windows are based on event-time, and because no
> new
> > > > input record is processed, the window is not closed. That is the
> reason
> > > > why you don't get
t is the reason
> > > why you don't get any output. Only a new input record can advance
> > > "stream time" and close the window.
> > >
> > > In practice, when data flows continuously, this should not be a issue
> > > though.
> > >
&
gt; > "stream time" and close the window.
> >
> > In practice, when data flows continuously, this should not be a issue
> > though.
> >
> >
> > -Matthias
> >
> > On 12/31/18 8:22 AM, jingguo yao wrote:
> > > Sorry for my typo in
gt; In practice, when data flows continuously, this should not be a issue
> though.
>
>
> -Matthias
>
> On 12/31/18 8:22 AM, jingguo yao wrote:
> > Sorry for my typo in the mail. "Whey" should be "Why" in "Whey does
> > the window final result
ndow.
In practice, when data flows continuously, this should not be a issue
though.
-Matthias
On 12/31/18 8:22 AM, jingguo yao wrote:
> Sorry for my typo in the mail. "Whey" should be "Why" in "Whey does
> the window final result is not emitted after the window h
Sorry for my typo in the mail. "Whey" should be "Why" in "Whey does
the window final result is not emitted after the window has elapsed?"
I have browsed the Kafka source code and found the ca
I followed [1] to code a simple example to try suppress operator.
Here is the simple code:
final Serde stringSerde = Serdes.String();
final StreamsBuilder builder = new StreamsBuilder();
builder.stream("TextLinesTopic", Consumed.with(Serdes.String(),
Serdes.String()))
.flatMapValues(value -> Ar
