WindowProcessor (Flink : Table : Runtime 2.1.2-cp1 API)

Type Parameters:

W - the window type.

C - the context that provides some information for the window processor.

All Superinterfaces:

Serializable

All Known Subinterfaces:

AsyncStateSlicingWindowProcessor<W>, AsyncStateWindowProcessor<W>, SlicingSyncStateWindowProcessor<W>, SyncStateWindowProcessor<W>, UnslicingSyncStateWindowProcessor<W>

All Known Implementing Classes:

AbstractAsyncStateSliceWindowAggProcessor, AbstractAsyncStateWindowAggProcessor, AbstractSliceSyncStateWindowAggProcessor, AbstractSyncStateWindowAggProcessor, AsyncStateSliceSharedWindowAggProcessor, AsyncStateSliceUnsharedWindowAggProcessor, RowTimeSyncStateWindowDeduplicateProcessor, SliceSharedSyncStateWindowAggProcessor, SliceUnsharedSyncStateWindowAggProcessor, SyncStateWindowRankProcessor, UnsliceSyncStateWindowAggProcessor, WindowAggProcessorBase
```
@Internal
public interface WindowProcessor<W,C extends WindowProcessor.Context<W>>
extends Serializable
```
A base window processor provides common methods used for SyncStateWindowProcessor and AsyncStateWindowProcessor.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static interface WindowProcessor.Context<W>
Information available in an invocation of methods of WindowProcessor.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`close()`	The tear-down method of the function.
`org.apache.flink.api.common.typeutils.TypeSerializer<W>`	`createWindowSerializer()`	Returns the serializer of the window type.
`void`	`initializeWatermark(long watermark)`	Initializes the watermark which restores from state.
`void`	`open(C context)`	Initialization method for the function.

- Method Detail
  - open
```
void open(C context)
   throws Exception
```
    Initialization method for the function. It is called before the actual working methods.
    
    Throws:
    
    Exception
  - close
```
void close()
    throws Exception
```
    The tear-down method of the function. It is called after the last call to the main working methods.
    
    Throws:
    
    Exception
  - initializeWatermark
```
void initializeWatermark(long watermark)
```
    Initializes the watermark which restores from state. The method is called after open method and before the actual working methods.
    
    Parameters:
    
    watermark - the initial watermark
  - createWindowSerializer
```
org.apache.flink.api.common.typeutils.TypeSerializer<W> createWindowSerializer()
```
    Returns the serializer of the window type.