Package | Description |
---|---|
org.apache.flink.api.common.functions | |
org.apache.flink.api.common.functions.util | |
org.apache.flink.api.common.state | |
org.apache.flink.runtime.state | |
org.apache.flink.state.api.runtime | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations on data streams.
|
org.apache.flink.streaming.tests.artificialstate.builder |
Modifier and Type | Method and Description |
---|---|
<T> ValueState<T> |
RuntimeContext.getState(ValueStateDescriptor<T> stateProperties)
Gets a handle to the system's key/value state.
|
Modifier and Type | Method and Description |
---|---|
<T> ValueState<T> |
AbstractRuntimeUDFContext.getState(ValueStateDescriptor<T> stateProperties) |
Modifier and Type | Method and Description |
---|---|
<T> ValueState<T> |
KeyedStateStore.getState(ValueStateDescriptor<T> stateProperties)
Gets a handle to the system's key/value state.
|
Modifier and Type | Method and Description |
---|---|
<T> ValueState<T> |
DefaultKeyedStateStore.getState(ValueStateDescriptor<T> stateProperties) |
Modifier and Type | Method and Description |
---|---|
<T> ValueState<T> |
SavepointRuntimeContext.getState(ValueStateDescriptor<T> stateProperties) |
Modifier and Type | Method and Description |
---|---|
QueryableStateStream<KEY,T> |
KeyedStream.asQueryableState(String queryableStateName,
ValueStateDescriptor<T> stateDescriptor)
Publishes the keyed stream as a queryable ValueState instance.
|
Modifier and Type | Method and Description |
---|---|
<T> ValueState<T> |
StreamingRuntimeContext.getState(ValueStateDescriptor<T> stateProperties) |
Modifier and Type | Method and Description |
---|---|
<T> ValueState<T> |
WindowOperator.MergingWindowStateStore.getState(ValueStateDescriptor<T> stateProperties) |
Constructor and Description |
---|
ArtificialValueStateBuilder(String stateName,
JoinFunction<IN,STATE,STATE> stateValueGenerator,
ValueStateDescriptor<STATE> valueStateDescriptor) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.