Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /* Copyright 2014 The Johns Hopkins University Applied Physics Laboratory
   *
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package edu.jhuapl.tinkerpop.mapreduce;
 
 import java.util.Map;
 import java.util.Set;
 
 import  org.apache.hadoop.io.WritableComparable;
 
 
 
 public abstract class MapReduceElement implements Element,
 		WritableComparable<MapReduceElement> {
 
 	protected String id;
 
 	protected Map<StringObjectproperties;
 
 
 		this. = parent;
 		 = new HashMap<StringObject>();
 	}
 
 	void prepareId(String id) {
 		this. = id;
 	}
 
 	void prepareProperty(String keyObject property) {
 		.put(keyproperty);
 	}
 
 	public Object getId() {
 		return ;
 	}
 
 	public <T> T getProperty(String key) {
 		return (T) .get(key);
 	}
 
 	public Set<StringgetPropertyKeys() {
 		return new HashSet<String>(.keySet());
 	}
 
 	public void remove() {
 				"You cannot remove an element during a MapReduce job.");
 	}
 
 	public <T> T removeProperty(String key) {
 				"You cannot modify an element during a MapReduce job.");
 	}
 
 	public void setProperty(String keyObject value) {
 				"You cannot modify an element during a MapReduce job.");
 	}
 
 	protected Graph getParent() {
 		return ;
 	}
 
 	public void readFields(DataInput inthrows IOException {
 
 		int count = in.readInt();
 		for (int i = 0; i < counti++) {
 			String key = in.readUTF();
			byte[] data = new byte[in.readInt()];
			in.readFully(data);
			Object val = AccumuloByteSerializer.desserialize(data);
			.put(keyval);
		}
	}
	public void write(DataOutput outthrows IOException {
		for (String key : .keySet()) {
			out.writeUTF(key);
			byte[] data = AccumuloByteSerializer.serialize(.get(key));
			out.writeInt(data.length);
			out.write(data);
		}
	}
	public int compareTo(MapReduceElement other) {
		int val = this..compareTo(other.id);
		if (val != 0) {
			return val;
		}
	}
	public boolean equals(Object object) {
		if (object == this) {
			return true;
else if (object == null) {
			return false;
else if (!object.getClass().equals(getClass())) {
			return false;
else {
			Element element = (Elementobject;
			if ( == null) {
				return element.getId() == null;
else {
				return .equals(element.getId());
			}
		}
	}
	public int hashCode() {
		int hash = 31 * getClass().hashCode();
		if ( != null) {
			hash ^= .hashCode();
		}
		return hash;
	}
New to GrepCode? Check out our FAQ X