Package ptolemy.actor.ptalon.lib

Class SplitReader

  • All Implemented Interfaces:
    java.lang.Cloneable, Actor, Executable, FiringsRecordable, Initializable, TypedActor, Changeable, Debuggable, DebugListener, Derivable, Instantiable, ModelErrorHandler, MoMLExportable, Moveable, Nameable
    public class SplitReader
extends Source
    Read a file a file or URL, one line at a time, and output each line as a string. This actor has multiple outputs, and emits blocks of lines to each output at each firing, splitting the lines as chunks of data for distributed processing.

    The file or URL is specified using any form acceptable to FileParameter. Before an end of file is reached, the endOfFile output produces false. The blockSize and numberOfOutputs parameters determine how many lines are written to each output on each firing, and how many outputs to write to. If both of these are set to 1, this actor behaves exactly like the LineReader actor. In the iteration where the last line of the file is read and produced on an output port channel, this actor produces true on the endOfFile port. In that iteration, postfire() returns false. If the actor is iterated again, after the end of file, then prefire() and postfire() will both return false, output will produce the string "EOF", and endOfFile will produce true.

    In some domains (such as SDF), returning false in postfire() causes the model to cease executing. In other domains (such as DE), this causes the director to avoid further firings of this actor. So usually, the actor will not be invoked again after the end of file is reached.

    This actor reads ahead in the file so that it can produce an output true on endOfFile in the same iteration where it outputs the last line. It reads the first line in preinitialize(), and subsequently reads a new line in each invocation of postfire(). The line read is produced on the output in the next iteration after it is read.

    This actor can skip some lines at the beginning of the file or URL, with the number specified by the numberOfLinesToSkip parameter. The default value of this parameter is 0.

    If you need to reset this line reader to start again at the beginning of the file, the way to do this is to call initialize() during the run of the model. This can be done, for example, using a modal model with a transition where reset is enabled.

    Since:
    Ptolemy II 6.1
    Version:
    $Id$
    Author:
    Adam Cataldo
    See Also:
    LineReader
    Pt.AcceptedRating:
    Red (cxh)
    Pt.ProposedRating:
    Red (cxh)

    • Field Detail

      • blockSize

        public Parameter blockSize
        This number of lines to output to each port when this actor is fired.

      • endOfFile

        public TypedIOPort endOfFile
        An output port that produces false until the end of file is reached, at which point it produces true. The type is boolean.

      • fileOrURL

        public FileParameter fileOrURL
        The file name or URL from which to read. This is a string with any form accepted by FileParameter.
        See Also:
        FileParameter

      • numberOfLinesToSkip

        public Parameter numberOfLinesToSkip
        The number of lines to skip at the beginning of the file or URL. This parameter contains an IntToken, initially with value 0. The value of this parameter must be non-negative.

      • numberOfOutputs

        public Parameter numberOfOutputs
        The number of output actors to write to. This parameter contains an IntToken, initially with value 1. The value must be greater than zero.

      • _currentLines

        protected java.lang.String[][] _currentLines
        Cache of most recently read data.

      • _reader

        protected java.io.BufferedReader _reader
        The current reader for the input file.

    • Method Detail

      • attributeChanged

        public void attributeChanged​(Attribute attribute)
                      throws IllegalActionException
        If the specified attribute is fileOrURL and there is an open file being read, then close that file and open the new one; if the attribute is numberOfLinesToSkip and its value is negative, then throw an exception. In the case of fileOrURL, do nothing if the file name is the same as the previous value of this attribute.
        Overrides:
        attributeChanged in class NamedObj
        Parameters:
        attribute - The attribute that has changed.
        Throws:
        IllegalActionException - If the specified attribute is fileOrURL and the file cannot be opened, or the previously opened file cannot be closed; or if the attribute is numberOfLinesToSkip and its value is negative.

      • initialize

        public void initialize()
                throws IllegalActionException
        If this is called after prefire() has been called but before wrapup() has been called, then close any open file re-open it, skip the number of lines given by the numberOfLinesToSkip parameter, and read the first line to be produced in the next invocation of prefire(). This occurs if this actor is re-initialized during a run of the model.
        Specified by:
        initialize in interface Initializable
        Overrides:
        initialize in class AtomicActor<TypedIOPort>
        Throws:
        IllegalActionException - If the file or URL cannot be opened, or if the lines to be skipped and the first line to be sent out in the fire() method cannot be read.

      • prefire

        public boolean prefire()
                throws IllegalActionException
        Return false if there is no more data available in the file. Otherwise, return whatever the superclass returns.
        Specified by:
        prefire in interface Executable
        Overrides:
        prefire in class Source
        Returns:
        True, unless the trigger input is connected and has no input.
        Throws:
        IllegalActionException - If the superclass throws it.

      • preinitialize

        public void preinitialize()
                   throws IllegalActionException
        Open the file or URL, skip the number of lines specified by the numberOfLinesToSkip parameter, and read the first line to be sent out in the fire() method. This is done in preinitialize() so that derived classes can extract information from the file that affects information used in type resolution or scheduling.
        Specified by:
        preinitialize in interface Initializable
        Overrides:
        preinitialize in class AtomicActor<TypedIOPort>
        Throws:
        IllegalActionException - If the file or URL cannot be opened, or if the lines to be skipped and the first line to be sent out in the fire() method cannot be read.