org.apache.flink.api.common.state.ValueStateDescriptor.getName()方法的使用及代码示例

本文整理了Java中org.apache.flink.api.common.state.ValueStateDescriptor.getName()方法的一些代码示例，展示了ValueStateDescriptor.getName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ValueStateDescriptor.getName()方法的具体详情如下：
包路径：org.apache.flink.api.common.state.ValueStateDescriptor
类名称：ValueStateDescriptor
方法名：getName

ValueStateDescriptor.getName介绍

暂无

代码示例

代码示例来源：origin: apache/flink

static ArtificialStateBuilder createValueStateBuilder(
JoinFunction inputAndOldStateToNewState,
ValueStateDescriptor valueStateDescriptor) {
return new ArtificialValueStateBuilder<>(
valueStateDescriptor.getName(),
inputAndOldStateToNewState,
valueStateDescriptor);
}

代码示例来源：origin: apache/flink

@Test
public void testVeryLargeDefaultValue() throws Exception {
// ensure that we correctly read very large data when deserializing the default value
TypeSerializer serializer = new KryoSerializer<>(String.class, new ExecutionConfig());
byte[] data = new byte[200000];
for (int i = 0; i <200000; i++) {
data[i] = 65;
}
data[199000] = '\0';
String defaultValue = new String(data, ConfigConstants.DEFAULT_CHARSET);
ValueStateDescriptor descr =
new ValueStateDescriptor<>("testName", serializer, defaultValue);
assertEquals("testName", descr.getName());
assertEquals(defaultValue, descr.getDefaultValue());
assertNotNull(descr.getSerializer());
assertEquals(serializer, descr.getSerializer());
ValueStateDescriptor copy = CommonTestUtils.createCopySerializable(descr);
assertEquals("testName", copy.getName());
assertEquals(defaultValue, copy.getDefaultValue());
assertNotNull(copy.getSerializer());
assertEquals(serializer, copy.getSerializer());
}
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

@Override
public ValueState createValueState(ValueStateDescriptor stateDesc) throws Exception {
Preconditions.checkNotNull(stateDesc, "stateDesc cannot be null.");
String stateName = stateDesc.getName();
State state = states.get(stateName);
if (state == null) {
stateDesc.initializeSerializerUnlessSet(executionConfig);
KeyedValueStateDescriptor keyedStateDescriptor =
new KeyedValueStateDescriptor(
stateDesc.getName(),
keyContext.getKeySerializer(),
stateDesc.getSerializer()
);
KeyedValueState keyedState = internalStateBackend.getKeyedState(keyedStateDescriptor);
state = new ContextValueState<>(keyContext, keyedState, stateDesc);
registerAsQueryableState(stateDesc, state);
states.put(stateName, state);
}
return (ValueState) state;
}

代码示例来源：origin: com.alibaba.blink/flink-table

@Override
public SubKeyedValueState getSubKeyedValueState(
ValueStateDescriptor descriptor
) throws Exception {
if (namespaceSerializer == null) {
throw new RuntimeException("The namespace serializer has not been initialized.");
}
descriptor.initializeSerializerUnlessSet(operator.getExecutionConfig());
return operator.getSubKeyedState(
new SubKeyedValueStateDescriptor<>(
descriptor.getName(),
(TypeSerializer) operator.getKeySerializer(),
(TypeSerializer) namespaceSerializer,
descriptor.getSerializer()
)
);
}

代码示例来源：origin: com.alibaba.blink/flink-table

@Override
public KeyedValueState getKeyedValueState(
ValueStateDescriptor descriptor) throws Exception {
descriptor.initializeSerializerUnlessSet(operator.getExecutionConfig());
return operator.getKeyedState(
new KeyedValueStateDescriptor<>(
descriptor.getName(),
(TypeSerializer) operator.getKeySerializer(),
descriptor.getSerializer()
)
);
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

public ValueState createValueState(
TypeSerializer namespaceSerializer,
ValueStateDescriptor stateDesc) throws Exception {
Preconditions.checkNotNull(namespaceSerializer, "namespaceSerializer cannot be null.");
State state;
if (VoidNamespaceSerializer.INSTANCE.equals(namespaceSerializer)) {
state = createValueState(stateDesc);
} else {
Preconditions.checkNotNull(stateDesc, "stateDesc cannot be null.");
String stateName = stateDesc.getName();
state = states.get(stateName);
if (state == null) {
stateDesc.initializeSerializerUnlessSet(executionConfig);
SubKeyedValueStateDescriptor subKeyedValueStateDescriptor =
new SubKeyedValueStateDescriptor(
stateDesc.getName(),
keyContext.getKeySerializer(),
namespaceSerializer,
stateDesc.getSerializer()
);
SubKeyedValueState subKeyedValueState = internalStateBackend.getSubKeyedState(subKeyedValueStateDescriptor);
state = new ContextSubKeyedValueState<>(this.keyContext, subKeyedValueState, stateDesc.getDefaultValue());
registerAsQueryableState(stateDesc, state);
states.put(stateName, state);
}
}
return (ValueState) state;
}