org.apache.flink.runtime.execution.Environment.getExecutionConfig()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(6.6k)|赞(0)|评价(0)|浏览(223)

本文整理了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

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

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(Environment env, String operatorIdentifier) throws Exception {
  3.   return new DefaultOperatorStateBackend(
  4.     env.getUserClassLoader(),
  5.     env.getExecutionConfig(),
  6.     true) {
  7.     @Nonnull
  8.     @Override
  9.     public RunnableFuture<SnapshotResult<OperatorStateHandle>> snapshot(
  10.       long checkpointId,
  11.       long timestamp,
  12.       @Nonnull CheckpointStreamFactory streamFactory,
  13.       @Nonnull CheckpointOptions checkpointOptions) throws Exception {
  14.       throw new Exception("Sync part snapshot exception.");
  15.     }
  16.   };
  17. }

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(Environment env, String operatorIdentifier) throws Exception {
  3.   return new DefaultOperatorStateBackend(
  4.     env.getUserClassLoader(),
  5.     env.getExecutionConfig(),
  6.     true) {
  7.     @Nonnull
  8.     @Override
  9.     public RunnableFuture<SnapshotResult<OperatorStateHandle>> snapshot(
  10.       long checkpointId,
  11.       long timestamp,
  12.       @Nonnull CheckpointStreamFactory streamFactory,
  13.       @Nonnull CheckpointOptions checkpointOptions) throws Exception {
  14.       return new FutureTask<>(() -> {
  15.         throw new Exception("Async part snapshot exception.");
  16.       });
  17.     }
  18.   };
  19. }

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

  1. numberOfKeyGroups,
  2. keyGroupRange,
  3. env.getExecutionConfig(),
  4. isIncrementalCheckpointsEnabled(),
  5. getNumberOfTransferingThreads(),

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

  1. /**
  2.  * Returns the global ExecutionConfig.
  3.  */
  4. public ExecutionConfig getExecutionConfig() {
  5.   return this.environment.getExecutionConfig();
  6. }

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

  1. /**
  2.  * Returns the global ExecutionConfig.
  3.  */
  4. public ExecutionConfig getExecutionConfig() {
  5.   return this.environment.getExecutionConfig();
  6. }

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

  1. /**
  2.    * Returns the global ExecutionConfig.
  3.    */
  4.   public ExecutionConfig getExecutionConfig() {
  5.     return this.environment.getExecutionConfig();
  6.   }
  7. }

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

  1. /**
  2.  * Returns the global ExecutionConfig.
  3.  */
  4. public ExecutionConfig getExecutionConfig() {
  5.   return this.environment.getExecutionConfig();
  6. }

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.   Environment env,
  4.   String operatorIdentifier) throws Exception {
  5.   return new DefaultOperatorStateBackend(
  6.     env.getUserClassLoader(),
  7.     env.getExecutionConfig(),
  8.     asynchronousSnapshots);
  9. }

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

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

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

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

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.   Environment env,
  4.   String operatorIdentifier) throws Exception {
  5.   return new DefaultOperatorStateBackend(
  6.     env.getUserClassLoader(),
  7.     env.getExecutionConfig(),
  8.     asynchronousSnapshots);
  9. }

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

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

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.   Environment env,
  4.   String operatorIdentifier) {
  5.   return new DefaultOperatorStateBackend(
  6.     env.getUserClassLoader(),
  7.     env.getExecutionConfig(),
  8.       isUsingAsynchronousSnapshots());
  9. }

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.   Environment env,
  4.   String operatorIdentifier) {
  5.   return new DefaultOperatorStateBackend(
  6.     env.getUserClassLoader(),
  7.     env.getExecutionConfig(),
  8.     isUsingAsynchronousSnapshots());
  9. }

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.     Environment env,
  4.     String operatorIdentifier) throws Exception {
  5.   return new DefaultOperatorStateBackend(
  6.       env.getUserClassLoader(),
  7.       env.getExecutionConfig(),
  8.       isUsingAsynchronousSnapshots());
  9. }

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.     Environment env,
  4.     String operatorIdentifier) throws Exception {
  5.   return new DefaultOperatorStateBackend(
  6.       env.getUserClassLoader(),
  7.       env.getExecutionConfig(),
  8.       isUsingAsynchronousSnapshots());
  9. }

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.   Environment env,
  4.   String operatorIdentifier) {
  5.   return new DefaultOperatorStateBackend(
  6.     env.getUserClassLoader(),
  7.     env.getExecutionConfig(),
  8.       isUsingAsynchronousSnapshots());
  9. }

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

  1. @Override
  2. public OperatorStateBackend createOperatorStateBackend(
  3.   Environment env,
  4.   String operatorIdentifier) throws Exception {
  5.   return new DefaultOperatorStateBackend(
  6.     env.getUserClassLoader(),
  7.     env.getExecutionConfig(),
  8.     isUsingAsynchronousSnapshots());
  9. }

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

  1. @Override
  2. public AbstractInternalStateBackend createInternalStateBackend(
  3.   Environment env,
  4.   String operatorIdentifier,
  5.   int numberOfGroups,
  6.   KeyGroupRange keyGroupRange) {
  7.   return new HeapInternalStateBackend(
  8.       numberOfGroups,
  9.       keyGroupRange,
  10.       env.getUserClassLoader(),
  11.       env.getTaskStateManager().createLocalRecoveryConfig(),
  12.       env.getTaskKvStateRegistry(),
  13.       isUsingAsynchronousSnapshots(),
  14.       env.getExecutionConfig()
  15.     );
  16. }

内容来源于网络，如有侵权，请联系作者删除！

Environment

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com