Properties
assignWindows
assignWindows: ((Instant: any) => W[])
Type declaration
-
- (Instant: any): W[]
-
Returns W[]
assignsToOneWindow
assignsToOneWindow: (() => boolean)
Type declaration
-
- (): boolean
-
Returns boolean
Optional
beamName
beamName?: string
isMerging
isMerging: (() => boolean)
Type declaration
-
- (): boolean
-
Returns boolean
toProto
toProto: (() => FunctionSpec)
Type declaration
-
- (): FunctionSpec
-
Returns FunctionSpec
windowCoder
window
Coder
: (() => Coder<W>)