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

Configuration.setValueInternal介绍

暂无

代码示例

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setString(String key, String value) {
  setValueInternal(key, value);
}

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setBoolean(String key, boolean value) {
  setValueInternal(key, value);
}

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setFloat(String key, float value) {
  setValueInternal(key, value);
}

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setDouble(String key, double value) {
  setValueInternal(key, value);
}

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

/**
 * Adds the given byte array to the configuration object. If key is <code>null</code> then nothing is added.
 *
 * @param key
 *        The key under which the bytes are added.
 * @param bytes
 *        The bytes to be added.
 */
public void setBytes(String key, byte[] bytes) {
  setValueInternal(key, bytes);
}

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setInteger(String key, int value) {
  setValueInternal(key, value);
}

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setLong(String key, long value) {
  setValueInternal(key, value);
}

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

/**
 * Adds the given key/value pair to the configuration object. The class can be retrieved by invoking
 * {@link #getClass(String, Class, ClassLoader)} if it is in the scope of the class loader on the caller.
 *
 * @param key The key of the pair to be added
 * @param klazz The value of the pair to be added
 * @see #getClass(String, Class, ClassLoader)
 */
public void setClass(String key, Class<?> klazz) {
  setValueInternal(key, klazz.getName());
}

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

/**
 * Adds the given value to the configuration object.
 * The main key of the config option will be used to map the value.
 *
 * @param key
 *        the option specifying the key to be added
 * @param value
 *        the value of the key/value pair to be added
 */
@PublicEvolving
public void setBoolean(ConfigOption<Boolean> key, boolean value) {
  setValueInternal(key.key(), value);
}

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

/**
 * Adds the given value to the configuration object.
 * The main key of the config option will be used to map the value.
 *
 * @param key
 *        the option specifying the key to be added
 * @param value
 *        the value of the key/value pair to be added
 */
@PublicEvolving
public void setString(ConfigOption<String> key, String value) {
  setValueInternal(key.key(), value);
}

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

/**
 * Adds the given value to the configuration object.
 * The main key of the config option will be used to map the value.
 *
 * @param key
 *        the option specifying the key to be added
 * @param value
 *        the value of the key/value pair to be added
 */
@PublicEvolving
public void setLong(ConfigOption<Long> key, long value) {
  setValueInternal(key.key(), value);
}

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

/**
 * Adds the given value to the configuration object.
 * The main key of the config option will be used to map the value.
 *
 * @param key
 *        the option specifying the key to be added
 * @param value
 *        the value of the key/value pair to be added
 */
@PublicEvolving
public void setDouble(ConfigOption<Double> key, double value) {
  setValueInternal(key.key(), value);
}

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

/**
 * Adds the given value to the configuration object.
 * The main key of the config option will be used to map the value.
 *
 * @param key
 *        the option specifying the key to be added
 * @param value
 *        the value of the key/value pair to be added
 */
@PublicEvolving
public void setInteger(ConfigOption<Integer> key, int value) {
  setValueInternal(key.key(), value);
}

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

/**
 * Adds the given value to the configuration object.
 * The main key of the config option will be used to map the value.
 *
 * @param key
 *        the option specifying the key to be added
 * @param value
 *        the value of the key/value pair to be added
 */
@PublicEvolving
public void setFloat(ConfigOption<Float> key, float value) {
  setValueInternal(key.key(), value);
}

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

@Test
  public void testDelegationConfigurationWithPrefix() {
    String prefix = "pref-";
    String expectedKey = "key";

    /*
     * Key matches the prefix
     */
    Configuration backingConf = new Configuration();
    backingConf.setValueInternal(prefix + expectedKey, "value");

    DelegatingConfiguration configuration = new DelegatingConfiguration(backingConf, prefix);
    Set<String> keySet = configuration.keySet();

    assertEquals(keySet.size(), 1);
    assertEquals(keySet.iterator().next(), expectedKey);

    /*
     * Key does not match the prefix
     */
    backingConf = new Configuration();
    backingConf.setValueInternal("test-key", "value");

    configuration = new DelegatingConfiguration(backingConf, prefix);
    keySet = configuration.keySet();

    assertTrue(keySet.isEmpty());
  }
}

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

@Test
public void testDelegationConfigurationWithNullPrefix() {
  Configuration backingConf = new Configuration();
  backingConf.setValueInternal("test-key", "value");
  DelegatingConfiguration configuration = new DelegatingConfiguration(
      backingConf, null);
  Set<String> keySet = configuration.keySet();
  assertEquals(keySet, backingConf.keySet());
}

代码示例来源：origin: org.apache.flink/flink-core

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setFloat(String key, float value) {
  setValueInternal(key, value);
}

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setBoolean(String key, boolean value) {
  setValueInternal(key, value);
}

代码示例来源：origin: org.apache.flink/flink-core

/**
 * Adds the given byte array to the configuration object. If key is <code>null</code> then nothing is added.
 *
 * @param key
 *        The key under which the bytes are added.
 * @param bytes
 *        The bytes to be added.
 */
public void setBytes(String key, byte[] bytes) {
  setValueInternal(key, bytes);
}

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

/**
 * Adds the given key/value pair to the configuration object.
 *
 * @param key
 *        the key of the key/value pair to be added
 * @param value
 *        the value of the key/value pair to be added
 */
public void setFloat(String key, float value) {
  setValueInternal(key, value);
}