Package 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

Modifier and Type	Method	Description
void	add(Value[] record)
void	add(String[] record)
StreamDataObject	create(byte[] b)	バイト列を基にストリームを作成します。 返り値のストリームにはストリームプロパティが適用されています。
StreamDataObject	create(byte[] b, String enc)	バイト列とエンコーディングを指定してストリームを作成します。 encがnullの場合AutoDetectとなります。 返り値のストリームにはストリームプロパティが適用されています。
StreamDataObject	create(File file, String enc)
StreamDataObject	create(InputStream is, String enc)
StreamDataObject	create(String str)	文字列からストリームを作成します。 返り値のストリームにはストリームプロパティが適用されています。
StreamDataObject	create(List<String[]> list)
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()	Initialize instance and discard previously added data.
boolean	isMemoryReductionMode()	MemoryReductionModeプロパティの値を取得します。
boolean	isOutputFieldName()
boolean	isReadTrim()	ReadTrimプロパティの値を取得します。
void	setupParser(com.infoteria.asteria.util.csv.CSVParser parser)
void	terminate()	Close any resources and discard previously added data.

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

add, getEncoding, getLineFeed, setLineFeed

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

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 Details

create

public StreamDataObject create(byte[] b)
                        throws StreamException

Description copied from class: StreamFactory

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

Overrides:

create in class StreamFactoryText

Throws:

StreamException

create

public StreamDataObject create(String str)
                        throws StreamException

Description copied from class: StreamFactoryText

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

Overrides:

create in class StreamFactoryText

Throws:

StreamException

create

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

Description copied from class: StreamFactoryText

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

Overrides:

create in class StreamFactoryText

Throws:

StreamException

create

public StreamDataObject create(List<String[]> list)
                        throws StreamException

Throws:

StreamException

create

public StreamDataObject create(File file,
 String enc)
                        throws StreamException

Overrides:

create in class StreamFactoryText

Throws:

StreamException

create

public StreamDataObject create(InputStream is,
 String enc)
                        throws StreamException

Overrides:

create in class StreamFactoryText

Throws:

StreamException

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

Throws:

StreamException

add

public void add(String[] record)
         throws StreamException

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プロパティの値を取得します。

isMemoryReductionMode

public boolean isMemoryReductionMode()

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

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