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, waitcreateMarshallingContext, createUnmarshallingContextpublic StreamFormatSupport()
public void setName(String name)
name - the stream namepublic String getName()
StreamFormatgetName in interface StreamFormatpublic RecordReader createRecordReader(Reader in)
createRecordReader in interface StreamFormatin - the input stream to read frompublic RecordWriter createRecordWriter(Writer out)
createRecordWriter in interface StreamFormatout - the output stream to write topublic RecordMarshaller createRecordMarshaller()
StreamFormatcreateRecordMarshaller in interface StreamFormatRecordMarshallerpublic RecordUnmarshaller createRecordUnmarshaller()
StreamFormatcreateRecordUnmarshaller in interface StreamFormatRecordUnmarshallerpublic void setRecordParserFactory(RecordParserFactory recordParserFactory)
RecordParserFactory for creating record parsers.recordParserFactory - the RecordParserFactoryprotected RecordParserFactory getRecordParserFactory()
RecordParserFactory used by this stream.RecordParserFactory