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;
 
 
 
 import stream.Data;

Author(s):
Hendrik Blom <hendrik.blom@udo.edu>
 
 public class Lookup extends AbstractProcessor {
 
 	static Logger log = LoggerFactory.getLogger(Lookup.class);
 
 	protected LookupService lookup;
 	protected String key;

Returns:
lookupService
 
 	public LookupService getLookup() {
 		return ;
 	}

Parameters:
lookup
 
 	public void setLookup(LookupService lookup) {
 		this. = lookup;
 	}

Returns:
the key
 
 	public String getKey() {
 		return ;
 	}

Parameters:
key the key to set
 
 	@Parameter(defaultValue = "@id")
 	public void setKey(String key) {
 		this. = key;
 	}

See also:
stream.DataProcessor#process(stream.Data )
 
 	public Data process(Data item) {
 		if ( == null) {
 			.error("No LookupService injected!");
 			return item;
 		}
 
 		Serializable value = null;
 
 		if (.indexOf("%{") >= 0) {
 			value = (Serializable) ExpressionResolver.resolve(,
 					item);
 		} else {
 			value = item.get();
 		}
 
 		if (value == null) {
 			.debug("No value for lookup key '{}' in item {}"item);
			return item;
		}
		Data lookupData = .lookup(value.toString());
		if (lookupData != null) {
			item.putAll(lookupData);
		}
		return item;
	}
New to GrepCode? Check out our FAQ X