Package com.asakusafw.compiler.flow.stage.StageModel

Examples of com.asakusafw.compiler.flow.stage.StageModel.Fragment

46
47
48
49
50
51
52
53
54
55
56
57
     * Part to Ex1.
     */
    @Test
    public void Part_Ex1() {
        List<StageModel> stages = compile(RestructureFlowExtend.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Ex1> result = mapper.create("out");

View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
85
     * Ex1 to Part.
     */
    @Test
    public void Ex1_Part() {
        List<StageModel> stages = compile(RestructureFlowProject.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Part1> result = mapper.create("out");

View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
113
     * Ex1 to Ex2.
     */
    @Test
    public void Ex1_Ex2() {
        List<StageModel> stages = compile(RestructureFlowSame.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Ex2> result = mapper.create("out");

View Full Code Here
131
132
133
134
135
136
137
138
139
140
141
142
     * Part1 to Part2.
     */
    @Test
    public void Part1_Part2() {
        List<StageModel> stages = compile(RestructureFlowSimple.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Part2> result = mapper.create("out");

View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
58
     * Ex1 to Part.
     */
    @Test
    public void Ex1_Part() {
        List<StageModel> stages = compile(ProjectFlowSimple.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Part1> result = mapper.create("out");

View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
86
     * Ex1 to Ex2.
     */
    @Test
    public void Ex1_Ex2() {
        List<StageModel> stages = compile(ProjectFlowSame.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Ex2> result = mapper.create("out");

View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
    @Test
    public void simple() throws Exception {
        StageModel analyzed = mr(NoShuffleStage.class);
        MapUnit map = analyzed.getMapUnits().get(0);
        assertThat(map.getFragments().size(), is(1));
        Fragment fragment = map.getFragments().get(0);

        MapFragmentEmitter emitter = new MapFragmentEmitter(environment);
        CompiledType name = emitter.emit(fragment, analyzed.getStageBlock());

        ClassLoader loader = start();
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
52
     * 単純なテスト。
     */
    @Test
    public void simple() {
        List<StageModel> stages = compile(UpdateFlowSimple.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Ex1> result = mapper.create("out");

View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
76
     * パラメーター付き。
     */
    @Test
    public void withParameter() {
        List<StageModel> stages = compile(UpdateFlowWithParameter.class);
        Fragment fragment = stages.get(0).getMapUnits().get(0).getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Ex1> result = mapper.create("out");

View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
    public void op1() {
        List<StageModel> stages = compile(CoGroupFlowOp1.class);
        StageModel stage = stages.get(0);
        Assume.assumeThat(stage.getReduceUnits().size(), is(1));
        ReduceUnit reduce = stage.getReduceUnits().get(0);
        Fragment fragment = reduce.getFragments().get(0);
        Name name = fragment.getCompiled().getQualifiedName();

        ClassLoader loader = start();
        PortMapper mapper = new PortMapper(fragment);
        MockResult<Ex1> result = mapper.create("r1");

        @SuppressWarnings("unchecked")
        Rendezvous<Writable> f = (Rendezvous<Writable>) create(loader, name, mapper.toArguments());

        Segment segment = stage.getShuffleModel().findSegment(fragment.getInputPorts().get(0));
        SegmentedWritable value = createShuffleValue(loader, stage);

        Ex1 ex1 = new Ex1();
        ex1.setStringAsString("string");
View Full Code Here
TOP

Related Classes of com.asakusafw.compiler.flow.stage.StageModel.Fragment

  • com.asakusafw.compiler.flow.processor.BranchFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.CoGroupFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.ConvertFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.ExtendFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.ExtractFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.GroupSortFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.LoggingFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.ProjectFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.RestructureFlowProcessorTest
  • com.asakusafw.compiler.flow.processor.SplitFlowProcessorTest
    • Copyright © 2018 www.massapicom. 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.