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() Convert this instance to use the default strategy and not use resources on server side.
protected StreamDataObject	doConvertToDefaultStrategy()
java.io.InputStream	getDataInputStream() Returns the stream's binary value as InputStream.
java.io.Reader	getDataStringReader() Return's the stream's String value as Reader.
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) Write stream data to specified file.

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

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

strValue

public java.lang.String strValue()
                          throws StreamException

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

Throws:

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

getDataStringReader

public java.io.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

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

Write stream data to specified file. Used to save stream together with a checkpoint.

Parameters:

targetFile - file to save stream to

Throws:

StreamException -

java.io.IOException -

convertToDefaultStrategy

public StreamDataObject convertToDefaultStrategy()
                                          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

doConvertToDefaultStrategy

protected StreamDataObject doConvertToDefaultStrategy()
                                               throws StreamException

clean

public void clean()

Clean all references and data in this instance.