Toggle navigation
Home
org.apache.flink.api.common.state.OperatorState to org.apache.flink.api.common.state.ValueState
No. of Instances - 31
No. of Commits - 4
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Other
0L
to
bCountsId
null
to
stateId
null
to
stateId
Long.class
to
LongSerializer.INSTANCE
Long.class
to
LongSerializer.INSTANCE
Long.class
to
LongSerializer.INSTANCE
Long.class
to
LongSerializer.INSTANCE
Integer.class
to
IntSerializer.INSTANCE
Integer.class
to
IntSerializer.INSTANCE
Add or Remove Method invocation
getRuntimeContext().getKeyValueState("b",Long.class,bCountsId)
to
getRuntimeContext().getPartitionedState(bCountsId)
createKeyValueState(STATE_NAME,outTypeSerializer,stateId)
to
getPartitionedState(stateId)
createKeyValueState(STATE_NAME,serializer,stateId)
to
getPartitionedState(stateId)
getRuntimeContext().getKeyValueState("a",NonSerializableLong.class,NonSerializableLong.of(0L))
to
getRuntimeContext().getPartitionedState(new ValueStateDescriptor<>("a",NonSerializableLong.of(0L),new KryoSerializer<>(NonSerializableLong.class,new ExecutionConfig())))
getRuntimeContext().getKeyValueState("a",NonSerializableLong.class,NonSerializableLong.of(0L))
to
getRuntimeContext().getPartitionedState(new ValueStateDescriptor<>("a",NonSerializableLong.of(0L),new KryoSerializer<>(NonSerializableLong.class,new ExecutionConfig())))
getRuntimeContext().getKeyValueState("pCount",LongSerializer.INSTANCE,0L)
to
getRuntimeContext().getPartitionedState(new ValueStateDescriptor<>("pCount",0L,LongSerializer.INSTANCE))
getRuntimeContext().getKeyValueState("my_state",LongSerializer.INSTANCE,0L)
to
getRuntimeContext().getPartitionedState(new ValueStateDescriptor<>("my_state",0L,LongSerializer.INSTANCE))
getRuntimeContext().getKeyValueState("my_state",LongSerializer.INSTANCE,0L)
to
getRuntimeContext().getPartitionedState(new ValueStateDescriptor<>("my_state",0L,LongSerializer.INSTANCE))
getRuntimeContext().getKeyValueState("b",LongSerializer.INSTANCE,0L)
to
getRuntimeContext().getPartitionedState(new ValueStateDescriptor<>("b",0L,LongSerializer.INSTANCE))
getRuntimeContext().getKeyValueState("totalCount",IntSerializer.INSTANCE,1)
to
getRuntimeContext().getState(new ValueStateDescriptor<>("totalCount",1,IntSerializer.INSTANCE))
getRuntimeContext().getKeyValueState("totalCount",IntSerializer.INSTANCE,0)
to
getRuntimeContext().getState(new ValueStateDescriptor<>("totalCount",0,IntSerializer.INSTANCE))
this.createKeyValueState(NFA_OPERATOR_STATE_NAME,new KryoSerializer<NFA<IN>>((Class<NFA<IN>>)(Class<?>)NFA.class,getExecutionConfig()),null)
to
getPartitionedState(new ValueStateDescriptor<NFA<IN>>(NFA_OPERATOR_STATE_NAME,new KryoSerializer<NFA<IN>>((Class<NFA<IN>>)(Class<?>)NFA.class,getExecutionConfig()),null))
this.createKeyValueState(PRIORIRY_QUEUE_STATE_NAME,new PriorityQueueSerializer<StreamRecord<IN>>(new StreamRecordSerializer<IN>(getInputSerializer()),new PriorityQueueStreamRecordFactory<IN>()),null)
to
getPartitionedState(new ValueStateDescriptor<PriorityQueue<StreamRecord<IN>>>(PRIORIRY_QUEUE_STATE_NAME,new PriorityQueueSerializer<StreamRecord<IN>>(new StreamRecordSerializer<IN>(getInputSerializer()),new PriorityQueueStreamRecordFactory<IN>()),null))
Cascading Type Change (Similar)
OperatorState<S>
to
ValueState<S>
OperatorState<S>
to
ValueState<S>
Update Anonymous class
{ @Override public S value() throws IOException { Serializable value=state.get(name); if (value == null) { state.put(name,defaultState); value=defaultState; } return (S)value; } @Override public void update( S value) throws IOException { state.put(name,value); } }
to
{ @Override public S value() throws IOException { Serializable value=state.get(name); if (value == null) { state.put(name,defaultState); value=defaultState; } return (S)value; } @Override public void update( S value) throws IOException { state.put(name,value); } @Override public void clear(){ state.remove(name); } }
{ @Override public S value() throws IOException { Serializable value=state.get(name); if (value == null) { state.put(name,defaultState); value=defaultState; } return (S)value; } @Override public void update( S value) throws IOException { state.put(name,value); } }
to
{ @Override public S value() throws IOException { Serializable value=state.get(name); if (value == null) { state.put(name,defaultState); value=defaultState; } return (S)value; } @Override public void update( S value) throws IOException { state.put(name,value); } @Override public void clear(){ state.remove(name); } }