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

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

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

Optional.of介绍

暂无

代码示例

代码示例来源：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

@Test(expected = NullPointerException.class)
public void testOfWithNull() {
 Optional.of(null);
}

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

@Test(expected = NullPointerException.class)
public void testOfWithNull() {
 Optional.of(null);
}

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

@Test(expected = NullPointerException.class)
public void testOfWithNull() {
 Optional.of(null);
}

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

@Test
public void testOf() {
 Assert.assertTrue(Optional.of(1).isPresent());
 Assert.assertNotNull(Optional.of(1).orNull());
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).get());
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).or(2));
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).orElse(2));
}

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

@Test
public void testOf() {
 Assert.assertTrue(Optional.of(1).isPresent());
 Assert.assertNotNull(Optional.of(1).orNull());
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).get());
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).or(2));
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).orElse(2));
}

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

@Test
public void testOf() {
 Assert.assertTrue(Optional.of(1).isPresent());
 Assert.assertNotNull(Optional.of(1).orNull());
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).get());
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).or(2));
 Assert.assertEquals(Integer.valueOf(1), Optional.of(1).orElse(2));
}

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

public RDDWrapper(@NonNull final JavaRDD<T> data, final long count) {
  this.data = data;
  this.count = Optional.of(count);
}

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

private void emitCartesianProduct(Tuple2<BatchJoinKey<K>, Either<L, R>> right) {
 leftQueue.forEach(
   left ->
     outQueue.add(
       new Tuple2<>(
         left._1.getKey(),
         new Tuple2<>(Optional.of(left._2.left()), Optional.of(right._2.right())))));
}

代码示例来源：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

private Tuple2<String, Tuple2<Optional<String>, Optional<String>>> entry(
  String key, String leftSide, String rightSide) {
 return new Tuple2<>(key, new Tuple2<>(Optional.of(leftSide), Optional.of(rightSide)));
}

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

private Tuple2<String, Tuple2<Optional<String>, Optional<String>>> entry(
   String key, Optional<String> leftSide, String rightSide) {
  return new Tuple2<>(key, new Tuple2<>(leftSide, Optional.of(rightSide)));
 }
}

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

private Tuple2<String, Tuple2<Optional<String>, Optional<String>>> entry(
  String key, String leftSide, Optional<String> rightSide) {
 return new Tuple2<>(key, new Tuple2<>(Optional.of(leftSide), rightSide));
}

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

public long getCount() {
    if (!count.isPresent()) {
      this.count = Optional.of(this.data.count());
    }
    return count.get();
  }
}

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

@SuppressWarnings("unchecked")
@Test
public void testUpdateStateByKey() {
 List<List<Tuple2<String, Integer>>> inputData = stringIntKVStream;
 List<List<Tuple2<String, Integer>>> expected = Arrays.asList(
   Arrays.asList(new Tuple2<>("california", 4),
          new Tuple2<>("new york", 5)),
   Arrays.asList(new Tuple2<>("california", 14),
          new Tuple2<>("new york", 9)),
   Arrays.asList(new Tuple2<>("california", 14),
          new Tuple2<>("new york", 9)));
 JavaDStream<Tuple2<String, Integer>> stream =
  JavaTestUtils.attachTestInputStream(ssc, inputData, 1);
 JavaPairDStream<String, Integer> pairStream = JavaPairDStream.fromJavaDStream(stream);
 JavaPairDStream<String, Integer> updated = pairStream.updateStateByKey((values, state) -> {
   int out = 0;
   if (state.isPresent()) {
    out += state.get();
   }
   for (Integer v : values) {
    out += v;
   }
   return Optional.of(out);
  });
 JavaTestUtils.attachTestOutputStream(updated);
 List<List<Tuple2<String, Integer>>> result = JavaTestUtils.runStreams(ssc, 3, 3);
 Assert.assertEquals(expected, result);
}

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

@Test
public void testUpdateStateByKey() {
 List<List<Tuple2<String, Integer>>> inputData = stringIntKVStream;
 List<List<Tuple2<String, Integer>>> expected = Arrays.asList(
  Arrays.asList(new Tuple2<>("california", 4),
   new Tuple2<>("new york", 5)),
  Arrays.asList(new Tuple2<>("california", 14),
   new Tuple2<>("new york", 9)),
  Arrays.asList(new Tuple2<>("california", 14),
   new Tuple2<>("new york", 9)));
 JavaDStream<Tuple2<String, Integer>> stream =
  JavaTestUtils.attachTestInputStream(ssc, inputData, 1);
 JavaPairDStream<String, Integer> pairStream = JavaPairDStream.fromJavaDStream(stream);
 JavaPairDStream<String, Integer> updated = pairStream.updateStateByKey((values, state) -> {
  int out = 0;
  if (state.isPresent()) {
   out = out + state.get();
  }
  for (Integer v : values) {
   out = out + v;
  }
  return Optional.of(out);
 });
 JavaTestUtils.attachTestOutputStream(updated);
 List<List<Tuple2<String, Integer>>> result = JavaTestUtils.runStreams(ssc, 3, 3);
 Assert.assertEquals(expected, result);
}

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

@Test
public void testUpdateStateByKey() {
 List<List<Tuple2<String, Integer>>> inputData = stringIntKVStream;
 List<List<Tuple2<String, Integer>>> expected = Arrays.asList(
  Arrays.asList(new Tuple2<>("california", 4),
   new Tuple2<>("new york", 5)),
  Arrays.asList(new Tuple2<>("california", 14),
   new Tuple2<>("new york", 9)),
  Arrays.asList(new Tuple2<>("california", 14),
   new Tuple2<>("new york", 9)));
 JavaDStream<Tuple2<String, Integer>> stream =
  JavaTestUtils.attachTestInputStream(ssc, inputData, 1);
 JavaPairDStream<String, Integer> pairStream = JavaPairDStream.fromJavaDStream(stream);
 JavaPairDStream<String, Integer> updated = pairStream.updateStateByKey((values, state) -> {
  int out = 0;
  if (state.isPresent()) {
   out = out + state.get();
  }
  for (Integer v : values) {
   out = out + v;
  }
  return Optional.of(out);
 });
 JavaTestUtils.attachTestOutputStream(updated);
 List<List<Tuple2<String, Integer>>> result = JavaTestUtils.runStreams(ssc, 3, 3);
 Assert.assertEquals(expected, result);
}

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

@SuppressWarnings("unchecked")
@Test
public void testUpdateStateByKey() {
 List<List<Tuple2<String, Integer>>> inputData = stringIntKVStream;
 List<List<Tuple2<String, Integer>>> expected = Arrays.asList(
   Arrays.asList(new Tuple2<>("california", 4),
          new Tuple2<>("new york", 5)),
   Arrays.asList(new Tuple2<>("california", 14),
          new Tuple2<>("new york", 9)),
   Arrays.asList(new Tuple2<>("california", 14),
          new Tuple2<>("new york", 9)));
 JavaDStream<Tuple2<String, Integer>> stream =
  JavaTestUtils.attachTestInputStream(ssc, inputData, 1);
 JavaPairDStream<String, Integer> pairStream = JavaPairDStream.fromJavaDStream(stream);
 JavaPairDStream<String, Integer> updated = pairStream.updateStateByKey((values, state) -> {
   int out = 0;
   if (state.isPresent()) {
    out += state.get();
   }
   for (Integer v : values) {
    out += v;
   }
   return Optional.of(out);
  });
 JavaTestUtils.attachTestOutputStream(updated);
 List<List<Tuple2<String, Integer>>> result = JavaTestUtils.runStreams(ssc, 3, 3);
 Assert.assertEquals(expected, result);
}

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

Optional

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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