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

ZipWithIdOperator介绍

[英]This operators attaches a unique ID to each input data quantum.
[中]该操作符为每个输入数据量附加一个唯一的ID。

代码示例

代码示例来源：origin: org.qcri.rheem/rheem-java

private SubplanPattern createSubplanPattern() {
  final OperatorPattern operatorPattern = new OperatorPattern(
      "zipwithid", new ZipWithIdOperator<>(DataSetType.none()), false);
  return SubplanPattern.createSingleton(operatorPattern);
}

代码示例来源：origin: org.qcri.rheem/rheem-basic

@Override
  public Optional<CardinalityEstimator> createCardinalityEstimator(
      final int outputIndex,
      final Configuration configuration) {
    Validate.inclusiveBetween(0, this.getNumOutputs() - 1, outputIndex);
    return Optional.of(new DefaultCardinalityEstimator(
        1d, 1, this.isSupportingBroadcastInputs(),
        inputCards -> inputCards[0]
    ));
  }
}

代码示例来源：origin: org.qcri.rheem/rheem-java

private ReplacementSubplanFactory createReplacementSubplanFactory() {
  return new ReplacementSubplanFactory.OfSingleOperators<ZipWithIdOperator<Object>>(
      (matchedOperator, epoch) -> {
        final DataSetType<Object> inputType = matchedOperator.getInputType();
        final DataSetType<Tuple2<Long, Object>> outputType = matchedOperator.getOutputType();
        return new JavaMapOperator<>(
            inputType,

代码示例来源：origin: org.qcri.rheem/rheem-spark

private SubplanPattern createSubplanPattern() {
  final OperatorPattern operatorPattern =
      new OperatorPattern<>("zipwithid", new ZipWithIdOperator<>(DataSetType.none()), false);
  return SubplanPattern.createSingleton(operatorPattern);
}