WindowBuffer.Factory (Flink : 2.0-SNAPSHOT API)

All Superinterfaces:

Serializable

All Known Implementing Classes:

RecordsWindowBuffer.Factory

Enclosing interface:

WindowBuffer

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
```
@FunctionalInterface
public static interface WindowBuffer.Factory
extends Serializable
```
A factory that creates a WindowBuffer.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`WindowBuffer`	`create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)`	Creates a `WindowBuffer` that buffers elements in memory before flushing.

- Method Detail
  - create
```
WindowBuffer create(Object operatorOwner,
                    MemoryManager memoryManager,
                    long memorySize,
                    RuntimeContext runtimeContext,
                    WindowTimerService<Long> timerService,
                    KeyedStateBackend<RowData> stateBackend,
                    WindowState<Long> windowState,
                    boolean isEventTime,
                    ZoneId shiftTimeZone)
             throws Exception
```
    Creates a WindowBuffer that buffers elements in memory before flushing.
    
    Parameters:
    
    operatorOwner - the owner of the operator
    
    memoryManager - the manager that governs memory by Flink framework
    
    memorySize - the managed memory size can be used by this operator
    
    runtimeContext - the current RuntimeContext
    
    timerService - the service to register event-time and processing-time timers
    
    stateBackend - the state backend to accessing states
    
    windowState - the window state to flush buffered data into.
    
    isEventTime - indicates whether the operator works in event-time or processing-time mode, used for register corresponding timers.
    
    shiftTimeZone - the shift timezone of the window
    
    Throws:
    
    IOException - thrown if the buffer can't be opened
    
    Exception