@ Override public void initialize ( InputStream inputStream , DumpTableEnum table ) throws IOException { unbufferedResult = new PipedInputStream ( ) ; decodedStream = new PipedOutputStream ( unbufferedResult ) ; result = new BufferedInputStream ( unbufferedResult , BUFFERSIZE ) ; xmlInputThread = new XMLDumpTableInputStreamThread ( inputStream , decodedStream , table ) ; xmlInputThread . start ( ) ; }
Decorator for InputStream which allows to convert an XML input stream to SQL