org.apache.flink.types.Either.Right()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(10.3k)|赞(0)|评价(0)|浏览(140)

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

Either.Right介绍

[英]Create a Right value of Either
[中]创建一个正确的值

代码示例

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

@Override
public Either<L, R> map1(R value) {
  return Either.Right(value);
}

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

/**
 * Sends the given message to the vertex identified by the given key. If the target vertex does not exist,
 * the next superstep will cause an exception due to a non-deliverable message.
 *
 * @param target The key (id) of the target vertex to message.
 * @param m The message.
 */
public final void sendMessageTo(K target, Message m) {
  outMsg.f0 = target;
  outMsg.f1 = m;
  out.collect(Either.Right(outMsg));
}

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

/**
   * Sends the combined message to the target vertex.
   *
   * @param combinedMessage
   * @throws Exception
   */
  public final void sendCombinedMessage(Message combinedMessage) {
    outValue.f1 = Either.Right(combinedMessage);
    out.collect(outValue);
  }
}

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

@Override
public Either<L, R> createInstance() {
  // We arbitrarily always create a Right value instance.
  return Right(rightSerializer.createInstance());
}

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

/**
 * Sends the given message to all vertices that adjacent to the changed vertex.
 * This method is mutually exclusive to the method {@link #getEdges()} and may be called only once.
 *
 * @param m The message to send.
 */
public final void sendMessageToAllNeighbors(Message m) {
  verifyEdgeUsage();
  outMsg.f1 = m;
  while (edges.hasNext()) {
    Tuple next = edges.next();
    outMsg.f0 = next.getField(1);
    out.collect(Either.Right(outMsg));
  }
}

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

public void flatMap(Either<Vertex<K, VV>, Tuple2<K, Message>> value,
      Collector<Tuple2<K, Either<NullValue, Message>>> out) {
    if (value.isRight()) {
      Tuple2<K, Message> message = value.right();
      outTuple.f0 = message.f0;
      outTuple.f1 = Either.Right(message.f1);
      out.collect(outTuple);
    }
  }
}

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

@Override
public Either<L, R> deserialize(DataInputView source) throws IOException {
  boolean isLeft = source.readBoolean();
  if (isLeft) {
    return Left(leftSerializer.deserialize(source));
  }
  else {
    return Right(rightSerializer.deserialize(source));
  }
}

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

@Override
public Either<L, R> copy(Either<L, R> from) {
  if (from.isLeft()) {
    L left = from.left();
    L copyLeft = leftSerializer.copy(left);
    return Left(copyLeft);
  }
  else {
    R right = from.right();
    R copyRight = rightSerializer.copy(right);
    return Right(copyRight);
  }
}

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

@SuppressWarnings("unchecked")
@Test
public void testStringDoubleEither() {
Either<String, Double>[] testData = new Either[] {
    Left("banana"),
    Left(""),
    Right(32.0),
    Right(Double.MIN_VALUE),
    Right(Double.MAX_VALUE)};
EitherTypeInfo<String, Double> eitherTypeInfo = (EitherTypeInfo<String, Double>) new EitherTypeInfo<String, Double>(
    BasicTypeInfo.STRING_TYPE_INFO, BasicTypeInfo.DOUBLE_TYPE_INFO);
EitherSerializer<String, Double> eitherSerializer =
    (EitherSerializer<String, Double>) eitherTypeInfo.createSerializer(new ExecutionConfig());
SerializerTestInstance<Either<String, Double>> testInstance =
    new EitherSerializerTestInstance<Either<String, Double>>(eitherSerializer, eitherTypeInfo.getTypeClass(), -1, testData);
testInstance.testAll();
}

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

@SuppressWarnings("unchecked")
@Test
public void testEitherWithTuple() {
Either<Tuple2<Long, Long>, Double>[] testData = new Either[] {
    Either.Left(new Tuple2<>(2L, 9L)),
    new Left<>(new Tuple2<>(Long.MIN_VALUE, Long.MAX_VALUE)),
    new Right<>(32.0),
    Right(Double.MIN_VALUE),
    Right(Double.MAX_VALUE)};
EitherTypeInfo<Tuple2<Long, Long>, Double> eitherTypeInfo = (EitherTypeInfo<Tuple2<Long, Long>, Double>)
    new EitherTypeInfo<Tuple2<Long, Long>, Double>(
    new TupleTypeInfo<Tuple2<Long, Long>>(BasicTypeInfo.LONG_TYPE_INFO, BasicTypeInfo.LONG_TYPE_INFO),
    BasicTypeInfo.DOUBLE_TYPE_INFO);
EitherSerializer<Tuple2<Long, Long>, Double> eitherSerializer =
    (EitherSerializer<Tuple2<Long, Long>, Double>) eitherTypeInfo.createSerializer(new ExecutionConfig());
SerializerTestInstance<Either<Tuple2<Long, Long>, Double>> testInstance =
    new EitherSerializerTestInstance<Either<Tuple2<Long, Long>, Double>>(
        eitherSerializer, eitherTypeInfo.getTypeClass(), -1, testData);
testInstance.testAll();
}

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

@Test
public void testEitherWithTupleValues() {
  @SuppressWarnings("unchecked")
  Either<Tuple2<LongValue, LongValue>, DoubleValue>[] testData = new Either[] {
    Left(new Tuple2<>(new LongValue(2L), new LongValue(9L))),
    new Left<>(new Tuple2<>(new LongValue(Long.MIN_VALUE), new LongValue(Long.MAX_VALUE))),
    new Right<>(new DoubleValue(32.0)),
    Right(new DoubleValue(Double.MIN_VALUE)),
    Right(new DoubleValue(Double.MAX_VALUE))};
  EitherTypeInfo<Tuple2<LongValue, LongValue>, DoubleValue> eitherTypeInfo = new EitherTypeInfo<>(
    new TupleTypeInfo<Tuple2<LongValue, LongValue>>(ValueTypeInfo.LONG_VALUE_TYPE_INFO, ValueTypeInfo.LONG_VALUE_TYPE_INFO),
    ValueTypeInfo.DOUBLE_VALUE_TYPE_INFO);
  EitherSerializer<Tuple2<LongValue, LongValue>, DoubleValue> eitherSerializer =
    (EitherSerializer<Tuple2<LongValue, LongValue>, DoubleValue>) eitherTypeInfo.createSerializer(new ExecutionConfig());
  SerializerTestInstance<Either<Tuple2<LongValue, LongValue>, DoubleValue>> testInstance =
    new EitherSerializerTestInstance<>(eitherSerializer, eitherTypeInfo.getTypeClass(), -1, testData);
  testInstance.testAll();
}

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

@Test
public void testEitherWithObjectReuse() {
  EitherTypeInfo<LongValue, DoubleValue> eitherTypeInfo = new EitherTypeInfo<>(
    ValueTypeInfo.LONG_VALUE_TYPE_INFO, ValueTypeInfo.DOUBLE_VALUE_TYPE_INFO);
  EitherSerializer<LongValue, DoubleValue> eitherSerializer =
    (EitherSerializer<LongValue, DoubleValue>) eitherTypeInfo.createSerializer(new ExecutionConfig());
  LongValue lv = new LongValue();
  DoubleValue dv = new DoubleValue();
  Either<LongValue, DoubleValue> left = Left(lv);
  Either<LongValue, DoubleValue> right = Right(dv);
  // the first copy creates a new instance of Left
  Either<LongValue, DoubleValue> copy0 = eitherSerializer.copy(left, right);
  // then the cross-references are used for future copies
  Either<LongValue, DoubleValue> copy1 = eitherSerializer.copy(right, copy0);
  Either<LongValue, DoubleValue> copy2 = eitherSerializer.copy(left, copy1);
  // validate reference equality
  assertSame(right, copy1);
  assertSame(copy0, copy2);
  // validate reference equality of contained objects
  assertSame(right.right(), copy1.right());
  assertSame(copy0.left(), copy2.left());
}

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

@Test
public void testStringValueDoubleValueEither() {
  @SuppressWarnings("unchecked")
  Either<StringValue, DoubleValue>[] testData = new Either[] {
    Left(new StringValue("banana")),
    Left.of(new StringValue("apple")),
    new Left(new StringValue("")),
    Right(new DoubleValue(32.0)),
    Right.of(new DoubleValue(Double.MIN_VALUE)),
    new Right(new DoubleValue(Double.MAX_VALUE))};
  EitherTypeInfo<StringValue, DoubleValue> eitherTypeInfo = new EitherTypeInfo<>(
    ValueTypeInfo.STRING_VALUE_TYPE_INFO, ValueTypeInfo.DOUBLE_VALUE_TYPE_INFO);
  EitherSerializer<StringValue, DoubleValue> eitherSerializer =
    (EitherSerializer<StringValue, DoubleValue>) eitherTypeInfo.createSerializer(new ExecutionConfig());
  SerializerTestInstance<Either<StringValue, DoubleValue>> testInstance =
    new EitherSerializerTestInstance<>(eitherSerializer, eitherTypeInfo.getTypeClass(), -1, testData);
  testInstance.testAll();
}

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

@Test
public void testSerializeIndividually() throws IOException {
  EitherTypeInfo<LongValue, DoubleValue> eitherTypeInfo = new EitherTypeInfo<>(
    ValueTypeInfo.LONG_VALUE_TYPE_INFO, ValueTypeInfo.DOUBLE_VALUE_TYPE_INFO);
  EitherSerializer<LongValue, DoubleValue> eitherSerializer =
    (EitherSerializer<LongValue, DoubleValue>) eitherTypeInfo.createSerializer(new ExecutionConfig());
  LongValue lv = new LongValue();
  DoubleValue dv = new DoubleValue();
  Either<LongValue, DoubleValue> left = Left(lv);
  Either<LongValue, DoubleValue> right = Right(dv);
  TestOutputView out = new TestOutputView();
  eitherSerializer.serialize(left, out);
  eitherSerializer.serialize(right, out);
  eitherSerializer.serialize(left, out);
  TestInputView in = out.getInputView();
  // the first deserialization creates a new instance of Left
  Either<LongValue, DoubleValue> copy0 = eitherSerializer.deserialize(right, in);
  // then the cross-references are used for future copies
  Either<LongValue, DoubleValue> copy1 = eitherSerializer.deserialize(copy0, in);
  Either<LongValue, DoubleValue> copy2 = eitherSerializer.deserialize(copy1, in);
  // validate reference equality
  assertSame(right, copy1);
  assertSame(copy0, copy2);
  // validate reference equality of contained objects
  assertSame(right.right(), copy1.right());
  assertSame(copy0.left(), copy2.left());
}

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

/**
 * Sends the given message to the vertex identified by the given key. If the target vertex does not exist,
 * the next superstep will cause an exception due to a non-deliverable message.
 * 
 * @param target The key (id) of the target vertex to message.
 * @param m The message.
 */
public final void sendMessageTo(K target, Message m) {
  outMsg.f0 = target;
  outMsg.f1 = m;
  out.collect(Either.Right(outMsg));
}

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

@Override
public Either<L, R> createInstance() {
  // We arbitrarily always create a Right value instance.
  return Right(rightSerializer.createInstance());
}

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

/**
   * Sends the combined message to the target vertex.
   * 
   * @param combinedMessage
   * @throws Exception
   */
  public final void sendCombinedMessage(Message combinedMessage) {
    outValue.f1 = Either.Right(combinedMessage);
    out.collect(outValue);
  }
}

代码示例来源：origin: com.alibaba.blink/flink-core

@Override
public Either<L, R> createInstance() {
  // We arbitrarily always create a Right value instance.
  return Right(rightSerializer.createInstance());
}

代码示例来源：origin: com.alibaba.blink/flink-core

@Override
public Either<L, R> deserialize(DataInputView source) throws IOException {
  boolean isLeft = source.readBoolean();
  if (isLeft) {
    return Left(leftSerializer.deserialize(source));
  }
  else {
    return Right(rightSerializer.deserialize(source));
  }
}

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

@Override
public Either<L, R> deserialize(DataInputView source) throws IOException {
  boolean isLeft = source.readBoolean();
  if (isLeft) {
    return Left(leftSerializer.deserialize(source));
  }
  else {
    return Right(rightSerializer.deserialize(source));
  }
}

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

Either

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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