cz.seznam.euphoria.core.client.operator.Union.createOutput()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(1.3k)|赞(0)|评价(0)|浏览(144)

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

Union.createOutput介绍

暂无

代码示例

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

@SuppressWarnings("unchecked")
Union(String name, Flow flow, List<Dataset<IN>> dataSets, Set<OutputHint> outputHints) {
 super(name, flow);
 Preconditions.checkArgument(
   dataSets.size() > 1,
   "Union needs at least two data sets.");
 Preconditions.checkArgument(
   dataSets.stream().map(Dataset::getFlow).distinct().count() == 1,
   "Only data sets from the same flow can be passed to Union.");
 this.dataSets = dataSets;
 this.output = createOutput(dataSets.get(0), outputHints);
}

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

@SuppressWarnings("unchecked")
Union(String name, Flow flow, List<Dataset<IN>> dataSets, Set<OutputHint> outputHints) {
 super(name, flow);
 Preconditions.checkArgument(
   dataSets.size() > 1,
   "Union needs at least two data sets.");
 Preconditions.checkArgument(
   dataSets.stream().map(Dataset::getFlow).distinct().count() == 1,
   "Only data sets from the same flow can be passed to Union.");
 this.dataSets = dataSets;
 this.output = createOutput(dataSets.get(0), outputHints);
}

相关文章