org.apache.spark.api.java.Optional.empty()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(105)

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

Optional.empty介绍

暂无

代码示例

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

/**
 * @return an empty {@code Optional}
 */
public static <T> Optional<T> absent() {
 return empty();
}

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

/**
 * @return an empty {@code Optional}
 */
public static <T> Optional<T> absent() {
 return empty();
}

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

/**
 * @return an empty {@code Optional}
 */
public static <T> Optional<T> absent() {
 return empty();
}

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

/**
 * @param value value to wrap, which may be null
 * @return {@code Optional} wrapping this value, which may be empty
 */
public static <T> Optional<T> ofNullable(T value) {
 if (value == null) {
  return empty();
 } else {
  return of(value);
 }
}

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

/**
 * @param value value to wrap, which may be null
 * @return {@code Optional} wrapping this value, which may be empty
 */
public static <T> Optional<T> ofNullable(T value) {
 if (value == null) {
  return empty();
 } else {
  return of(value);
 }
}

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

/**
 * @param value value to wrap, which may be null
 * @return {@code Optional} wrapping this value, which may be empty
 */
public static <T> Optional<T> ofNullable(T value) {
 if (value == null) {
  return empty();
 } else {
  return of(value);
 }
}

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

@Test(expected = NullPointerException.class)
public void testEmptyGet() {
 Optional.empty().get();
}

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

@Test(expected = NullPointerException.class)
public void testEmptyGet() {
 Optional.empty().get();
}

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

@Test
public void testEmpty() {
 Assert.assertFalse(Optional.empty().isPresent());
 Assert.assertNull(Optional.empty().orNull());
 Assert.assertEquals("foo", Optional.empty().or("foo"));
 Assert.assertEquals("foo", Optional.empty().orElse("foo"));
}

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

@Test(expected = NullPointerException.class)
public void testEmptyGet() {
 Optional.empty().get();
}

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

@Test
public void testEmpty() {
 Assert.assertFalse(Optional.empty().isPresent());
 Assert.assertNull(Optional.empty().orNull());
 Assert.assertEquals("foo", Optional.empty().or("foo"));
 Assert.assertEquals("foo", Optional.empty().orElse("foo"));
}

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

@Test
public void testEmpty() {
 Assert.assertFalse(Optional.empty().isPresent());
 Assert.assertNull(Optional.empty().orNull());
 Assert.assertEquals("foo", Optional.empty().or("foo"));
 Assert.assertEquals("foo", Optional.empty().orElse("foo"));
}

代码示例来源：origin: seznam/euphoria

private void emitLeft() {
 leftQueue.forEach(
   left ->
     outQueue.add(
       new Tuple2<>(
         left._1.getKey(),
         new Tuple2<>(Optional.of(left._2.left()), Optional.empty()))));
 leftQueue.clear();
}

代码示例来源：origin: seznam/euphoria

sjk.getKey(), new Tuple2<>(Optional.empty(), Optional.of(tuple._2.right()))));

代码示例来源：origin: seznam/euphoria

@Test
public void emitsARightLonerWhenARightSideWithADifferentKeyComes() {
 final Iterator<Tuple2<BatchJoinKey<String>, Either<String, String>>> inner =
   asList(
       entry("key1", LEFT, Either.left("v1")),
       entry("key1", RIGHT, Either.right("w1")),
       // ~ a right side with a different key
       entry("key3", RIGHT, Either.right("w1")))
     .iterator();
 final List<Tuple2<String, Tuple2<Optional<String>, Optional<String>>>> results =
   Lists.newArrayList(new BatchJoinIterator<>(inner));
 assertEquals(asList(entry("key1", "v1", "w1"), entry("key3", Optional.empty(), "w1")), results);
}

代码示例来源：origin: seznam/euphoria

@Test
public void emitsALeftLonerAndARightLonerWhenARightSideWithADifferentKeyComes() {
 final Iterator<Tuple2<BatchJoinKey<String>, Either<String, String>>> inner =
   asList(
       entry("key1", LEFT, Either.left("v1")),
       entry("key1", RIGHT, Either.right("w1")),
       // ~ a left side with no right sides
       entry("key2", LEFT, Either.left("v1")),
       // ~ a right side with a different key
       entry("key3", RIGHT, Either.right("w1")))
     .iterator();
 final List<Tuple2<String, Tuple2<Optional<String>, Optional<String>>>> results =
   Lists.newArrayList(new BatchJoinIterator<>(inner));
 assertEquals(
   asList(
     entry("key1", "v1", "w1"),
     entry("key3", Optional.empty(), "w1"),
     entry("key2", "v1", Optional.empty())),
   results);
}

代码示例来源：origin: seznam/euphoria

@Test
public void lonerRightSideInTheEnd() {
 final Iterator<Tuple2<BatchJoinKey<String>, Either<String, String>>> inner =
   asList(
       entry("key1", LEFT, Either.left("v1")),
       entry("key1", RIGHT, Either.right("w1")),
       entry("key1", RIGHT, Either.right("w2")),
       entry("key2", RIGHT, Either.right("w1")))
     .iterator();
 final List<Tuple2<String, Tuple2<Optional<String>, Optional<String>>>> results =
   Lists.newArrayList(new BatchJoinIterator<>(inner));
 assertEquals(
   asList(
     entry("key1", "v1", "w1"),
     entry("key1", "v1", "w2"),
     entry("key2", Optional.empty(), "w1")),
   results);
}

代码示例来源：origin: seznam/euphoria

@Test
public void lonerLeftSideInTheEnd() {
 final Iterator<Tuple2<BatchJoinKey<String>, Either<String, String>>> inner =
   asList(
       entry("key1", LEFT, Either.left("v1")),
       entry("key1", RIGHT, Either.right("w1")),
       entry("key1", RIGHT, Either.right("w2")),
       entry("key2", LEFT, Either.left("v1")))
     .iterator();
 final List<Tuple2<String, Tuple2<Optional<String>, Optional<String>>>> results =
   Lists.newArrayList(new BatchJoinIterator<>(inner));
 assertEquals(
   asList(
     entry("key1", "v1", "w1"),
     entry("key1", "v1", "w2"),
     entry("key2", "v1", Optional.empty())),
   results);
}

代码示例来源：origin: seznam/euphoria

@Test
public void emitsALeftLonerWhenAConsecutiveSecondLeftSideComes() {
 final Iterator<Tuple2<BatchJoinKey<String>, Either<String, String>>> inner =
   asList(
       entry("key1", LEFT, Either.left("v1")),
       entry("key1", RIGHT, Either.right("w1")),
       // ~ a left side with no right sides
       entry("key2", LEFT, Either.left("v1")),
       // ~ a consecutive second left side
       entry("key3", LEFT, Either.left("v1")),
       entry("key3", RIGHT, Either.right("w1")))
     .iterator();
 final List<Tuple2<String, Tuple2<Optional<String>, Optional<String>>>> results =
   Lists.newArrayList(new BatchJoinIterator<>(inner));
 assertEquals(
   asList(
     entry("key1", "v1", "w1"),
     entry("key2", "v1", Optional.empty()),
     entry("key3", "v1", "w1")),
   results);
}

代码示例来源：origin: seznam/euphoria

@Test
public void emitsARightLonerWhenAConsecutiveSecondLeftSideComes() {
 final Iterator<Tuple2<BatchJoinKey<String>, Either<String, String>>> inner =
   asList(
       entry("key1", LEFT, Either.left("v1")),
       entry("key1", RIGHT, Either.right("w1")),
       // ~ a left side with no right sides
       entry("key2", RIGHT, Either.right("w1")),
       // ~ a consecutive second left side
       entry("key3", LEFT, Either.left("v1")),
       entry("key3", RIGHT, Either.right("w1")))
     .iterator();
 final List<Tuple2<String, Tuple2<Optional<String>, Optional<String>>>> results =
   Lists.newArrayList(new BatchJoinIterator<>(inner));
 assertEquals(
   asList(
     entry("key1", "v1", "w1"),
     entry("key2", Optional.empty(), "w1"),
     entry("key3", "v1", "w1")),
   results);
}

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

Optional

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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