Examples of org.apache.tez.runtime.api.Processor

org.apache.tez.runtime.api.Processor
{@link Processor} represents the Tez entity responsible forconsuming {@link Input} and producing {@link Output}. It defines the application logic that processes and transforms the data. Users are expected to derive from {@link AbstractLogicalIOProcessor}

    return (LogicalOutput) output;
  }


  private LogicalIOProcessor createProcessor(
      ProcessorDescriptor processorDescriptor) {
    Processor processor = RuntimeUtils.createClazzInstance(processorDescriptor
        .getClassName());
    if (!(processor instanceof LogicalIOProcessor)) {
      throw new TezUncheckedException(processor.getClass().getName()
          + " is not a sub-type of LogicalIOProcessor."
          + " Only LogicalIOProcessor sub-types supported by LogicalIOProcessorRuntimeTask.");
    }
    return (LogicalIOProcessor) processor;
  }

View Full Code Here

    return (LogicalOutput) output;
  }


  private LogicalIOProcessor createProcessor(
      ProcessorDescriptor processorDescriptor) {
    Processor processor = RuntimeUtils.createClazzInstance(processorDescriptor
        .getClassName());
    if (!(processor instanceof LogicalIOProcessor)) {
      throw new TezUncheckedException(processor.getClass().getName()
          + " is not a sub-type of LogicalIOProcessor."
          + " Only LogicalIOProcessor sub-types supported by LogicalIOProcessorRuntimeTask.");
    }
    return (LogicalIOProcessor) processor;
  }

View Full Code Here

    return (LogicalOutput) output;
  }


  private AbstractLogicalIOProcessor createProcessor(
      String processorClassName, ProcessorContext processorContext) {
    Processor processor = ReflectionUtils.createClazzInstance(processorClassName,
        new Class[]{ProcessorContext.class}, new Object[]{processorContext});
    if (!(processor instanceof AbstractLogicalIOProcessor)) {
      throw new TezUncheckedException(processor.getClass().getName()
          + " is not a sub-type of AbstractLogicalIOProcessor."
          + " Only AbstractLogicalIOProcessor sub-types supported by LogicalIOProcessorRuntimeTask.");
    }
    return (AbstractLogicalIOProcessor) processor;
  }

View Full Code Here

    return (LogicalOutput) output;
  }


  private LogicalIOProcessor createProcessor(
      ProcessorDescriptor processorDescriptor) {
    Processor processor = RuntimeUtils.createClazzInstance(processorDescriptor
        .getClassName());
    if (!(processor instanceof LogicalIOProcessor)) {
      throw new TezUncheckedException(processor.getClass().getName()
          + " is not a sub-type of LogicalIOProcessor."
          + " Only LogicalIOProcessor sub-types supported by LogicalIOProcessorRuntimeTask.");
    }
    return (LogicalIOProcessor) processor;
  }

View Full Code Here

TOP

Related Classes of org.apache.tez.runtime.api.Processor

org.apache.tez.runtime.LogicalIOProcessorRuntimeTask

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.