Package com.teracloud.streams.topology.file

Class TextFileReader

java.lang.Object
com.ibm.streams.operator.AbstractOperator
com.teracloud.streams.topology.file.TextFileReader
All Implemented Interfaces:
com.ibm.streams.operator.Operator
@PrimitiveOperator @InputPortSet(cardinality=1) @OutputPortSet(cardinality=1) public class TextFileReader extends com.ibm.streams.operator.AbstractOperator

  • Nested Class Summary

    Nested classes/interfaces inherited from interface com.ibm.streams.operator.Operator

    com.ibm.streams.operator.Operator.TagNames

  • Field Summary

    Fields inherited from class com.ibm.streams.operator.AbstractOperator

    IBM_Teracloud_ApS_COPYRIGHT

  • Constructor Summary

    Constructors
    Constructor
    Description
    TextFileReader()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getEncoding()
     
    void
    initialize(com.ibm.streams.operator.OperatorContext context)
     
    void
    process(com.ibm.streams.operator.StreamingInput<com.ibm.streams.operator.Tuple> stream, com.ibm.streams.operator.Tuple tuple)
     
    void
    setEncoding(String encoding)
     

    Methods inherited from class com.ibm.streams.operator.AbstractOperator

    allPortsReady, checkPorts, createAvoidCompletionThread, createAvoidCompletionThread, createAvoidCompletionThreadIfNoInputs, getControlPlaneContext, getException, getInput, getOperatorContext, getOutput, processPunctuation, setLoggerAspects, setTagData, shutdown

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TextFileReader

      public TextFileReader()

  • Method Details

    • getEncoding

      public String getEncoding()

    • setEncoding

      @Parameter(optional=true) public void setEncoding(String encoding)

    • initialize

      public void initialize(com.ibm.streams.operator.OperatorContext context) throws Exception
      Specified by:
      initialize in interface com.ibm.streams.operator.Operator
      Overrides:
      initialize in class com.ibm.streams.operator.AbstractOperator
      Throws:
      Exception

    • process

      public void process(com.ibm.streams.operator.StreamingInput<com.ibm.streams.operator.Tuple> stream, com.ibm.streams.operator.Tuple tuple) throws Exception
      Specified by:
      process in interface com.ibm.streams.operator.Operator
      Overrides:
      process in class com.ibm.streams.operator.AbstractOperator
      Throws:
      Exception