scala.collection.JavaConverters.iterableAsScalaIterableConverter()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(3.2k)|赞(0)|评价(0)|浏览(75)

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

JavaConverters.iterableAsScalaIterableConverter介绍

暂无

代码示例

代码示例来源:origin: com.typesafe.akka/akka-http-core

@SuppressWarnings("unchecked")
public static <T, U extends T> Seq<U> convertIterable(Iterable<T> els) {
  return scala.collection.JavaConverters.iterableAsScalaIterableConverter((Iterable<U>)els).asScala().toVector();
}
public static <T, U extends T> Seq<U> convertArray(T[] els) {

代码示例来源:origin: com.typesafe.akka/akka-http-core_2.12

@SuppressWarnings("unchecked")
public static <T, U extends T> Seq<U> convertIterable(Iterable<T> els) {
  return scala.collection.JavaConverters.iterableAsScalaIterableConverter((Iterable<U>)els).asScala().toVector();
}
public static <T, U extends T> Seq<U> convertArray(T[] els) {

代码示例来源:origin: com.typesafe.akka/akka-http-core-experimental

@SuppressWarnings("unchecked")
public static <T, U extends T> Seq<U> convertIterable(Iterable<T> els) {
  return scala.collection.JavaConverters.iterableAsScalaIterableConverter((Iterable<U>)els).asScala().toVector();
}
@SuppressWarnings("unchecked")

代码示例来源:origin: com.typesafe.akka/akka-http-core_2.11

@SuppressWarnings("unchecked")
public static <T, U extends T> Seq<U> convertIterable(Iterable<T> els) {
  return scala.collection.JavaConverters.iterableAsScalaIterableConverter((Iterable<U>)els).asScala().toVector();
}
public static <T, U extends T> Seq<U> convertArray(T[] els) {

代码示例来源:origin: uber/marmaray

/**
 * Creates {@link SparkConf} with {@link org.apache.spark.serializer.KryoSerializer} along with
 * registering default/user-input serializable classes and user-input Avro Schemas.
 * Once {@link SparkContext} is created, we can no longer register serialization classes and Avro schemas.
 */
public SparkConf createSparkConf(@NonNull final SparkArgs sparkArgs) {
  /**
   * By custom registering classes the full class name of each object
   * is not stored during serialization which reduces storage space.
   */
  final SparkConf sparkConf = new SparkConf();
  sparkConf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer");
  final List<Class> serializableClasses = getDefaultSerializableClasses();
  serializableClasses.addAll(sparkArgs.getUserSerializationClasses());
  sparkConf.registerKryoClasses(serializableClasses.toArray(new Class[0]));
  if (sparkArgs.getAvroSchemas().isPresent()) {
    sparkConf.registerAvroSchemas(
      JavaConverters
        .iterableAsScalaIterableConverter(sparkArgs.getAvroSchemas().get())
        .asScala()
        .toSeq());
  }
  // override spark properties
  final Map<String, String> sparkProps = sparkArgs.getOverrideSparkProperties();
  for (Entry<String, String> entry : sparkProps.entrySet()) {
    log.info("Setting spark key:val {} : {}", entry.getKey(), entry.getValue());
    sparkConf.set(entry.getKey(), entry.getValue());
  }
  return sparkConf;
}

代码示例来源:origin: uber/marmaray

JavaConverters.iterableAsScalaIterableConverter(avroSchemas.get())
.asScala()
.toSeq());

相关文章