org.apache.flink.streaming.runtime.operators.windowing.buffers

Interface WindowBufferFactory<T,O,B extends WindowBuffer<T,O>>

Type Parameters:

T - The type of elements that the created WindowBuffer can store.

O - The type of elements that the created buffer will return when asked for its contents.

B - The type of the created WindowBuffer

All Superinterfaces:

Serializable

All Known Implementing Classes:

FoldingWindowBuffer.Factory, ListWindowBuffer.Factory, ReducingWindowBuffer.Factory

@Internal
public interface WindowBufferFactory<T,O,B extends WindowBuffer<T,O>>
extends Serializable

A factory for WindowBuffers.

Method Summary

Modifier and Type	Method and Description
B	create() Creates a new WindowBuffer.
B	restoreFromSnapshot(DataInputView in) Restores a WindowBuffer from a previous snapshot written using WindowBuffer.snapshot(DataOutputView).

Method Detail

create

B create()

Creates a new WindowBuffer.

restoreFromSnapshot

B restoreFromSnapshot(DataInputView in)
               throws IOException

Restores a WindowBuffer from a previous snapshot written using WindowBuffer.snapshot(DataOutputView).

Throws:

IOException