Package com.infoteria.asteria.flowlibrary2.stream

Class StreamDataContainer

java.lang.Object
com.infoteria.asteria.flowlibrary2.stream.StreamDataObject
com.infoteria.asteria.flowlibrary2.stream.StreamDataContainer
All Implemented Interfaces:
RecordSet, Serializable
public class StreamDataContainer extends StreamDataObject
ストリームコンテナ
See Also:

  • Constructor Details

    • StreamDataContainer

      public StreamDataContainer(int type)
      ストリームタイプを指定してストリームコンテナを作成します。

  • Method Details

    • getFieldDefinition

      public FieldDefinition getFieldDefinition()
      Description copied from class: StreamDataObject
      フィールド定義を取得します。
      フィールド定義が存在しない場合はnullを返します。
      Overrides:
      getFieldDefinition in class StreamDataObject

    • addStream

      public void addStream(StreamDataObject stream)
      ストリームコンテナにストリームを追加します。

    • getStreamCount

      public int getStreamCount()
      コンテナ中のストリーム数を返します。

    • getStream

      public StreamDataObject getStream(int index)
      index番目のストリームを取得します。

    • byteValue

      public byte[] byteValue() throws StreamException
      ストリームのバイト表現。 ストリームコンテナのバイナリ値はコンテナ中の各ストリームのバイナリ値を連結した値です。
      Overrides:
      byteValue in class StreamDataObject
      Throws:
      StreamException - パースが発生し、それに失敗した場合

    • strValue

      public String strValue() throws StreamException
      ストリームの文字列表現。 ストリームコンテナの文字列値はコンテナ中の各ストリームの文字列値を連結した値です。
      Overrides:
      strValue in class StreamDataObject
      Throws:
      StreamException - パースが発生し、それに失敗した場合

    • getRecord

      public Record getRecord() throws StreamException
      Recordを取得します。
      ストリームコンテナのRecordはコンテナ中の各ストリームのレコードをすべて含みます。
      Throws:
      StreamException

    • getRecordCount

      public int getRecordCount() throws StreamException
      Record数を取得します。
      ストリームコンテナのRecord数はコンテナ中の各ストリームのレコードの和です。
      Throws:
      StreamException

    • getStreamProperty

      @Deprecated public Value getStreamProperty(String name, int recordIndex)
      Deprecated.
      use getStreamVariable

    • getStreamVariable

      public Value getStreamVariable(String name, int recordIndex)
      recordIndexに対応するストリームのストリーム変数を取得します。
      2番目の引数がストリームのインデックスではなく、レコードのインデックスであることに注意してください。

    • canProcessBigData

      public boolean canProcessBigData()

    • clean

      public void clean()
      Description copied from class: StreamDataObject
      Clean all references and data in this instance.
      Overrides:
      clean in class StreamDataObject

    • doConvertToDefaultStrategy

      protected StreamDataObject doConvertToDefaultStrategy() throws StreamException
      Overrides:
      doConvertToDefaultStrategy in class StreamDataObject
      Throws:
      StreamException