Package com.infoteria.asteria.flowlibrary2.stream

Class StreamDataObject

java.lang.Object
com.infoteria.asteria.flowlibrary2.stream.StreamDataObject
All Implemented Interfaces:
RecordSet, Serializable
Direct Known Subclasses:
StreamDataBinaryBase, StreamDataContainer, StreamDataParameterList, StreamDataRecord
public abstract class StreamDataObject extends Object implements RecordSet, Serializable
ストリームの基底クラスです。
See Also:

  • Field Details

    • PROPERTY_FILEPATH

      public static final String PROPERTY_FILEPATH
      FilePathを表すストリーム変数のシンボル
      See Also:

    • _streamStrategy

      protected com.infoteria.asteria.flowlibrary2.stream.strategy.IStreamDataStrategy _streamStrategy

  • Method Details

    • getType

      public int getType()
      タイプを取得します。

    • byteValue

      public byte[] byteValue() throws StreamException
      ストリームのバイナリ値を取得します。
      Throws:
      StreamException - パースが発生し、それに失敗した場合

    • getDataInputStream

      public InputStream getDataInputStream() throws StreamException
      Returns the stream's binary value as InputStream. If this instance is a high-capacity stream, this method will make sure, that large data is not loaded into memory all at once.
      Returns:
      the stream's data
      Throws:
      StreamException

    • strValue

      public String strValue() throws StreamException
      ストリームの文字列値を取得します。
      Throws:
      StreamException - パースが発生し、それに失敗した場合

    • getDataStringReader

      public Reader getDataStringReader() throws StreamException
      Return's the stream's String value as Reader. If this instance is a high-capacity stream, this method will make sure, that large data is not loaded into memory all at once.
      Returns:
      the stream's String value as Reader
      Throws:
      StreamException

    • getFieldDefinition

      public FieldDefinition getFieldDefinition()
      フィールド定義を取得します。
      フィールド定義が存在しない場合はnullを返します。

    • putStreamVariable

      public void putStreamVariable(String name, Value value)
      ストリーム変数を設定します。
      Parameters:
      name - 変数名
      value - 値

    • getStreamVariable

      public Value getStreamVariable(String name)
      ストリーム変数を取得します。
      Parameters:
      name - 変数名
      Returns:
      値。変数名に対応する値が存在しない場合はnull

    • getStreamVariableCount

      public int getStreamVariableCount()
      設定されているストリーム変数の数を返します。
      Returns:
      設定されている変数の数値。(RecordNoとRecordCountは返り値に含まれません)

    • getStreamVariableNames

      public Iterator<String> getStreamVariableNames()
      ストリーム変数名のIteratorを返します。

    • getStreamPropertyNames

      public Iterator<String> getStreamPropertyNames()

    • writeCheckpointFile

      public void writeCheckpointFile(File targetFile) throws StreamException, IOException
      Write stream data to specified file. Used to save stream together with a checkpoint.
      Parameters:
      targetFile - file to save stream to
      Throws:
      StreamException
      IOException

    • convertToDefaultStrategy

      public StreamDataObject convertToDefaultStrategy(boolean debugMode) throws StreamException
      Convert this instance to use the default strategy and not use resources on server side. This ensures that data can be sent between Warp server and designer.
      Returns:
      the converted stream object using the default strategy
      Throws:
      StreamException

    • doConvertToDefaultStrategy

      protected StreamDataObject doConvertToDefaultStrategy() throws StreamException
      Throws:
      StreamException

    • clean

      public void clean()
      Clean all references and data in this instance.