com.infoteria.asteria.flowlibrary2.stream
Class StreamFactoryRecord
java.lang.Object
|
+--com.infoteria.asteria.flowlibrary2.stream.StreamFactory
|
+--com.infoteria.asteria.flowlibrary2.stream.StreamFactoryRecord
- public class StreamFactoryRecord
- extends StreamFactory
Recordのストリームファクトリ。
StreamFactory#getTypeがStreamType.RECORDSを返す場合このクラスにキャストできます。
Methods inherited from class com.infoteria.asteria.flowlibrary2.stream.StreamFactory |
addProperty, compare, create, create, doEquals, equals, getFieldDefinition, getInstance, getType, setFieldDefinition, setNeedCheckpointParse, setProperties |
create
public StreamDataRecord create(List list)
throws StreamException
- Listを基にストリームを作成します。
引数のListはValue[]のリストでなければなりません。
create
public StreamDataObject create(byte[] b)
throws StreamException
- バイト列を基にストリームを作成します。
返り値のストリームにはストリームプロパティが適用されています。
StreamFactoryRecordではこのメソッドは使用するべきではありません。
- Overrides:
create
in class StreamFactory
createEmptyStream
public StreamDataObject createEmptyStream()
throws StreamException
- Description copied from class:
StreamFactory
- 空のストリームを作成します。
- Overrides:
createEmptyStream
in class StreamFactory