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

Flow.add介绍

[英]Adds a new operator to the flow.
[中]将新操作符添加到流中。

代码示例

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

@SuppressWarnings("unchecked")
public Dataset<OUT> output() {
 Flow flow = input.getFlow();
 ReduceWindow<T, VALUE, OUT, ?> operator = new ReduceWindow<>(
   name, flow, input, valueExtractor,
     (Windowing) windowing, reducer, valueComparator);
 flow.add(operator);
 return operator.output();
}

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

@Override
 public Dataset<IN> output(OutputHint... outputHints) {
  final Flow flow = dataSets.get(0).getFlow();
  final Union<IN> union = new Union<>(name, flow, dataSets, Sets.newHashSet(outputHints));
  flow.add(union);
  return union.output();
 }
}

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

@Override
 public Dataset<IN> output(OutputHint... outputHints) {
  final Flow flow = dataSets.get(0).getFlow();
  final Union<IN> union = new Union<>(name, flow, dataSets, Sets.newHashSet(outputHints));
  flow.add(union);
  return union.output();
 }
}

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

@SuppressWarnings("unchecked")
public Dataset<OUT> output() {
 Flow flow = input.getFlow();
 ReduceWindow<T, VALUE, OUT, ?> operator = new ReduceWindow<>(
   name, flow, input, valueExtractor,
     (Windowing) windowing, reducer, valueComparator);
 flow.add(operator);
 return operator.output();
}

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

@Override
 public Dataset<Pair<KEY, Long>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  SumByKey<IN, KEY, W> sumByKey =
    new SumByKey<>(
      name, flow, input, keyExtractor, valueExtractor,
      windowing, Sets.newHashSet(outputHints));
  flow.add(sumByKey);
  return sumByKey.output();
 }
}

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

@Override
 public Dataset<OUT> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  FlatMap<IN, OUT> map = new FlatMap<>(name, flow, input, functor, evtTimeFn,
    Sets.newHashSet(outputHints));
  flow.add(map);
  return map.output();
 }
}

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

@Override
public Dataset<IN> output(OutputHint... outputHints) {
 Flow flow = input.getFlow();
 Filter<IN> filter = new Filter<>(name, flow, input, predicate, Sets.newHashSet(outputHints));
 flow.add(filter);
 return filter.output();
}

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

@Override
 public Dataset<Pair<KEY, Long>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  SumByKey<IN, KEY, W> sumByKey =
    new SumByKey<>(
      name, flow, input, keyExtractor, valueExtractor,
      windowing, Sets.newHashSet(outputHints));
  flow.add(sumByKey);
  return sumByKey.output();
 }
}

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

@Override
 public Dataset<ELEM> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  Distinct<IN, ELEM, W> distinct = new Distinct<>(
    name, flow, input, mapper, windowing, Sets.newHashSet(outputHints));
  flow.add(distinct);
  return distinct.output();
 }
}

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

@Override
 public Dataset<Pair<KEY, OUT>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  ReduceStateByKey<IN, KEY, VALUE, OUT, STATE, W>
    reduceStateByKey =
    new ReduceStateByKey<>(name, flow, input, keyExtractor, valueExtractor,
      windowing, stateFactory, stateMerger, Sets.newHashSet(outputHints));
  flow.add(reduceStateByKey);
  return reduceStateByKey.output();
 }
}

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

@Override
 public Dataset<Pair<KEY, OUT>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  ReduceStateByKey<IN, KEY, VALUE, OUT, STATE, W>
    reduceStateByKey =
    new ReduceStateByKey<>(name, flow, input, keyExtractor, valueExtractor,
      windowing, stateFactory, stateMerger, Sets.newHashSet(outputHints));
  flow.add(reduceStateByKey);
  return reduceStateByKey.output();
 }
}

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

@Override
 public Dataset<OUT> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  FlatMap<IN, OUT> map = new FlatMap<>(name, flow, input, functor, evtTimeFn,
    Sets.newHashSet(outputHints));
  flow.add(map);
  return map.output();
 }
}

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

@Override
 public Dataset<Triple<K, V, S>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  TopPerKey<IN, K, V, S, W> top =
    new TopPerKey<>(flow, name, input, keyFn, valueFn,
      scoreFn, windowing, Sets.newHashSet(outputHints));
  flow.add(top);
  return top.output();
 }
}

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

@Override
 public Dataset<Pair<KEY, Long>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  CountByKey<IN, KEY, W> count = new CountByKey<>(
    name, flow, input, keyExtractor, windowing, Sets.newHashSet(outputHints));
  flow.add(count);
  return count.output();
 }
}

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

@Override
 public Dataset<OUT> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  MapElements<IN, OUT> map = new MapElements<>(name, flow, input, mapper, Sets.newHashSet(outputHints));
  flow.add(map);
  return map.output();
 }
}

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

@Override
 public Dataset<ELEM> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  Distinct<IN, ELEM, W> distinct = new Distinct<>(
    name, flow, input, mapper, windowing, Sets.newHashSet(outputHints));
  flow.add(distinct);
  return distinct.output();
 }
}

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

@Override
 public Dataset<IN> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  AssignEventTime<IN> op = new AssignEventTime<>(name, flow, input, eventTimeFn,
    Sets.newHashSet(outputHints));
  flow.add(op);
  return op.output();
 }
}

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

@Override
 public Dataset<Pair<KEY, Long>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  CountByKey<IN, KEY, W> count = new CountByKey<>(
    name, flow, input, keyExtractor, windowing, Sets.newHashSet(outputHints));
  flow.add(count);
  return count.output();
 }
}

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

@Override
 public Dataset<Triple<K, V, S>> output(OutputHint... outputHints) {
  Flow flow = input.getFlow();
  TopPerKey<IN, K, V, S, W> top =
    new TopPerKey<>(flow, name, input, keyFn, valueFn,
      scoreFn, windowing, Sets.newHashSet(outputHints));
  flow.add(top);
  return top.output();
 }
}

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

@Override
public Dataset<IN> output(OutputHint... outputHints) {
 Flow flow = input.getFlow();
 Filter<IN> filter = new Filter<>(name, flow, input, predicate, Sets.newHashSet(outputHints));
 flow.add(filter);
 return filter.output();
}