Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package stream.data;
 
 
 import stream.Data;

Author(s):
Hendrik Blom
public class CheckDataAvailability extends AbstractProcessor {
	static Logger log = LoggerFactory.getLogger(CheckDataAvailability.class);
	protected String[] keys;
	protected String scope;
		super();
		 = "data";
	}
	public String[] getKeys() {
		return ;
	}
	public void setKeys(String[] keys) {
		this. = keys;
	}
	public void init(ProcessContext ctxthrows Exception {
		super.init(ctx);
	}
	public String getScope() {
		return ;
	}
	public void setScope(String scope) {
		this. = scope;
	}
	public Data process(Data input) {
		boolean complete = true;
		if (.equals("data")) {
			for (String key : ) {
				if (input.get(key) == null) {
					sb.append(key);
					sb.append("\n");
					complete = false;
				}
			}
		}
		if (.equals("process")) {
			for (String key : ) {
				if (.get(key) == null) {
					sb.append(key);
					sb.append("\n");
					complete = false;
				}
			}
		}
		if (!complete) {
			.info("Not all data with the defined keys are aavailable. Missing keys:\n"
sb.toString());
			input.put("dataavailable"false);
else {
			.info("All data are available.");
			input.put("dataavailable"true);
		}
		return input;
	}
New to GrepCode? Check out our FAQ X