com.infoteria.asteria.flowlibrary2.stream
Class StreamFactoryCSV

java.lang.Object
  |
  +--com.infoteria.asteria.flowlibrary2.stream.StreamFactory
        |
        +--com.infoteria.asteria.flowlibrary2.stream.StreamFactoryText
              |
              +--com.infoteria.asteria.flowlibrary2.stream.StreamFactoryCSV

public class StreamFactoryCSV

extends StreamFactoryText

CSVのストリームファクトリ。
StreamFactory#getTypeがStreamType.CSVを返す場合このクラスにキャストできます。

Method Summary

void	add(java.lang.String[] record)
void	add(Value[] record)
StreamDataObject	create(byte[] b)
StreamDataObject	create(byte[] b, java.lang.String enc)
StreamDataObject	create(java.io.File file, java.lang.String enc)
StreamDataObject	create(java.io.InputStream is, java.lang.String enc)
StreamDataObject	create(java.util.List list)
StreamDataObject	create(java.lang.String str)
protected boolean	doEquals(StreamFactory sf)
int	getEscapeMode() EscapeModeプロパティの値を取得します。
int	getNullQuoting() NullQuotingプロパティの値を取得します。
int	getOutputFieldName() OutputFieldNameプロパティの値を取得します。
char	getQuotedBy() QuotedByプロパティの値を取得します。
int	getQuoteTarget() QuoteTargetプロパティの値を取得します。
char	getSeparator() Separatorプロパティの値を取得します。
int	getStartRow() StartRowプロパティの値を取得します。
void	initialize()
boolean	isOutputFieldName()
boolean	isReadTrim() ReadTrimプロパティの値を取得します。
void	setupParser(com.infoteria.asteria.util.csv.CSVParser parser)
void	terminate()

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

add, getEncoding, getLineFeed, setLineFeed

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

addProperty, compare, create, create, create, createEmptyStream, equals, getFactoryOutputStream, getFieldDefinition, getInstance, getInstance, getType, setFieldDefinition, setNeedCheckpointParse, setProperties

Methods inherited from class java.lang.Object

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

Method Detail

create

public StreamDataObject create(byte[] b)
                        throws StreamException

Description copied from class: StreamFactory

バイト列を基にストリームを作成します。
返り値のストリームにはストリームプロパティが適用されています。

Overrides:

create in class StreamFactoryText

create

public StreamDataObject create(java.lang.String str)
                        throws StreamException

Description copied from class: StreamFactoryText

文字列からストリームを作成します。
返り値のストリームにはストリームプロパティが適用されています。

Overrides:

create in class StreamFactoryText

create

public StreamDataObject create(byte[] b,
                               java.lang.String enc)
                        throws StreamException

Description copied from class: StreamFactoryText

バイト列とエンコーディングを指定してストリームを作成します。
encがnullの場合AutoDetectとなります。
返り値のストリームにはストリームプロパティが適用されています。

Overrides:

create in class StreamFactoryText

create

public StreamDataObject create(java.util.List list)
                        throws StreamException

create

public StreamDataObject create(java.io.File file,
                               java.lang.String enc)
                        throws StreamException

Overrides:

create in class StreamFactoryText

create

public StreamDataObject create(java.io.InputStream is,
                               java.lang.String enc)
                        throws StreamException

Overrides:

create in class StreamFactoryText

initialize

public void initialize()

Description copied from class: StreamFactory

Initialize instance and discard previously added data. Used together with "add" methods, StreamFactory.create() and StreamFactory.terminate(). Example usage:

 
 try {
 	initialize();
 	add(dataPart1);
 	add(dataPart2);
 	stream = create();
 } finally {
 	terminate();
 }
 
 

Overrides:

initialize in class StreamFactory

add

public void add(Value[] record)
         throws StreamException

add

public void add(java.lang.String[] record)
         throws StreamException

terminate

public void terminate()

Description copied from class: StreamFactory

Close any resources and discard previously added data. See StreamFactory.initialize() for more details.

Overrides:

terminate in class StreamFactory

getSeparator

public char getSeparator()

Separatorプロパティの値を取得します。

getQuotedBy

public char getQuotedBy()

QuotedByプロパティの値を取得します。

getStartRow

public int getStartRow()

StartRowプロパティの値を取得します。

getNullQuoting

public int getNullQuoting()

NullQuotingプロパティの値を取得します。

getQuoteTarget

public int getQuoteTarget()

QuoteTargetプロパティの値を取得します。

getOutputFieldName

public int getOutputFieldName()

OutputFieldNameプロパティの値を取得します。

getEscapeMode

public int getEscapeMode()

EscapeModeプロパティの値を取得します。

isReadTrim

public boolean isReadTrim()

ReadTrimプロパティの値を取得します。

isOutputFieldName

public boolean isOutputFieldName()

setupParser

public void setupParser(com.infoteria.asteria.util.csv.CSVParser parser)

doEquals

protected boolean doEquals(StreamFactory sf)

Overrides:

doEquals in class StreamFactoryText