Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   *  streams library
   *
   *  Copyright (C) 2011-2012 by Christian Bockermann, Hendrik Blom
   * 
   *  streams is a library, API and runtime environment for processing high
   *  volume data streams. It is composed of three submodules "stream-api",
   *  "stream-core" and "stream-runtime".
   *
  *  The streams library (and its submodules) is free software: you can 
  *  redistribute it and/or modify it under the terms of the 
  *  GNU Affero General Public License as published by the Free Software 
  *  Foundation, either version 3 of the License, or (at your option) any 
  *  later version.
  *
  *  The stream.ai library (and its submodules) is distributed in the hope
  *  that it will be useful, but WITHOUT ANY WARRANTY; without even the implied 
  *  warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  *  GNU Affero General Public License for more details.
  *
  *  You should have received a copy of the GNU Affero General Public License
  *  along with this program.  If not, see http://www.gnu.org/licenses/.
  */
 package stream.data.graph;
 
 import java.io.File;
 import java.util.Map;
 import java.util.Set;
 
 
 import stream.Data;

Author(s):
chris
 
 public class GraphProvider implements GraphService {
 
 	static Logger log = LoggerFactory.getLogger(GraphProvider.class);
 	File file;

Returns:
the file
 
 	public File getFile() {
 		return ;
 	}

Parameters:
file the file to set
 
 	public void setFile(File file) {
 		this. = file;
 	}

 
 	public void reset() throws Exception {
 		.debug("Reading graph from {}");
 		CsvStream stream = new CsvStream(new FileInputStream());
 		Data item = stream.read();
 		while (item != null) {
 			Serializable start = item.get("start");
 			Serializable end = item.get("end");
 			if (start != null && end != null) {
 				addEdge(start.toString(), end.toString());
 			} else {
 				throw new Exception(
 						"Failed to extract start/end from data item: " + item
 								+ "!");
 			}
 			item = stream.read();
 		}
 		stream.close();
 	}
 
 	public void addEdge(String startString end) {
 
 		Set<Stringneighs = .get(start);
 		if (neighs == null) {
 			neighs = new LinkedHashSet<String>();
 			.put(startneighs);
 		}
 		neighs.add(end);
 		.debug("Adding edge ({},{})"startend);
 		.debug("Neighbors of {} are: {}"startneighs);
 	}

	public Set<StringgetNodes() {
		return .keySet();
	}

	public Set<StringgetNeighbors(String node) {
			return .get(node);
		else
			return new HashSet<String>();
	}
New to GrepCode? Check out our FAQ X