com.infoteria.asteria.flowlibrary2.stream
Class StreamDataObject

java.lang.Object
  |
  +--com.infoteria.asteria.flowlibrary2.stream.StreamDataObject

All Implemented Interfaces:

RecordSet, java.io.Serializable

Direct Known Subclasses:

StreamDataBinaryBase, StreamDataContainer, StreamDataParameterList, StreamDataRecord

public abstract class StreamDataObject

extends java.lang.Object

implements RecordSet, java.io.Serializable

ストリームの基底クラスです。

See Also:

Serialized Form

Field Summary

static java.lang.String

PROPERTY_FILEPATH FilePathを表すストリーム変数のシンボル

Method Summary

byte[]	byteValue() ストリームのバイナリ値を取得します。
void	clean() Clean all references and data in this instance.
StreamDataObject	convertToDefaultStrategy()
protected StreamDataObject	doConvertToDefaultStrategy()
java.io.InputStream	getDataInputStream()
java.io.Reader	getDataStringReader()
FieldDefinition	getFieldDefinition() フィールド定義を取得します。 フィールド定義が存在しない場合はnullを返します。
java.util.Iterator	getStreamPropertyNames()
Value	getStreamVariable(java.lang.String name) ストリーム変数を取得します。
int	getStreamVariableCount() 設定されているストリーム変数の数を返します。
java.util.Iterator	getStreamVariableNames() ストリーム変数名のIteratorを返します。
int	getType() タイプを取得します。
void	putStreamVariable(java.lang.String name, Value value) ストリーム変数を設定します。
java.lang.String	strValue() ストリームの文字列値を取得します。
void	writeCheckpointFile(java.io.File targetFile)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.infoteria.asteria.flowlibrary2.stream.RecordSet

getRecord, getRecordCount

Field Detail

PROPERTY_FILEPATH

public static final java.lang.String PROPERTY_FILEPATH

FilePathを表すストリーム変数のシンボル

Method Detail

getType

public int getType()

タイプを取得します。

byteValue

public byte[] byteValue()
                 throws StreamException

ストリームのバイナリ値を取得します。

Throws:

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

getDataInputStream

public java.io.InputStream getDataInputStream()
                                       throws StreamException

strValue

public java.lang.String strValue()
                          throws StreamException

ストリームの文字列値を取得します。

Throws:

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

getDataStringReader

public java.io.Reader getDataStringReader()
                                   throws StreamException

getFieldDefinition

public FieldDefinition getFieldDefinition()

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

putStreamVariable

public void putStreamVariable(java.lang.String name,
                              Value value)

ストリーム変数を設定します。

Parameters:

name - 変数名

value - 値

getStreamVariable

public Value getStreamVariable(java.lang.String name)

ストリーム変数を取得します。

Parameters:

name - 変数名

Returns:

値。変数名に対応する値が存在しない場合はnull

getStreamVariableCount

public int getStreamVariableCount()

設定されているストリーム変数の数を返します。

Returns:

設定されている変数の数値。(RecordNoとRecordCountは返り値に含まれません)

getStreamVariableNames

public java.util.Iterator getStreamVariableNames()

ストリーム変数名のIteratorを返します。

getStreamPropertyNames

public java.util.Iterator getStreamPropertyNames()

writeCheckpointFile

public void writeCheckpointFile(java.io.File targetFile)
                         throws StreamException,
                                java.io.IOException

convertToDefaultStrategy

public StreamDataObject convertToDefaultStrategy()
                                          throws StreamException

doConvertToDefaultStrategy

protected StreamDataObject doConvertToDefaultStrategy()
                                               throws StreamException

clean

public void clean()

Clean all references and data in this instance.