test_class.file: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContextTest.java
test_class.identifier: StreamingRuntimeContextTest
test_case.body: @Test
  	public void testValueStateInstantiation() throws Exception {
  		
  		final ExecutionConfig config = new ExecutionConfig();
  		config.registerKryoType(Path.class);
  		
  		final AtomicReference<Object> descriptorCapture = new AtomicReference<>();
  		
  		StreamingRuntimeContext context = new StreamingRuntimeContext(
  				createMockOp(descriptorCapture, config),
  				createMockEnvironment(),
  				Collections.<String, Accumulator<?, ?>>emptyMap());
  
  		ValueStateDescriptor<TaskInfo> descr = new ValueStateDescriptor<>("name", TaskInfo.class, null);
  		context.getState(descr);
  		
  		StateDescriptor<?, ?> descrIntercepted = (StateDescriptor<?, ?>) descriptorCapture.get();
  		TypeSerializer<?> serializer = descrIntercepted.getSerializer();
  		
  		// check that the Path class is really registered, i.e., the execution config was applied
  		assertTrue(serializer instanceof KryoSerializer);
  		assertTrue(((KryoSerializer<?>) serializer).getKryo().getRegistration(Path.class).getId() > 0);
  	}
test_case.class_method_signature: StreamingRuntimeContextTest.testValueStateInstantiation()
test_case.full_signature: @Test public void testValueStateInstantiation()
test_case.identifier: testValueStateInstantiation
test_case.invocations: registerKryoType createMockOp createMockEnvironment emptyMap getState get getSerializer assertTrue assertTrue getId getRegistration getKryo
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testValueStateInstantiation()
focal_class.declarator: operator
focal_class.modifier: private final
focal_class.original_string: private final AbstractStreamOperator<?> operator;
focal_class.type: AbstractStreamOperator<?>
focal_class.var_name: operator
focal_class.declarator: taskEnvironment
focal_class.modifier: private final
focal_class.original_string: private final Environment taskEnvironment;
focal_class.type: Environment
focal_class.var_name: taskEnvironment
focal_class.declarator: streamConfig
focal_class.modifier: private final
focal_class.original_string: private final StreamConfig streamConfig;
focal_class.type: StreamConfig
focal_class.var_name: streamConfig
focal_class.file: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
focal_class.identifier: StreamingRuntimeContext
focal_class.class_method_signature: StreamingRuntimeContext.StreamingRuntimeContext(AbstractStreamOperator<?> operator,
  									Environment env, Map<String, Accumulator<?, ?>> accumulators)
focal_class.full_signature: public  StreamingRuntimeContext(AbstractStreamOperator<?> operator,
  									Environment env, Map<String, Accumulator<?, ?>> accumulators)
focal_class.identifier: StreamingRuntimeContext
focal_class.modifiers: public
focal_class.parameters: (AbstractStreamOperator<?> operator,
  									Environment env, Map<String, Accumulator<?, ?>> accumulators)
focal_class.signature:  StreamingRuntimeContext(AbstractStreamOperator<?> operator,
  									Environment env, Map<String, Accumulator<?, ?>> accumulators)
focal_class.class_method_signature: StreamingRuntimeContext.getInputSplitProvider()
focal_class.full_signature: public InputSplitProvider getInputSplitProvider()
focal_class.identifier: getInputSplitProvider
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: InputSplitProvider
focal_class.signature: InputSplitProvider getInputSplitProvider()
focal_class.class_method_signature: StreamingRuntimeContext.registerTimer(long time, Triggerable target)
focal_class.full_signature: public void registerTimer(long time, Triggerable target)
focal_class.identifier: registerTimer
focal_class.modifiers: public
focal_class.parameters: (long time, Triggerable target)
focal_class.return: void
focal_class.signature: void registerTimer(long time, Triggerable target)
focal_class.class_method_signature: StreamingRuntimeContext.getBroadcastVariable(String name)
focal_class.full_signature: @Override public List<RT> getBroadcastVariable(String name)
focal_class.identifier: getBroadcastVariable
focal_class.modifiers: @Override public
focal_class.parameters: (String name)
focal_class.return: List<RT>
focal_class.signature: List<RT> getBroadcastVariable(String name)
focal_class.class_method_signature: StreamingRuntimeContext.getBroadcastVariableWithInitializer(String name, BroadcastVariableInitializer<T, C> initializer)
focal_class.full_signature: @Override public C getBroadcastVariableWithInitializer(String name, BroadcastVariableInitializer<T, C> initializer)
focal_class.identifier: getBroadcastVariableWithInitializer
focal_class.modifiers: @Override public
focal_class.parameters: (String name, BroadcastVariableInitializer<T, C> initializer)
focal_class.return: C
focal_class.signature: C getBroadcastVariableWithInitializer(String name, BroadcastVariableInitializer<T, C> initializer)
focal_class.class_method_signature: StreamingRuntimeContext.getState(ValueStateDescriptor<T> stateProperties)
focal_class.full_signature: @Override public ValueState<T> getState(ValueStateDescriptor<T> stateProperties)
focal_class.identifier: getState
focal_class.modifiers: @Override public
focal_class.parameters: (ValueStateDescriptor<T> stateProperties)
focal_class.return: ValueState<T>
focal_class.signature: ValueState<T> getState(ValueStateDescriptor<T> stateProperties)
focal_class.class_method_signature: StreamingRuntimeContext.getListState(ListStateDescriptor<T> stateProperties)
focal_class.full_signature: @Override public ListState<T> getListState(ListStateDescriptor<T> stateProperties)
focal_class.identifier: getListState
focal_class.modifiers: @Override public
focal_class.parameters: (ListStateDescriptor<T> stateProperties)
focal_class.return: ListState<T>
focal_class.signature: ListState<T> getListState(ListStateDescriptor<T> stateProperties)
focal_class.class_method_signature: StreamingRuntimeContext.getReducingState(ReducingStateDescriptor<T> stateProperties)
focal_class.full_signature: @Override public ReducingState<T> getReducingState(ReducingStateDescriptor<T> stateProperties)
focal_class.identifier: getReducingState
focal_class.modifiers: @Override public
focal_class.parameters: (ReducingStateDescriptor<T> stateProperties)
focal_class.return: ReducingState<T>
focal_class.signature: ReducingState<T> getReducingState(ReducingStateDescriptor<T> stateProperties)
focal_class.class_method_signature: StreamingRuntimeContext.getKeyValueState(String name, Class<S> stateType, S defaultState)
focal_class.full_signature: @Override @Deprecated public OperatorState<S> getKeyValueState(String name, Class<S> stateType, S defaultState)
focal_class.identifier: getKeyValueState
focal_class.modifiers: @Override @Deprecated public
focal_class.parameters: (String name, Class<S> stateType, S defaultState)
focal_class.return: OperatorState<S>
focal_class.signature: OperatorState<S> getKeyValueState(String name, Class<S> stateType, S defaultState)
focal_class.class_method_signature: StreamingRuntimeContext.getKeyValueState(String name, TypeInformation<S> stateType, S defaultState)
focal_class.full_signature: @Override @Deprecated public OperatorState<S> getKeyValueState(String name, TypeInformation<S> stateType, S defaultState)
focal_class.identifier: getKeyValueState
focal_class.modifiers: @Override @Deprecated public
focal_class.parameters: (String name, TypeInformation<S> stateType, S defaultState)
focal_class.return: OperatorState<S>
focal_class.signature: OperatorState<S> getKeyValueState(String name, TypeInformation<S> stateType, S defaultState)
focal_class.class_method_signature: StreamingRuntimeContext.isCheckpointingEnabled()
focal_class.full_signature: public boolean isCheckpointingEnabled()
focal_class.identifier: isCheckpointingEnabled
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isCheckpointingEnabled()
focal_class.class_method_signature: StreamingRuntimeContext.getCheckpointMode()
focal_class.full_signature: public CheckpointingMode getCheckpointMode()
focal_class.identifier: getCheckpointMode
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: CheckpointingMode
focal_class.signature: CheckpointingMode getCheckpointMode()
focal_class.class_method_signature: StreamingRuntimeContext.getBufferTimeout()
focal_class.full_signature: public long getBufferTimeout()
focal_class.identifier: getBufferTimeout
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getBufferTimeout()
focal_class.superclass: extends AbstractRuntimeUDFContext
focal_method.body: @Override
  	public <T> ValueState<T> getState(ValueStateDescriptor<T> stateProperties) {
  		requireNonNull(stateProperties, "The state properties must not be null");
  		try {
  			stateProperties.initializeSerializerUnlessSet(getExecutionConfig());
  			return operator.getPartitionedState(stateProperties);
  		} catch (Exception e) {
  			throw new RuntimeException("Error while getting state", e);
  		}
  	}
focal_method.class_method_signature: StreamingRuntimeContext.getState(ValueStateDescriptor<T> stateProperties)
focal_method.full_signature: @Override public ValueState<T> getState(ValueStateDescriptor<T> stateProperties)
focal_method.identifier: getState
focal_method.invocations: requireNonNull initializeSerializerUnlessSet getExecutionConfig getPartitionedState
focal_method.modifiers: @Override public
focal_method.parameters: (ValueStateDescriptor<T> stateProperties)
focal_method.return: ValueState<T>
focal_method.signature: ValueState<T> getState(ValueStateDescriptor<T> stateProperties)