org.apache.flink.shaded.guava18.com.google.common.collect.Lists类的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(14.1k)|赞(0)|评价(0)|浏览(1402)

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

Lists介绍

暂无

代码示例

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

/**
 * Creates a new {@code CoFeedbackTransformation} from the given input.
 *
 * @param parallelism The parallelism of the upstream {@code StreamTransformation} and the
 *                    feedback edges.
 * @param feedbackType The type of the feedback edges
 * @param waitTime The wait time of the feedback operator. After the time expires
 *                          the operation will close and not receive any more feedback elements.
 */
public CoFeedbackTransformation(int parallelism,
    TypeInformation<F> feedbackType,
    Long waitTime) {
  super("CoFeedback", feedbackType, parallelism);
  this.waitTime = waitTime;
  this.feedbackEdges = Lists.newArrayList();
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  result.addAll(input.getTransitivePredecessors());
  return result;
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  result.addAll(input.getTransitivePredecessors());
  return result;
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  result.addAll(input.getTransitivePredecessors());
  return result;
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  result.addAll(input.getTransitivePredecessors());
  return result;
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  result.addAll(input.getTransitivePredecessors());
  return result;
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  result.addAll(input.getTransitivePredecessors());
  return result;
}

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

@Override
  public Collection<StreamTransformation<?>> getTransitivePredecessors() {
    List<StreamTransformation<?>> result = Lists.newArrayList();
    result.add(this);
    result.addAll(input.getTransitivePredecessors());
    return result;
  }
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  for (StreamTransformation<T> input: inputs) {
    result.addAll(input.getTransitivePredecessors());
  }
  return result;
}

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

@Override
public Collection<StreamTransformation<?>> getTransitivePredecessors() {
  List<StreamTransformation<?>> result = Lists.newArrayList();
  result.add(this);
  result.addAll(input1.getTransitivePredecessors());
  result.addAll(input2.getTransitivePredecessors());
  return result;
}

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

@Test
public void testNotFollowedByBeforeOneOrMoreCombinations() throws Exception {
  final List<List<Event>> matches = testNotFollowedByBeforeOneOrMore(false, false);
  compareMaps(matches, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.D_1)
  ));
}

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

@Test
public void testSkipTillAnyOneOrMore() throws Exception {
  List<List<Event>> resultingPatterns = testOneOrMore(Quantifier.ConsumingStrategy.SKIP_TILL_ANY);
  compareMaps(resultingPatterns, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent3, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent3, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent3, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent3, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.end)
  ));
}

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

@Test
public void testNotFollowedByAnyAfterOneOrMoreCombinations() throws Exception {
  final List<List<Event>> matches = testNotFollowedByAfterOneOrMore(false, true);
  compareMaps(matches, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_4, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_4, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_6, NotFollowByData.D_1)
  ));
}

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

@Test
public void testNotFollowedByAnyAfterOneOrMoreEager() throws Exception {
  final List<List<Event>> matches = testNotFollowedByAfterOneOrMore(true, true);
  compareMaps(matches, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_4, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_6, NotFollowByData.D_1)
  ));
}

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

@Test
public void testNotFollowedByAnyBeforeOneOrMoreCombinations() throws Exception {
  final List<List<Event>> matches = testNotFollowedByBeforeOneOrMore(false, true);
  compareMaps(matches, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.D_1)
  ));
}

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

@Test
public void testNotFollowedByBeforeZeroOrMoreCombinationsSkipTillNext() throws Exception {
  final List<List<Event>> matches = testNotFollowedByBeforeZeroOrMore(false, false);
  compareMaps(matches, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_6, NotFollowByData.D_1)
  ));
}

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

@Test
public void testNotFollowedByBeforeZeroOrMoreCombinationsSkipTillAny() throws Exception {
  final List<List<Event>> matches = testNotFollowedByBeforeZeroOrMore(false, true);
  compareMaps(matches, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_4, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.B_6, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_5, NotFollowByData.D_1),
    Lists.newArrayList(NotFollowByData.A_1, NotFollowByData.B_1, NotFollowByData.B_6, NotFollowByData.D_1)
  ));
}

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

@Test
public void testSkipTillAnyZeroOrMore() throws Exception {
  List<List<Event>> resultingPatterns = testZeroOrMore(Quantifier.ConsumingStrategy.SKIP_TILL_ANY);
  compareMaps(resultingPatterns, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent3, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent3, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent3, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent3, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.end)
  ));
}

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

@Test
public void testIterativeWithBranchingPatternCombinations() throws Exception {
  List<List<Event>> actual = testIterativeWithBranchingPattern(false);
  compareMaps(actual,
    Lists.<List<Event>>newArrayList(
      Lists.newArrayList(startEvent1, endEvent, middleEvent1, middleEvent2, middleEvent4),
      Lists.newArrayList(startEvent1, endEvent, middleEvent2, middleEvent1),
      Lists.newArrayList(startEvent1, endEvent, middleEvent3, middleEvent1),
      Lists.newArrayList(startEvent2, endEvent, middleEvent3, middleEvent4),
      Lists.newArrayList(startEvent1, endEvent, middleEvent4, middleEvent1),
      Lists.newArrayList(startEvent1, endEvent, middleEvent1),
      Lists.newArrayList(startEvent2, endEvent, middleEvent3)
    )
  );
}

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

@Test
public void testSkipTillNextZeroOrMore() throws Exception {
  List<List<Event>> resultingPatterns = testZeroOrMore(Quantifier.ConsumingStrategy.SKIP_TILL_NEXT);
  compareMaps(resultingPatterns, Lists.<List<Event>>newArrayList(
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent3, ConsecutiveData.middleEvent4, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.middleEvent3, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.middleEvent2, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.middleEvent1, ConsecutiveData.end),
    Lists.newArrayList(ConsecutiveData.startEvent, ConsecutiveData.end)
  ));
}

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

Lists

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    Lists类方法

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