scala.util.Try类的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(306)

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

Try介绍

暂无

代码示例

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

/**
 * Makes a prediction using MLeap API.
 *
 * @param inputFrame Input MLeap frame.
 * @return Prediction result.
 */
public double predict(DefaultLeapFrame inputFrame) {
  DefaultLeapFrame outputFrame = transformer.transform(inputFrame).get();
  Try<DefaultLeapFrame> resFrame = outputFrame.select(new Set.Set1<>(outputFieldName).toSeq());
  DefaultLeapFrame frame = resFrame.get();
  Stream<?> stream = (Stream<?>)frame.productElement(1);
  Row row = (Row)stream.head();
  return (Double)row.get(0);
}

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

@Override
 public Void apply(Try<T> v1) {
  if (v1.isSuccess()) {
   fut.complete(v1.get());
  } else {
   fut.fail(v1.failed().get());
  }
  return null;
 }
}, ec);

代码示例来源：origin: eclipse/ditto

private MessageMapper createInstanceFor(final String className)
    throws ClassNotFoundException, InstantiationException {
  final ClassTag<MessageMapper> tag = scala.reflect.ClassTag$.MODULE$.apply(MessageMapper.class);
  final List<Tuple2<Class<?>, Object>> constructorArgs = new ArrayList<>();
  final Try<MessageMapper> mapperTry =
      dynamicAccess.createInstanceFor(className, JavaConversions.asScalaBuffer(constructorArgs).toList(),
          tag);
  if (mapperTry.isFailure()) {
    final Throwable error = mapperTry.failed().get();
    if (error.getClass().isAssignableFrom(ClassNotFoundException.class)) {
      throw (ClassNotFoundException) error;
    } else if (error.getClass().isAssignableFrom(InstantiationException.class)) {
      throw (InstantiationException) error;
    } else if (error.getClass().isAssignableFrom(ClassCastException.class)) {
      throw (ClassCastException) error;
    } else {
      throw new IllegalStateException("There was an unknown error when trying to creating instance for '"
          + className + "'", error);
    }
  }
  return mapperTry.get();
}

代码示例来源：origin: johanandren/akka-actor-java8-webinar

if (result.isFailure()) {
 return complete(StatusCodes.SERVICE_UNAVAILABLE);
} else {
 final DbActor.ProductResult productResult = result.get();
 if (productResult.product.isPresent()) {
  return completeOK(productResult.product.get(), productMarshaller);

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

cachedFuture.value().get().isFailure()) {

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

@Override
 public Void apply(Try<T> v1) {
  if (v1.isSuccess()) {
   fut.complete();
  } else {
   fut.fail(v1.failed().get());
  }
  return null;
 }
}, ec);

代码示例来源：origin: org.eclipse.ditto/ditto-services-connectivity-mapping

private MessageMapper createInstanceFor(final String className)
    throws ClassNotFoundException, InstantiationException {
  final ClassTag<MessageMapper> tag = scala.reflect.ClassTag$.MODULE$.apply(MessageMapper.class);
  final List<Tuple2<Class<?>, Object>> constructorArgs = new ArrayList<>();
  final Try<MessageMapper> mapperTry =
      dynamicAccess.createInstanceFor(className, JavaConversions.asScalaBuffer(constructorArgs).toList(),
          tag);
  if (mapperTry.isFailure()) {
    final Throwable error = mapperTry.failed().get();
    if (error.getClass().isAssignableFrom(ClassNotFoundException.class)) {
      throw (ClassNotFoundException) error;
    } else if (error.getClass().isAssignableFrom(InstantiationException.class)) {
      throw (InstantiationException) error;
    } else if (error.getClass().isAssignableFrom(ClassCastException.class)) {
      throw (ClassCastException) error;
    } else {
      throw new IllegalStateException("There was an unknown error when trying to creating instance for '"
          + className + "'", error);
    }
  }
  return mapperTry.get();
}

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

@Override
 public Void apply(Try<V> v1) {
  if (v1.isSuccess()) {
   code.handle(Future.succeededFuture(v1.get()));
  } else {
   code.handle(Future.failedFuture(v1.failed().get()));
  }
  return null;
 }
};

代码示例来源：origin: com.typesafe.play/play_2.12

@Override
public boolean delete(TemporaryFile temporaryFile) {
  play.api.libs.Files.TemporaryFile scalaFile = asScala().create(temporaryFile.path());
  Try<Object> tryValue = asScala().delete(scalaFile);
  return (Boolean) tryValue.get();
}

代码示例来源：origin: org.talend.components/processing-runtime

private List<Object> getInputFields(IndexedRecord inputRecord, String columnName) {
  // Adapt non-avpath syntax to avpath.
  // TODO: This should probably not be automatic, use the actual syntax.
  if (!columnName.startsWith("."))
    columnName = "." + columnName;
  Try<scala.collection.immutable.List<Evaluator.Ctx>> result = wandou.avpath.package$.MODULE$.select(inputRecord,
      columnName);
  List<Object> values = new ArrayList<Object>();
  if (result.isSuccess()) {
    for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
      values.add(ctx.value());
    }
  } else {
    // Evaluating the expression failed, and we can handle the exception.
    Throwable t = result.failed().get();
    throw ProcessingErrorCode.createAvpathSyntaxError(t, columnName, -1);
  }
  return values;
}

代码示例来源：origin: com.typesafe.play/play_2.12

@Override
public boolean delete(TemporaryFile temporaryFile) {
  play.api.libs.Files.TemporaryFile scalaFile = asScala().create(temporaryFile.path());
  Try<Object> tryValue = asScala().delete(scalaFile);
  return (Boolean) tryValue.get();
}

代码示例来源：origin: org.talend.components/processing-runtime

/**
 * Use an AVPath to extract data from an indexed record
 * 
 * @param record an indexed record
 * @param avPath the path to elements to extract (can be one or multiples elements)
 * @return the extracted data as a list.
 */
public static List<Evaluator.Ctx> getInputFields(IndexedRecord record, String avPath) {
  // Adapt non-avpath syntax to avpath.
  // TODO: This should probably not be automatic, use the actual syntax.
  if (!avPath.startsWith("."))
    avPath = "." + avPath;
  Try<scala.collection.immutable.List<Evaluator.Ctx>> result =
      wandou.avpath.package$.MODULE$.select(record, avPath);
  List<Evaluator.Ctx> results = new ArrayList<Evaluator.Ctx>();
  if (result.isSuccess()) {
    for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
      results.add(ctx);
    }
  } else {
    // Evaluating the expression failed, and we can handle the exception.
    throw ProcessingErrorCode.createAvpathSyntaxError(result.failed().get(), avPath, -1);
  }
  return results;
}

代码示例来源：origin: com.typesafe.play/play_2.11

@Override
public boolean delete(TemporaryFile temporaryFile) {
  play.api.libs.Files.TemporaryFile scalaFile = asScala().create(temporaryFile.path());
  Try<Object> tryValue = asScala().delete(scalaFile);
  return (Boolean) tryValue.get();
}

代码示例来源：origin: Talend/components

/**
 * Use an AVPath to extract data from an indexed record
 * 
 * @param record an indexed record
 * @param avPath the path to elements to extract (can be one or multiples elements)
 * @return the extracted data as a list.
 */
public static List<Evaluator.Ctx> getInputFields(IndexedRecord record, String avPath) {
  // Adapt non-avpath syntax to avpath.
  // TODO: This should probably not be automatic, use the actual syntax.
  if (!avPath.startsWith("."))
    avPath = "." + avPath;
  Try<scala.collection.immutable.List<Evaluator.Ctx>> result =
      wandou.avpath.package$.MODULE$.select(record, avPath);
  List<Evaluator.Ctx> results = new ArrayList<Evaluator.Ctx>();
  if (result.isSuccess()) {
    for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
      results.add(ctx);
    }
  } else {
    // Evaluating the expression failed, and we can handle the exception.
    throw ProcessingErrorCode.createAvpathSyntaxError(result.failed().get(), avPath, -1);
  }
  return results;
}

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

@Override
public boolean delete(TemporaryFile temporaryFile) {
  play.api.libs.Files.TemporaryFile scalaFile = asScala().create(temporaryFile.path());
  Try<Object> tryValue = asScala().delete(scalaFile);
  return (Boolean) tryValue.get();
}

代码示例来源：origin: Talend/components

private List<Object> getInputFields(IndexedRecord inputRecord, String columnName) {
  // Adapt non-avpath syntax to avpath.
  // TODO: This should probably not be automatic, use the actual syntax.
  if (!columnName.startsWith("."))
    columnName = "." + columnName;
  Try<scala.collection.immutable.List<Evaluator.Ctx>> result = wandou.avpath.package$.MODULE$.select(inputRecord,
      columnName);
  List<Object> values = new ArrayList<Object>();
  if (result.isSuccess()) {
    for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
      values.add(ctx.value());
    }
  } else {
    // Evaluating the expression failed, and we can handle the exception.
    Throwable t = result.failed().get();
    throw ProcessingErrorCode.createAvpathSyntaxError(t, columnName, -1);
  }
  return values;
}

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

@Override
public boolean delete(TemporaryFile temporaryFile) {
  play.api.libs.Files.TemporaryFile scalaFile = asScala().create(temporaryFile.path());
  Try<Object> tryValue = asScala().delete(scalaFile);
  return (Boolean) tryValue.get();
}

代码示例来源：origin: com.lightbend.akka/akka-stream-alpakka-file

@Override
public void preStart() {
 chunkCallback =
   createAsyncCallback(
     (tryInteger) -> {
      if (tryInteger.isSuccess()) {
       int readBytes = tryInteger.get();
       if (readBytes > 0) {
        buffer.flip();
        push(out, ByteString.fromByteBuffer(buffer));
        position += readBytes;
        buffer.clear();
       } else {
        // hit end, try again in a while
        scheduleOnce("poll", pollingInterval);
       }
      } else {
       failStage(tryInteger.failed().get());
      }
     });
}

代码示例来源：origin: com.typesafe.play/play_2.11

@Override
public boolean delete(TemporaryFile temporaryFile) {
  play.api.libs.Files.TemporaryFile scalaFile = asScala().create(temporaryFile.path());
  Try<Object> tryValue = asScala().delete(scalaFile);
  return (Boolean) tryValue.get();
}

代码示例来源：origin: org.opendaylight.controller/sal-distributed-datastore

final TransactionContextWrapper newTransactionContextWrapper(final TransactionProxy parent, final String shardName) {
  final TransactionContextWrapper transactionContextWrapper =
      new TransactionContextWrapper(parent.getIdentifier(), actorContext);
  Future<PrimaryShardInfo> findPrimaryFuture = findPrimaryShard(shardName, parent.getIdentifier());
  if(findPrimaryFuture.isCompleted()) {
    Try<PrimaryShardInfo> maybe = findPrimaryFuture.value().get();
    if(maybe.isSuccess()) {
      onFindPrimaryShardSuccess(maybe.get(), parent, shardName, transactionContextWrapper);
    } else {
      onFindPrimaryShardFailure(maybe.failed().get(), parent, shardName, transactionContextWrapper);
    }
  } else {
    findPrimaryFuture.onComplete(new OnComplete<PrimaryShardInfo>() {
      @Override
      public void onComplete(final Throwable failure, final PrimaryShardInfo primaryShardInfo) {
        if (failure == null) {
          onFindPrimaryShardSuccess(primaryShardInfo, parent, shardName, transactionContextWrapper);
        } else {
          onFindPrimaryShardFailure(failure, parent, shardName, transactionContextWrapper);
        }
      }
    }, actorContext.getClientDispatcher());
  }
  return transactionContextWrapper;
}

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

Try

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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