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, java.io.Serializable

public class StreamDataContainer

extends StreamDataObject

ストリームコンテナ

See Also:

Serialized Form

Fields inherited from class com.infoteria.asteria.flowlibrary2.stream.StreamDataObject

PROPERTY_FILEPATH

Constructor Summary

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

Method Summary

void	addStream(StreamDataObject stream) ストリームコンテナにストリームを追加します。
byte[]	byteValue() ストリームのバイト表現。 ストリームコンテナのバイナリ値はコンテナ中の各ストリームのバイナリ値を連結した値です。
void	clean()
protected StreamDataObject	doConvertToDefaultStrategy()
FieldDefinition	getFieldDefinition()
Record	getRecord() Recordを取得します。 ストリームコンテナのRecordはコンテナ中の各ストリームのレコードをすべて含みます。
int	getRecordCount() Record数を取得します。 ストリームコンテナのRecord数はコンテナ中の各ストリームのレコードの和です。
StreamDataObject	getStream(int index) index番目のストリームを取得します。
int	getStreamCount() コンテナ中のストリーム数を返します。
Value	getStreamProperty(java.lang.String name, int recordIndex) Deprecated. use getStreamVariable
Value	getStreamVariable(java.lang.String name, int recordIndex) recordIndexに対応するストリームのストリーム変数を取得します。 2番目の引数がストリームのインデックスではなく、レコードのインデックスであることに注意してください。
java.lang.String	strValue() ストリームの文字列表現。 ストリームコンテナの文字列値はコンテナ中の各ストリームの文字列値を連結した値です。

Methods inherited from class com.infoteria.asteria.flowlibrary2.stream.StreamDataObject

convertToDefaultStrategy, getDataInputStream, getDataStringReader, getStreamPropertyNames, getStreamVariable, getStreamVariableCount, getStreamVariableNames, getType, putStreamVariable, writeCheckpointFile

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamDataContainer

public StreamDataContainer(int type)

ストリームタイプを指定してストリームコンテナを作成します。

Method Detail

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 java.lang.String strValue()
                          throws StreamException

ストリームの文字列表現。 ストリームコンテナの文字列値はコンテナ中の各ストリームの文字列値を連結した値です。

Overrides:

strValue in class StreamDataObject

Throws:

StreamException - パースが発生し、それに失敗した場合

getRecord

public Record getRecord()
                 throws StreamException

Recordを取得します。
ストリームコンテナのRecordはコンテナ中の各ストリームのレコードをすべて含みます。

getRecordCount

public int getRecordCount()
                   throws StreamException

Record数を取得します。
ストリームコンテナのRecord数はコンテナ中の各ストリームのレコードの和です。

getStreamProperty

public Value getStreamProperty(java.lang.String name,
                               int recordIndex)

Deprecated. use getStreamVariable

getStreamVariable

public Value getStreamVariable(java.lang.String name,
                               int recordIndex)

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

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