From: <tho...@us...> - 2010-10-18 19:14:40
|
Revision: 3813 http://bigdata.svn.sourceforge.net/bigdata/?rev=3813&view=rev Author: thompsonbry Date: 2010-10-18 19:14:34 +0000 (Mon, 18 Oct 2010) Log Message: ----------- removed unused method. Modified Paths: -------------- branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/BOpContext.java Modified: branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/BOpContext.java =================================================================== --- branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/BOpContext.java 2010-10-18 17:09:14 UTC (rev 3812) +++ branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/BOpContext.java 2010-10-18 19:14:34 UTC (rev 3813) @@ -385,40 +385,40 @@ // // } - /** - * Copy data from the source to the sink. The sink will be flushed and - * closed. The source will be closed. - */ - public void copySourceToSink() { +// /** +// * Copy data from the source to the sink. The sink will be flushed and +// * closed. The source will be closed. +// */ +// public void copySourceToSink() { +// +// // source. +// final IAsynchronousIterator<IBindingSet[]> source = (IAsynchronousIterator) getSource(); +// +// // default sink +// final IBlockingBuffer<IBindingSet[]> sink = (IBlockingBuffer) getSink(); +// +// final BOpStats stats = getStats(); +// +// try { +// +// // copy binding sets from the source. +// BOpUtility.copy(source, sink, null/* sink2 */, +// null/* constraints */, stats); +// +// // flush the sink. +// sink.flush(); +// +// } finally { +// +// sink.close(); +// +// if (sink2 != null) +// sink2.close(); +// +// source.close(); +// +// } +// +// } - // source. - final IAsynchronousIterator<IBindingSet[]> source = (IAsynchronousIterator) getSource(); - - // default sink - final IBlockingBuffer<IBindingSet[]> sink = (IBlockingBuffer) getSink(); - - final BOpStats stats = getStats(); - - try { - - // copy binding sets from the source. - BOpUtility.copy(source, sink, null/* sink2 */, - null/* constraints */, stats); - - // flush the sink. - sink.flush(); - - } finally { - - sink.close(); - - if (sink2 != null) - sink2.close(); - - source.close(); - - } - - } - } This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |