Coverage Report

 // BSD License (http://www.galagosearch.org/license)
 package org.galagosearch.tupleflow.execution;
 
 /**
  * <p>This specifies how input data should be assigned to outputs
  * in a TupleFlow connection.</p> 
  * 
  * <p>If a connection output has the "Combined" assignment, that means
  * that each stage instance reading that output will recieve all of the
  * input data.  This is the right kind of assignment to use when writing
  * out a single index file, for instance, where you want all the data
  * that was genereated by lots of parsing stage instances.</p>
  * 
  * <p>The "Each" mode means that every output stage instance gets
  * exactly one of the output streams.  Notice that a connection can be 
  * hashed, so this doesn't necessarily imply a 1-to-1 mapping between
  * inputs and outputs.  This is what you want to use when you're
  * trying to distribute data broadly across a cluster of machines.</p>
  * 
  * <p>The "One" mode is not yet supported.  The "One" mode, when implemented,
  * will allow each different named output to recieve exactly one share of the
  * input data.  The main use case for this is to support building document-distributed
  * indexes.</p>
  * 
  * @see org.galagosearch.tupleflow.execution.Connection
  * @see org.galagosearch.tupleflow.execution.Job
  * @author trevor
  */
 public enum ConnectionAssignmentType {
     Each {
         @Override
         public String toString() {
             return "each";
         }
     },
     One {
         @Override
         public String toString() {
             return "one";
         }
     },
     Combined {
         @Override
         public String toString() {
             return "combined";
         }
     }
 };

1		// BSD License (http://www.galagosearch.org/license)
2		package org.galagosearch.tupleflow.execution;
3
4		/**
5		* <p>This specifies how input data should be assigned to outputs
6		* in a TupleFlow connection.</p>
7		*
8		* <p>If a connection output has the "Combined" assignment, that means
9		* that each stage instance reading that output will recieve all of the
10		* input data. This is the right kind of assignment to use when writing
11		* out a single index file, for instance, where you want all the data
12		* that was genereated by lots of parsing stage instances.</p>
13		*
14		* <p>The "Each" mode means that every output stage instance gets
15		* exactly one of the output streams. Notice that a connection can be
16		* hashed, so this doesn't necessarily imply a 1-to-1 mapping between
17		* inputs and outputs. This is what you want to use when you're
18		* trying to distribute data broadly across a cluster of machines.</p>
19		*
20		* <p>The "One" mode is not yet supported. The "One" mode, when implemented,
21		* will allow each different named output to recieve exactly one share of the
22		* input data. The main use case for this is to support building document-distributed
23		* indexes.</p>
24		*
25		* @see org.galagosearch.tupleflow.execution.Connection
26		* @see org.galagosearch.tupleflow.execution.Job
27		* @author trevor
28		*/
29	14	public enum ConnectionAssignmentType {
30	2	Each {
31		@Override
32	2	public String toString() {
33	0	return "each";
34		}
35		},
36	2	One {
37		@Override
38	2	public String toString() {
39	0	return "one";
40		}
41		},
42	2	Combined {
43		@Override
44	2	public String toString() {
45	0	return "combined";
46		}
47		}
48		};