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

Environment.getExecutionConfig介绍

[英]Returns the job specific ExecutionConfig.
[中]返回作业特定的ExecutionConfig。

代码示例

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

@Override
public OperatorStateBackend createOperatorStateBackend(
    Environment env,
    String operatorIdentifier) throws Exception {
  //the default for RocksDB; eventually there can be a operator state backend based on RocksDB, too.
  final boolean asyncSnapshots = true;
  return new DefaultOperatorStateBackend(
      env.getUserClassLoader(),
      env.getExecutionConfig(),
      asyncSnapshots);
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(Environment env, String operatorIdentifier) throws Exception {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
    true) {
    @Nonnull
    @Override
    public RunnableFuture<SnapshotResult<OperatorStateHandle>> snapshot(
      long checkpointId,
      long timestamp,
      @Nonnull CheckpointStreamFactory streamFactory,
      @Nonnull CheckpointOptions checkpointOptions) throws Exception {
      throw new Exception("Sync part snapshot exception.");
    }
  };
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(Environment env, String operatorIdentifier) throws Exception {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
    true) {
    @Nonnull
    @Override
    public RunnableFuture<SnapshotResult<OperatorStateHandle>> snapshot(
      long checkpointId,
      long timestamp,
      @Nonnull CheckpointStreamFactory streamFactory,
      @Nonnull CheckpointOptions checkpointOptions) throws Exception {
      return new FutureTask<>(() -> {
        throw new Exception("Async part snapshot exception.");
      });
    }
  };
}

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

numberOfKeyGroups,
keyGroupRange,
env.getExecutionConfig(),
isIncrementalCheckpointsEnabled(),
getNumberOfTransferingThreads(),

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

/**
 * Returns the global ExecutionConfig.
 */
public ExecutionConfig getExecutionConfig() {
  return this.environment.getExecutionConfig();
}

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

/**
 * Returns the global ExecutionConfig.
 */
public ExecutionConfig getExecutionConfig() {
  return this.environment.getExecutionConfig();
}

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

/**
   * Returns the global ExecutionConfig.
   */
  public ExecutionConfig getExecutionConfig() {
    return this.environment.getExecutionConfig();
  }
}

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

/**
 * Returns the global ExecutionConfig.
 */
public ExecutionConfig getExecutionConfig() {
  return this.environment.getExecutionConfig();
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
  Environment env,
  String operatorIdentifier) throws Exception {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
    asynchronousSnapshots);
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
  Environment env,
  String operatorIdentifier) throws Exception {
  //the default for RocksDB; eventually there can be a operator state backend based on RocksDB, too.
  final boolean asyncSnapshots = true;
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
    asyncSnapshots);
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
    Environment env,
    String operatorIdentifier) throws Exception {
  //the default for RocksDB; eventually there can be a operator state backend based on RocksDB, too.
  final boolean asyncSnapshots = true;
  return new DefaultOperatorStateBackend(
      env.getUserClassLoader(),
      env.getExecutionConfig(),
      asyncSnapshots);
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
  Environment env,
  String operatorIdentifier) throws Exception {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
    asynchronousSnapshots);
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
    Environment env,
    String operatorIdentifier) throws Exception {
  //the default for RocksDB; eventually there can be a operator state backend based on RocksDB, too.
  final boolean asyncSnapshots = true;
  return new DefaultOperatorStateBackend(
      env.getUserClassLoader(),
      env.getExecutionConfig(),
      asyncSnapshots);
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
  Environment env,
  String operatorIdentifier) {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
      isUsingAsynchronousSnapshots());
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
  Environment env,
  String operatorIdentifier) {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
    isUsingAsynchronousSnapshots());
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
    Environment env,
    String operatorIdentifier) throws Exception {
  return new DefaultOperatorStateBackend(
      env.getUserClassLoader(),
      env.getExecutionConfig(),
      isUsingAsynchronousSnapshots());
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
    Environment env,
    String operatorIdentifier) throws Exception {
  return new DefaultOperatorStateBackend(
      env.getUserClassLoader(),
      env.getExecutionConfig(),
      isUsingAsynchronousSnapshots());
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
  Environment env,
  String operatorIdentifier) {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
      isUsingAsynchronousSnapshots());
}

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

@Override
public OperatorStateBackend createOperatorStateBackend(
  Environment env,
  String operatorIdentifier) throws Exception {
  return new DefaultOperatorStateBackend(
    env.getUserClassLoader(),
    env.getExecutionConfig(),
    isUsingAsynchronousSnapshots());
}

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

@Override
public AbstractInternalStateBackend createInternalStateBackend(
  Environment env,
  String operatorIdentifier,
  int numberOfGroups,
  KeyGroupRange keyGroupRange) {
  return new HeapInternalStateBackend(
      numberOfGroups,
      keyGroupRange,
      env.getUserClassLoader(),
      env.getTaskStateManager().createLocalRecoveryConfig(),
      env.getTaskKvStateRegistry(),
      isUsingAsynchronousSnapshots(),
      env.getExecutionConfig()
    );
}