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