本文整理了Java中scala.collection.JavaConverters.iterableAsScalaIterableConverter()
方法的一些代码示例,展示了JavaConverters.iterableAsScalaIterableConverter()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JavaConverters.iterableAsScalaIterableConverter()
方法的具体详情如下:
包路径:scala.collection.JavaConverters
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!