public abstract class StreamFormatSupport extends Object implements StreamFormat
StreamFormat
implementations.Constructor and Description |
---|
StreamFormatSupport()
Constructs a new StreamFormatSupport.
|
Modifier and Type | Method and Description |
---|---|
RecordMarshaller |
createRecordMarshaller()
Creates a new record marshaller.
|
RecordReader |
createRecordReader(Reader in)
Creates a new RecordReader to read from the given input stream.
|
RecordUnmarshaller |
createRecordUnmarshaller()
Creates a new record unmarshaller.
|
RecordWriter |
createRecordWriter(Writer out)
Creates a new RecordWriter for writing to the given output stream.
|
String |
getName()
Returns the name of the stream.
|
protected RecordParserFactory |
getRecordParserFactory()
Returns the
RecordParserFactory used by this stream. |
void |
setName(String name)
Sets the name of this stream.
|
void |
setRecordParserFactory(RecordParserFactory recordParserFactory)
Sets the
RecordParserFactory for creating record parsers. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createMarshallingContext, createUnmarshallingContext
public StreamFormatSupport()
public void setName(String name)
name
- the stream namepublic String getName()
StreamFormat
getName
in interface StreamFormat
public RecordReader createRecordReader(Reader in)
createRecordReader
in interface StreamFormat
in
- the input stream to read frompublic RecordWriter createRecordWriter(Writer out)
createRecordWriter
in interface StreamFormat
out
- the output stream to write topublic RecordMarshaller createRecordMarshaller()
StreamFormat
createRecordMarshaller
in interface StreamFormat
RecordMarshaller
public RecordUnmarshaller createRecordUnmarshaller()
StreamFormat
createRecordUnmarshaller
in interface StreamFormat
RecordUnmarshaller
public void setRecordParserFactory(RecordParserFactory recordParserFactory)
RecordParserFactory
for creating record parsers.recordParserFactory
- the RecordParserFactory
protected RecordParserFactory getRecordParserFactory()
RecordParserFactory
used by this stream.RecordParserFactory