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

Configuration.setClass介绍

[英]Adds the given key/value pair to the configuration object. The class can be retrieved by invoking #getClass(String,Class,ClassLoader) if it is in the scope of the class loader on the caller.
[中]将给定的键/值对添加到配置对象。如果类在调用方的类加载器的作用域内，则可以通过调用#getClass（String，class，ClassLoader）来检索该类。

代码示例

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

@Override
public void setClass(String key, Class<?> klazz) {
  this.backingConfig.setClass(this.prefix + key, klazz);
}

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

public void setStreamOperator(StreamOperator<?> operator) {
  if (operator != null) {
    config.setClass(USER_FUNCTION, operator.getClass());
    try {
      InstantiationUtil.writeObjectToConfig(operator, this.config, SERIALIZEDUDF);
    } catch (IOException e) {
      throw new StreamTaskException("Cannot serialize operator object "
          + operator.getClass() + ".", e);
    }
  }
}

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

orig.setBoolean("shouldbetrue", true);
orig.setBytes("bytes sequence", new byte[] { 1, 2, 3, 4, 5 });
orig.setClass("myclass", this.getClass());

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

@Override
public void setClass(String key, Class<?> klazz) {
  this.backingConfig.setClass(this.prefix + key, klazz);
}

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

@Override
public void setClass(String key, Class<?> klazz) {
  this.backingConfig.setClass(this.prefix + key, klazz);
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

public void setStreamOperator(StreamOperator<?> operator) {
  if (operator != null) {
    config.setClass(USER_FUNCTION, operator.getClass());
    try {
      InstantiationUtil.writeObjectToConfig(operator, this.config, SERIALIZEDUDF);
    } catch (IOException e) {
      throw new StreamTaskException("Cannot serialize operator object "
          + operator.getClass() + ".", e);
    }
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.10

public void setStreamOperator(StreamOperator<?> operator) {
  if (operator != null) {
    config.setClass(USER_FUNCTION, operator.getClass());
    try {
      InstantiationUtil.writeObjectToConfig(operator, this.config, SERIALIZEDUDF);
    } catch (IOException e) {
      throw new StreamTaskException("Cannot serialize operator object "
          + operator.getClass() + ".", e);
    }
  }
}

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

public void setStreamOperator(StreamOperator<?> operator) {
  if (operator != null) {
    config.setClass(USER_FUNCTION, operator.getClass());
    try {
      InstantiationUtil.writeObjectToConfig(operator, this.config, SERIALIZEDUDF);
    } catch (IOException e) {
      throw new StreamTaskException("Cannot serialize operator object "
          + operator.getClass() + ".", e);
    }
  }
}