public static class ListWindowBuffer.Factory<T> extends Object implements WindowBufferFactory<T,T,ListWindowBuffer<T>>
Constructor and Description |
---|
Factory(TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
ListWindowBuffer<T> |
create()
Creates a new
WindowBuffer . |
ListWindowBuffer<T> |
restoreFromSnapshot(DataInputView in)
Restores a
WindowBuffer from a previous snapshot written using
WindowBuffer.snapshot(DataOutputView) . |
public Factory(TypeSerializer<T> serializer)
public ListWindowBuffer<T> create()
WindowBufferFactory
WindowBuffer
.create
in interface WindowBufferFactory<T,T,ListWindowBuffer<T>>
public ListWindowBuffer<T> restoreFromSnapshot(DataInputView in) throws IOException
WindowBufferFactory
WindowBuffer
from a previous snapshot written using
WindowBuffer.snapshot(DataOutputView)
.restoreFromSnapshot
in interface WindowBufferFactory<T,T,ListWindowBuffer<T>>
IOException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.