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

FlatMap.<init>介绍

暂无

代码示例

代码示例来源：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<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 DAG<Operator<?, ?>> getBasicOps() {
 return DAG.of(new FlatMap<>(
   getName(), getFlow(), input,
   (i, c) -> c.collect(i), eventTimeFn, getHints()));
}

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

@Override
public DAG<Operator<?, ?>> getBasicOps() {
 return DAG.of(new FlatMap<>(
   getName(), getFlow(), input,
   (i, c) -> c.collect(i), eventTimeFn, getHints()));
}

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

/** This operator can be implemented using FlatMap. */
 @Override
 public DAG<Operator<?, ?>> getBasicOps() {
  return DAG.of(new FlatMap<>(getName(), getFlow(), input,
    (elem, collector) -> {
     if (predicate.apply(elem)) {
      collector.collect(elem);
     }
    },
    null,
    getHints()));
 }
}

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

/** This operator can be implemented using FlatMap. */
 @Override
 public DAG<Operator<?, ?>> getBasicOps() {
  return DAG.of(new FlatMap<>(getName(), getFlow(), input,
    (elem, collector) -> {
     if (predicate.apply(elem)) {
      collector.collect(elem);
     }
    },
    null,
    getHints()));
 }
}

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

/**
 * This is not a basic operator. It can be straightforwardly implemented
 * by using {@code FlatMap} operator.
 * @return the operator chain representing this operation including FlatMap
 */
@Override
public DAG<Operator<?, ?>> getBasicOps() {
 return DAG.of(
   // do not use the client API here, because it modifies the Flow!
   new FlatMap<IN, OUT>(getName(), getFlow(), input,
     (i, c) -> c.collect(mapper.apply(i, c.asContext())), null, getHints()));
}

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

/**
 * This is not a basic operator. It can be straightforwardly implemented
 * by using {@code FlatMap} operator.
 * @return the operator chain representing this operation including FlatMap
 */
@Override
public DAG<Operator<?, ?>> getBasicOps() {
 return DAG.of(
   // do not use the client API here, because it modifies the Flow!
   new FlatMap<IN, OUT>(getName(), getFlow(), input,
     (i, c) -> c.collect(mapper.apply(i, c.asContext())), null, getHints()));
}

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

FlatMap<IN, Pair<Window<?>, IN>> map = new FlatMap<>(getName() + "::window-to-key",
  getFlow(),
  input,

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

FlatMap<IN, Pair<Window<?>, IN>> map = new FlatMap<>(getName() + "::window-to-key",
  getFlow(),
  input,