Modifier and Type | Method and Description |
---|---|
void |
JoinBolt.execute(TupleWindow inputWindow) |
Modifier and Type | Method and Description |
---|---|
void |
TestWindowBolt.execute(TupleWindow inputWindow) |
Modifier and Type | Method and Description |
---|---|
void |
TimeDataVerificationBolt.execute(TupleWindow inputWindow) |
void |
VerificationBolt.execute(TupleWindow inputWindow) |
Modifier and Type | Method and Description |
---|---|
void |
SlidingWindowSumBolt.execute(TupleWindow inputWindow) |
Modifier and Type | Method and Description |
---|---|
void |
IWindowedBolt.execute(TupleWindow inputWindow)
Process the tuple window and optionally emit new tuples based on the tuples in the input window.
|
Modifier and Type | Class and Description |
---|---|
class |
TupleWindowImpl
Holds the expired, new and current tuples in a window.
|
class |
TupleWindowIterImpl
An iterator based implementation over the events in a window.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.