Package org.apache.flink.runtime.operators.util

Examples of org.apache.flink.runtime.operators.util.TaskConfig

1347
1348
1349
1350
1351
1352
1353
1354
1355
1356
1357
1358
1359
1360
1361
1362
        catch (Exception ex) {
          throw new RuntimeException("Could not instantiate chained task driver.", ex);
        }

        // get the configuration for the task
        final TaskConfig chainedStubConf = config.getChainedStubConfig(i);
        final String taskName = config.getChainedTaskName(i);

        if (i == numChained -1) {
          // last in chain, instantiate the output collector for this task
          previous = getOutputCollector(nepheleTask, chainedStubConf, cl, eventualOutputs, chainedStubConf.getNumOutputs());
        }

        ct.setup(chainedStubConf, taskName, previous, nepheleTask, cl);
        chainedTasksTarget.add(0, ct);
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
  @Test
  public void testOutputFormatVertex() {
    try {
      final TestingOutputFormat outputFormat = new TestingOutputFormat();
      final OutputFormatVertex of = new OutputFormatVertex("Name");
      new TaskConfig(of.getConfiguration()).setStubWrapper(new UserCodeObjectWrapper<OutputFormat<?>>(outputFormat));
      final ClassLoader cl = getClass().getClassLoader();
     
      try {
        of.initializeOnMaster(cl);
        fail("Did not throw expected exception.");
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
  @Test
  public void testInputFormatVertex() {
    try {
      final TestInputFormat inputFormat = new TestInputFormat();
      final InputFormatVertex vertex = new InputFormatVertex("Name");
      new TaskConfig(vertex.getConfiguration()).setStubWrapper(new UserCodeObjectWrapper<InputFormat<?, ?>>(inputFormat));
     
      final ClassLoader cl = getClass().getClassLoader();
     
      vertex.initializeOnMaster(cl);
      InputSplit[] splits = vertex.getInputSplitSource().createInputSplits(77);
View Full Code Here
TOP

Related Classes of org.apache.flink.runtime.operators.util.TaskConfig

  • org.apache.flink.api.common.distributions.DataDistribution
  • org.apache.flink.compiler.plantranslate.NepheleJobGraphGenerator
  • org.apache.flink.compiler.plantranslate.NepheleJobGraphGenerator$IterationDescriptor
  • org.apache.flink.configuration.Configuration
  • org.apache.flink.core.memory.InputViewDataInputStreamWrapper
  • org.apache.flink.core.memory.OutputViewDataOutputStreamWrapper
  • org.apache.flink.runtime.iterative.task.AbstractIterativePactTask
  • org.apache.flink.runtime.iterative.task.IterationHeadPactTask
  • org.apache.flink.runtime.iterative.task.IterationSynchronizationSinkTask
  • org.apache.flink.runtime.jobgraph.InputFormatVertex
    • 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.