scala.Option.apply()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(204)

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

Option.apply介绍

暂无

代码示例

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

@Override
public synchronized Option<URL> resolve(Path remoteFile) {
  Option<URL> resolved = Option.apply(paths.get(remoteFile));
  return resolved;
}

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

/**
 * Transition the worker to a launched state.
 * @return a new worker instance (does not mutate the current instance).
 */
public Worker launchWorker(Protos.SlaveID slaveID, String hostname) {
  return new Worker(taskID, profile, Option.apply(slaveID), Option.apply(hostname), WorkerState.Launched);
}

代码示例来源：origin: com.typesafe.play/play-test_2.10

/**
 * A test Netty web server with HTTPS support
 * @param port HTTP port to bind on
 * @param application The Application to load in this server
 * @param sslPort HTTPS port to bind on
 */
public TestServer(int port, Application application, int sslPort) {
  super(port, application.getWrappedApplication(), Option.<Object>apply(sslPort), play.libs.Scala.<ServerProvider>None());
}

代码示例来源：origin: org.apache.spark/spark-core_2.10

@Override
 public Option<MapStatus> stop(boolean success) {
  try {
   taskContext.taskMetrics().incPeakExecutionMemory(getPeakMemoryUsedBytes());

   if (stopping) {
    return Option.apply(null);
   } else {
    stopping = true;
    if (success) {
     if (mapStatus == null) {
      throw new IllegalStateException("Cannot call stop(true) without having called write()");
     }
     return Option.apply(mapStatus);
    } else {
     return Option.apply(null);
    }
   }
  } finally {
   if (sorter != null) {
    // If sorter is non-null, then this implies that we called stop() in response to an error,
    // so we need to clean up memory and spill files created by the sorter
    sorter.cleanupResources();
   }
  }
 }
}

代码示例来源：origin: org.apache.spark/spark-core_2.11

@Override
 public Option<MapStatus> stop(boolean success) {
  try {
   taskContext.taskMetrics().incPeakExecutionMemory(getPeakMemoryUsedBytes());

   if (stopping) {
    return Option.apply(null);
   } else {
    stopping = true;
    if (success) {
     if (mapStatus == null) {
      throw new IllegalStateException("Cannot call stop(true) without having called write()");
     }
     return Option.apply(mapStatus);
    } else {
     return Option.apply(null);
    }
   }
  } finally {
   if (sorter != null) {
    // If sorter is non-null, then this implies that we called stop() in response to an error,
    // so we need to clean up memory and spill files created by the sorter
    sorter.cleanupResources();
   }
  }
 }
}

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

@Override
 public Option<MapStatus> stop(boolean success) {
  try {
   taskContext.taskMetrics().incPeakExecutionMemory(getPeakMemoryUsedBytes());

   if (stopping) {
    return Option.apply(null);
   } else {
    stopping = true;
    if (success) {
     if (mapStatus == null) {
      throw new IllegalStateException("Cannot call stop(true) without having called write()");
     }
     return Option.apply(mapStatus);
    } else {
     return Option.apply(null);
    }
   }
  } finally {
   if (sorter != null) {
    // If sorter is non-null, then this implies that we called stop() in response to an error,
    // so we need to clean up memory and spill files created by the sorter
    sorter.cleanupResources();
   }
  }
 }
}

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

/**
 * Triggers a savepoint for the job identified by the job id. The savepoint will be written to the given savepoint
 * directory, or {@link org.apache.flink.configuration.CheckpointingOptions#SAVEPOINT_DIRECTORY} if it is null.
 *
 * @param jobId job id
 * @param savepointDirectory directory the savepoint should be written to
 * @return path future where the savepoint is located
 * @throws FlinkException if no connection to the cluster could be established
 */
public CompletableFuture<String> triggerSavepoint(JobID jobId, @Nullable String savepointDirectory) throws FlinkException {
  final ActorGateway jobManager = getJobManagerGateway();
  Future<Object> response = jobManager.ask(new JobManagerMessages.TriggerSavepoint(jobId, Option.<String>apply(savepointDirectory)),
    new FiniteDuration(1, TimeUnit.HOURS));
  CompletableFuture<Object> responseFuture = FutureUtils.toJava(response);
  return responseFuture.thenApply((responseMessage) -> {
    if (responseMessage instanceof JobManagerMessages.TriggerSavepointSuccess) {
      JobManagerMessages.TriggerSavepointSuccess success = (JobManagerMessages.TriggerSavepointSuccess) responseMessage;
      return success.savepointPath();
    } else if (responseMessage instanceof JobManagerMessages.TriggerSavepointFailure) {
      JobManagerMessages.TriggerSavepointFailure failure = (JobManagerMessages.TriggerSavepointFailure) responseMessage;
      throw new CompletionException(failure.cause());
    } else {
      throw new CompletionException(
        new IllegalStateException("Unknown JobManager response of type " + responseMessage.getClass()));
    }
  });
}

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

/**
 * Get the persisted framework ID.
 * @return the current ID or empty if none is yet persisted.
 * @throws Exception on ZK failures, interruptions.
 */
@Override
public Option<Protos.FrameworkID> getFrameworkID() throws Exception {
  synchronized (startStopLock) {
    verifyIsRunning();
    Option<Protos.FrameworkID> frameworkID;
    byte[] value = frameworkIdInZooKeeper.getValue();
    if (value.length == 0) {
      frameworkID = Option.empty();
    } else {
      frameworkID = Option.apply(Protos.FrameworkID.newBuilder().setValue(new String(value,
        ConfigConstants.DEFAULT_CHARSET)).build());
    }
    return frameworkID;
  }
}

代码示例来源：origin: linkedin/kafka-monitor

void maybeAddPartitions(int minPartitionNum) {
 KafkaZkClient zkClient = KafkaZkClient.apply(_zkConnect, JaasUtils.isZkSecurityEnabled(), ZK_SESSION_TIMEOUT_MS,
   ZK_CONNECTION_TIMEOUT_MS, Integer.MAX_VALUE, Time.SYSTEM, METRIC_GROUP_NAME, "SessionExpireListener");
 AdminZkClient adminZkClient = new AdminZkClient(zkClient);
 try {
  scala.collection.Map<Object, scala.collection.Seq<Object>> existingAssignment = getPartitionAssignment(zkClient, _topic);
  int partitionNum = existingAssignment.size();
  if (partitionNum < minPartitionNum) {
   LOG.info("MultiClusterTopicManagementService will increase partition of the topic {} "
     + "in cluster {} from {} to {}.", _topic, _zkConnect, partitionNum, minPartitionNum);
   scala.Option<scala.collection.Map<java.lang.Object, scala.collection.Seq<java.lang.Object>>> replicaAssignment = scala.Option.apply(null);
   scala.Option<Seq<Object>> brokerList = scala.Option.apply(null);
   adminZkClient.addPartitions(_topic, existingAssignment, adminZkClient.getBrokerMetadatas(RackAwareMode.Disabled$.MODULE$, brokerList), minPartitionNum, replicaAssignment, false);
  }
 } finally {
  zkClient.close();
 }
}

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

Option<String> containerVolOpt = Option.<String>apply(flinkConfig.getString(MESOS_RM_CONTAINER_VOLUMES));
Option<String> dockerParamsOpt = Option.<String>apply(flinkConfig.getString(MESOS_RM_CONTAINER_DOCKER_PARAMETERS));
Option<String> uriParamsOpt = Option.<String>apply(flinkConfig.getString(MESOS_TM_URIS));
Option<String> taskManagerHostname = Option.apply(flinkConfig.getString(MESOS_TM_HOSTNAME));
Option<String> tmBootstrapCommand = Option.apply(flinkConfig.getString(MESOS_TM_BOOTSTRAP_CMD));
  gpus,
  containerType,
  Option.apply(imageName),
  containeredParameters,
  containerVolumes,

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

protected void registered(Registered message) {
  connectionMonitor.tell(message, selfActor);
  try {
    workerStore.setFrameworkID(Option.apply(message.frameworkId()));
  } catch (Exception ex) {
    onFatalError(new ResourceManagerException("Unable to store the assigned framework ID.", ex));
    return;
  }
  launchCoordinator.tell(message, selfActor);
  reconciliationCoordinator.tell(message, selfActor);
  taskMonitor.tell(message, selfActor);
}

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

scala.Option<String> stringNone = scala.Option.apply(null);
KafkaServer server = new KafkaServer(kafkaConfig, SystemTime$.MODULE$, stringNone);
server.startup();

代码示例来源：origin: twitter/distributedlog

@SuppressWarnings("unchecked")
private ClientBuilder setDefaultSettings(ClientBuilder builder) {
  return builder.name(clientName)
      .codec(ThriftClientFramedCodec.apply(Option.apply(clientId)))
      .failFast(false)
      .noFailureAccrual()
      // disable retries on finagle client builder, as there is only one host per finagle client
      // we should throw exception immediately on first failure, so DL client could quickly detect
      // failures and retry other proxies.
      .retries(1)
      .keepAlive(true);
}

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

scala.Option<String> stringNone = scala.Option.apply(null);
KafkaServer server = new KafkaServer(kafkaConfig, Time.SYSTEM, stringNone, new ArraySeq<KafkaMetricsReporter>(0));
server.startup();

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

scala.Option<String> stringNone = scala.Option.apply(null);
KafkaServer server = new KafkaServer(kafkaConfig, Time.SYSTEM, stringNone, new ArraySeq<KafkaMetricsReporter>(0));
server.startup();

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

scala.Option<String> stringNone = scala.Option.apply(null);
KafkaServer server = new KafkaServer(kafkaConfig, Time.SYSTEM, stringNone, new ArraySeq<KafkaMetricsReporter>(0));
server.startup();

代码示例来源：origin: org.apache.spark/spark-core_2.10

private void testMergingSpills(
  final boolean transferToEnabled,
  String compressionCodecName,
  boolean encrypt) throws Exception {
 if (compressionCodecName != null) {
  conf.set("spark.shuffle.compress", "true");
  conf.set("spark.io.compression.codec", compressionCodecName);
 } else {
  conf.set("spark.shuffle.compress", "false");
 }
 conf.set(org.apache.spark.internal.config.package$.MODULE$.IO_ENCRYPTION_ENABLED(), encrypt);
 SerializerManager manager;
 if (encrypt) {
  manager = new SerializerManager(serializer, conf,
   Option.apply(CryptoStreamUtils.createKey(conf)));
 } else {
  manager = new SerializerManager(serializer, conf);
 }
 when(blockManager.serializerManager()).thenReturn(manager);
 testMergingSpills(transferToEnabled, encrypt);
}

代码示例来源：origin: org.apache.spark/spark-core_2.11

private void testMergingSpills(
  final boolean transferToEnabled,
  String compressionCodecName,
  boolean encrypt) throws Exception {
 if (compressionCodecName != null) {
  conf.set("spark.shuffle.compress", "true");
  conf.set("spark.io.compression.codec", compressionCodecName);
 } else {
  conf.set("spark.shuffle.compress", "false");
 }
 conf.set(org.apache.spark.internal.config.package$.MODULE$.IO_ENCRYPTION_ENABLED(), encrypt);
 SerializerManager manager;
 if (encrypt) {
  manager = new SerializerManager(serializer, conf,
   Option.apply(CryptoStreamUtils.createKey(conf)));
 } else {
  manager = new SerializerManager(serializer, conf);
 }
 when(blockManager.serializerManager()).thenReturn(manager);
 testMergingSpills(transferToEnabled, encrypt);
}

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

private void testMergingSpills(
  final boolean transferToEnabled,
  String compressionCodecName,
  boolean encrypt) throws Exception {
 if (compressionCodecName != null) {
  conf.set("spark.shuffle.compress", "true");
  conf.set("spark.io.compression.codec", compressionCodecName);
 } else {
  conf.set("spark.shuffle.compress", "false");
 }
 conf.set(org.apache.spark.internal.config.package$.MODULE$.IO_ENCRYPTION_ENABLED(), encrypt);
 SerializerManager manager;
 if (encrypt) {
  manager = new SerializerManager(serializer, conf,
   Option.apply(CryptoStreamUtils.createKey(conf)));
 } else {
  manager = new SerializerManager(serializer, conf);
 }
 when(blockManager.serializerManager()).thenReturn(manager);
 testMergingSpills(transferToEnabled, encrypt);
}

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

new MesosConfiguration(masterUrl, frameworkInfo, scala.Option.apply(credential));

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

Option

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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