Examples of generateSequence()

Examples of eas.simulation.spatial.sim2D.marbSimulation.endlAutomat.EndlicherAutomat.generateSequence()

1170
1171
1172
1173
1174
1175
1176
1177
                        t.setAlter(t.getAlter() + 1);
                    }
                }
            }
        }
        getVerhCodes()[this.getAktAutNum()] = ea.generateSequence();
    }
}
View Full Code Here

Examples of eu.stratosphere.api.java.ExecutionEnvironment.generateSequence()

45
46
47
48
49
50
51
52
53
54
55
 
  @Override
  protected void testProgram() throws Exception {
    ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
   
    DataSet<Long> vertexIds = env.generateSequence(1, NUM_VERTICES);
    DataSet<String> edgeString = env.fromElements(ConnectedComponentsData.getRandomOddEvenEdges(NUM_EDGES, NUM_VERTICES, SEED).split("\n"));
   
    DataSet<Tuple2<Long, Long>> edges = edgeString.map(new EdgeParser());
   
    DataSet<Tuple2<Long, Long>> initialVertices = vertexIds.map(new IdAssigner());
View Full Code Here

Examples of eu.stratosphere.api.java.ExecutionEnvironment.generateSequence()

83
84
85
86
87
88
89
90
91
92
93
  public void testAllReduceWithCombiner() {
    try {
      ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
      env.setDegreeOfParallelism(8);
     
      DataSet<Long> data = env.generateSequence(1, 8000000).name("source");
     
      data.reduce(new ReduceFunction<Long>() {
       
        @Override
        public Long reduce(Long value1, Long value2){
View Full Code Here

Examples of eu.stratosphere.api.java.ExecutionEnvironment.generateSequence()

46
47
48
49
50
51
52
53
54
55
56
    try {
      ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
      env.setDegreeOfParallelism(DEFAULT_PARALLELISM);
      // compose test program
      {
        DataSet<Long> vertexIds = env.generateSequence(1, 2);
       
        @SuppressWarnings("unchecked")
        DataSet<Tuple2<Long, Long>> edges = env.fromElements(new Tuple2<Long, Long>(1L, 2L));
       
        DataSet<Tuple2<Long, Long>> initialVertices = vertexIds.map(new IdAssigner());
View Full Code Here

Examples of eu.stratosphere.api.java.ExecutionEnvironment.generateSequence()

86
87
88
89
90
91
92
93
94
95
96
  public void testAllReduceWithCombiner() {
    try {
      ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
      env.setDegreeOfParallelism(8);
     
      DataSet<Long> data = env.generateSequence(1, 8000000).name("source");
     
      ReduceGroupOperator<Long, Long> reduced = data.reduceGroup(new GroupReduceFunction<Long, Long>() {
        public void reduce(Iterator<Long> values, Collector<Long> out) {}
      }).name("reducer");
     
View Full Code Here

Examples of eu.stratosphere.api.java.ExecutionEnvironment.generateSequence()

116
117
118
119
120
121
122
123
124
125
126
      env.setDegreeOfParallelism(DEFAULT_PARALLELISM);
      // compose test program
      {
        DataSet<Long> bcVar = env.fromElements(1L);
       
        DataSet<Long> vertexIds = env.generateSequence(1, 2);
       
        @SuppressWarnings("unchecked")
        DataSet<Tuple2<Long, Long>> edges = env.fromElements(new Tuple2<Long, Long>(1L, 2L));
       
        DataSet<Tuple2<Long, Long>> initialVertices = vertexIds.map(new IdAssigner());
View Full Code Here

Examples of eu.stratosphere.api.java.ExecutionEnvironment.generateSequence()

26
27
28
29
30
31
32
33
34
35
36
public class SpargelConnectedComponents {

  public static void main(String[] args) throws Exception {
    ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
   
    DataSet<Long> vertexIds = env.generateSequence(0, 10);
    DataSet<Tuple2<Long, Long>> edges = env.fromElements(new Tuple2<Long, Long>(0L, 2L), new Tuple2<Long, Long>(2L, 4L), new Tuple2<Long, Long>(4L, 8L),
                              new Tuple2<Long, Long>(1L, 5L), new Tuple2<Long, Long>(3L, 7L), new Tuple2<Long, Long>(3L, 9L));
   
    DataSet<Tuple2<Long, Long>> initialVertices = vertexIds.map(new IdAssigner());
   
View Full Code Here

Examples of eu.stratosphere.api.java.ExecutionEnvironment.generateSequence()

41
42
43
44
45
46
47
48
49
50
51
    final int NUM_VERTICES = 100;
   
    ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
   
    // a list of vertices
    DataSet<Long> vertices = env.generateSequence(1, NUM_VERTICES);
   
    // generate some random edges. the transition probability on each edge is 1/num-out-edges of the source vertex
    DataSet<Tuple3<Long, Long, Double>> edgesWithProbability = env.generateSequence(1, NUM_VERTICES)
                .flatMap(new FlatMapFunction<Long, Tuple3<Long, Long, Double>>() {
                  public void flatMap(Long value, Collector<Tuple3<Long, Long, Double>> out) {
View Full Code Here

Examples of org.apache.flink.api.java.CollectionEnvironment.generateSequence()

38
39
40
41
42
43
44
45
46
47
48
    try {
      final int NUM_ELEMENTS = 100;
     
      ExecutionEnvironment env = new CollectionEnvironment();
     
      env.generateSequence(1, NUM_ELEMENTS)
        .map(new CountingMapper())
        .output(new DiscardingOuputFormat<Long>());
     
      JobExecutionResult result = env.execute();
     
View Full Code Here

Examples of org.apache.flink.api.java.ExecutionEnvironment.generateSequence()

37
38
39
40
41
42
43
44
45
46
47
  @Test
  public void testWorksetIterationNotDependingOnSolutionSet() {
    try {
      ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
     
      DataSet<Tuple2<Long, Long>> input = env.generateSequence(1, 100).map(new Duplicator<Long>());
     
      DeltaIteration<Tuple2<Long, Long>, Tuple2<Long, Long>> iteration = input.iterateDelta(input, 100, 1);
     
      DataSet<Tuple2<Long, Long>> iterEnd = iteration.getWorkset().map(new TestMapper<Tuple2<Long,Long>>());
      iteration.closeWith(iterEnd, iterEnd).print();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.