Package com.infoteria.asteria.flowlibrary2.stream

Class StreamFactory

java.lang.Object
com.infoteria.asteria.flowlibrary2.stream.StreamFactory
Direct Known Subclasses:
StreamFactoryBinary, StreamFactoryParameterList, StreamFactoryRecord, StreamFactoryText
public abstract class StreamFactory extends Object
ストリームファクトリ。
ストリームファクトリはコンポーネントで設定されたフィールド定義とストリームプロパティを保持し、 ストリームに対して適用します。

  • Constructor Details

    • StreamFactory

      protected StreamFactory()

    • StreamFactory

      protected StreamFactory(com.infoteria.asteria.flowlibrary2.stream.strategy.IStreamStrategy strategy)

    • StreamFactory

      protected StreamFactory(StreamFactory factory)

  • Method Details

    • getInstance

      public static StreamFactory getInstance(int type)
      StreamTypeに応じたStreamFactoryのインスタンスを生成します

    • getInstance

      public static StreamFactory getInstance(int type, com.infoteria.asteria.flowlibrary2.stream.strategy.IStreamStrategy streamFactoryStrategy)
      StreamTypeに応じたStreamFactoryのインスタンスを生成します

    • addProperty

      public void addProperty(String name, String value) throws CompileException
      ストリーム定義のプロパティを設定します
      Throws:
      CompileException

    • setProperties

      public void setProperties(StreamDataObject stream) throws StreamException
      引数のstreamに対してストリームプロパティを適用します。
      引数のstreamに既にストリームプロパティが設定されている場合は何もしません。
      Throws:
      StreamException

    • setFieldDefinition

      public void setFieldDefinition(FieldDefinition value)
      フィールド定義を設定します。

    • getFieldDefinition

      public FieldDefinition getFieldDefinition()
      フィールド定義を取得します。

    • getType

      public int getType()
      このファクトリのストリームフォーマットを返します。
      返り値はStreamTypeクラスで宣言されているシンボルのいずれかになります。

    • initialize

      public void initialize()
      Initialize instance and discard previously added data. Used together with "add" methods, create() and terminate(). Example usage: 
       
 try {
        initialize();
        add(dataPart1);
        add(dataPart2);
        stream = create();
 } finally {
        terminate();
 }

    • getFactoryOutputStream

      public OutputStream getFactoryOutputStream() throws StreamException
      Get OutputStream to write stream data to. Call
      invalid reference 
      #initialize(StreamProperties)
      prior to this method. When finished writing all data to the output stream, call
      invalid reference 
      #create(StreamProperties)
      to create the stream object. Data can only be provided either with
      invalid reference 
      #getFactoryOutputStream(StreamProperties)
      or "add" methods, but not both.
      Parameters:
      streamProperties - properties to use for the new stream
      Returns:
      the output stream to write stream data to
      Throws:
      StreamException

    • terminate

      public void terminate()
      Close any resources and discard previously added data. See initialize() for more details.

    • create

      public abstract StreamDataObject create(byte[] b) throws StreamException
      バイト列を基にストリームを作成します。
      返り値のストリームにはストリームプロパティが適用されています。
      Throws:
      StreamException

    • create

      public StreamDataObject create() throws StreamException
      Create a StreamDataObject instance. If data is available from previous calls of "add" methods, the instance will be created using these data. Otherwise, an empty StreamDataObject instance will be returned. This method automatically calls terminate() in the end. See initialize() for more details.
      返り値のストリームにはストリームプロパティが適用されています。
      Returns:
      the new stream object
      Throws:
      StreamException - in case of an exception

    • createEmptyStream

      public StreamDataObject createEmptyStream() throws StreamException
      空のストリームを作成します。
      Throws:
      StreamException

    • create

      public StreamDataObject create(File file) throws StreamException
      Fileオブジェクトからストリームを作成します。
      Throws:
      StreamException

    • create

      public StreamDataObject create(InputStream is) throws StreamException
      java.io.InputStreamからストリームを作成します。
      Throws:
      StreamException

    • compare

      protected static boolean compare(Object o1, Object o2)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • doEquals

      protected boolean doEquals(StreamFactory sf)

    • setNeedCheckpointParse

      public void setNeedCheckpointParse(boolean b)