Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Modifier and Type | Method and Description |
---|---|
AbstractStateBackend.CheckpointStateOutputView |
AbstractStateBackend.createCheckpointStateOutputView(long checkpointID,
long timestamp)
Creates a
DataOutputView stream that writes into the state of the given checkpoint. |
Modifier and Type | Method and Description |
---|---|
protected void |
NonKeyedWindowOperator.Context.writeToState(AbstractStateBackend.CheckpointStateOutputView out) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.