org.apache.flink.streaming.api.operators.sorted.state

类 BatchExecutionStateBackend

java.lang.Object

org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionStateBackend

所有已实现的接口:

Serializable, org.apache.flink.runtime.state.StateBackend

public class BatchExecutionStateBackend
extends Object
implements org.apache.flink.runtime.state.StateBackend

A simple StateBackend which is used in a BATCH style execution.

另请参阅:

序列化表格

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.runtime.state.StateBackend

org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics, org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K>, org.apache.flink.runtime.state.StateBackend.OperatorStateBackendParameters

构造器概要

构造器

构造器和说明
BatchExecutionStateBackend()

方法概要

限定符和类型	方法和说明
<K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>	createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K> parameters)
org.apache.flink.runtime.state.OperatorStateBackend	createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend.OperatorStateBackendParameters parameters)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.flink.runtime.state.StateBackend

createAsyncKeyedStateBackend, getName, supportsAsyncKeyedStateBackend, supportsNoClaimRestoreMode, supportsSavepointFormat, useManagedMemory

构造器详细资料

BatchExecutionStateBackend

public BatchExecutionStateBackend()

方法详细资料

createKeyedStateBackend

public <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K> parameters)

指定者:

createKeyedStateBackend 在接口中 org.apache.flink.runtime.state.StateBackend

createOperatorStateBackend

public org.apache.flink.runtime.state.OperatorStateBackend createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend.OperatorStateBackendParameters parameters)
                                                                               throws Exception

指定者:

createOperatorStateBackend 在接口中 org.apache.flink.runtime.state.StateBackend

抛出:

Exception