metron-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ceste...@apache.org
Subject [2/6] incubator-metron git commit: METRON-362: Unify the Stellar Languages closes apache/incubator-metron#207
Date Thu, 11 Aug 2016 22:25:25 GMT
http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationLexer.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationLexer.java b/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationLexer.java
deleted file mode 100644
index ca48a83..0000000
--- a/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationLexer.java
+++ /dev/null
@@ -1,148 +0,0 @@
-// Generated from org/apache/metron/common/transformation/generated/Transformation.g4 by ANTLR 4.5
-package org.apache.metron.common.transformation.generated;
-
-//CHECKSTYLE:OFF
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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.
- */
-
-import org.antlr.v4.runtime.Lexer;
-import org.antlr.v4.runtime.CharStream;
-import org.antlr.v4.runtime.Token;
-import org.antlr.v4.runtime.TokenStream;
-import org.antlr.v4.runtime.*;
-import org.antlr.v4.runtime.atn.*;
-import org.antlr.v4.runtime.dfa.DFA;
-import org.antlr.v4.runtime.misc.*;
-
-@SuppressWarnings({"all", "warnings", "unchecked", "unused", "cast"})
-public class TransformationLexer extends Lexer {
-	static { RuntimeMetaData.checkVersion("4.5", RuntimeMetaData.VERSION); }
-
-	protected static final DFA[] _decisionToDFA;
-	protected static final PredictionContextCache _sharedContextCache =
-		new PredictionContextCache();
-	public static final int
-		COMMA=1, LBRACKET=2, RBRACKET=3, LPAREN=4, RPAREN=5, INT_LITERAL=6, DOUBLE_LITERAL=7, 
-		IDENTIFIER=8, STRING_LITERAL=9, COMMENT=10, WS=11;
-	public static String[] modeNames = {
-		"DEFAULT_MODE"
-	};
-
-	public static final String[] ruleNames = {
-		"COMMA", "LBRACKET", "RBRACKET", "LPAREN", "RPAREN", "INT_LITERAL", "DOUBLE_LITERAL", 
-		"IDENTIFIER", "SCHAR", "STRING_LITERAL", "COMMENT", "WS"
-	};
-
-	private static final String[] _LITERAL_NAMES = {
-		null, "','", "'['", "']'", "'('", "')'"
-	};
-	private static final String[] _SYMBOLIC_NAMES = {
-		null, "COMMA", "LBRACKET", "RBRACKET", "LPAREN", "RPAREN", "INT_LITERAL", 
-		"DOUBLE_LITERAL", "IDENTIFIER", "STRING_LITERAL", "COMMENT", "WS"
-	};
-	public static final Vocabulary VOCABULARY = new VocabularyImpl(_LITERAL_NAMES, _SYMBOLIC_NAMES);
-
-	/**
-	 * @deprecated Use {@link #VOCABULARY} instead.
-	 */
-	@Deprecated
-	public static final String[] tokenNames;
-	static {
-		tokenNames = new String[_SYMBOLIC_NAMES.length];
-		for (int i = 0; i < tokenNames.length; i++) {
-			tokenNames[i] = VOCABULARY.getLiteralName(i);
-			if (tokenNames[i] == null) {
-				tokenNames[i] = VOCABULARY.getSymbolicName(i);
-			}
-
-			if (tokenNames[i] == null) {
-				tokenNames[i] = "<INVALID>";
-			}
-		}
-	}
-
-	@Override
-	@Deprecated
-	public String[] getTokenNames() {
-		return tokenNames;
-	}
-
-	@Override
-
-	public Vocabulary getVocabulary() {
-		return VOCABULARY;
-	}
-
-
-	public TransformationLexer(CharStream input) {
-		super(input);
-		_interp = new LexerATNSimulator(this,_ATN,_decisionToDFA,_sharedContextCache);
-	}
-
-	@Override
-	public String getGrammarFileName() { return "Transformation.g4"; }
-
-	@Override
-	public String[] getRuleNames() { return ruleNames; }
-
-	@Override
-	public String getSerializedATN() { return _serializedATN; }
-
-	@Override
-	public String[] getModeNames() { return modeNames; }
-
-	@Override
-	public ATN getATN() { return _ATN; }
-
-	public static final String _serializedATN =
-		"\3\u0430\ud6d1\u8206\uad2d\u4417\uaef1\u8d80\uaadd\2\rd\b\1\4\2\t\2\4"+
-		"\3\t\3\4\4\t\4\4\5\t\5\4\6\t\6\4\7\t\7\4\b\t\b\4\t\t\t\4\n\t\n\4\13\t"+
-		"\13\4\f\t\f\4\r\t\r\3\2\3\2\3\3\3\3\3\4\3\4\3\5\3\5\3\6\3\6\3\7\6\7\'"+
-		"\n\7\r\7\16\7(\3\b\6\b,\n\b\r\b\16\b-\3\b\3\b\6\b\62\n\b\r\b\16\b\63\3"+
-		"\t\3\t\7\t8\n\t\f\t\16\t;\13\t\3\n\3\n\3\13\3\13\7\13A\n\13\f\13\16\13"+
-		"D\13\13\3\13\3\13\3\13\7\13I\n\13\f\13\16\13L\13\13\3\13\5\13O\n\13\3"+
-		"\f\3\f\3\f\3\f\6\fU\n\f\r\f\16\fV\3\f\5\fZ\n\f\3\f\3\f\3\r\6\r_\n\r\r"+
-		"\r\16\r`\3\r\3\r\3V\2\16\3\3\5\4\7\5\t\6\13\7\r\b\17\t\21\n\23\2\25\13"+
-		"\27\f\31\r\3\2\7\5\2C\\aac|\b\2\60\60\62;C\\^^aac|\7\2\f\f\17\17$$))^"+
-		"^\3\3\f\f\5\2\13\f\16\17\"\"k\2\3\3\2\2\2\2\5\3\2\2\2\2\7\3\2\2\2\2\t"+
-		"\3\2\2\2\2\13\3\2\2\2\2\r\3\2\2\2\2\17\3\2\2\2\2\21\3\2\2\2\2\25\3\2\2"+
-		"\2\2\27\3\2\2\2\2\31\3\2\2\2\3\33\3\2\2\2\5\35\3\2\2\2\7\37\3\2\2\2\t"+
-		"!\3\2\2\2\13#\3\2\2\2\r&\3\2\2\2\17+\3\2\2\2\21\65\3\2\2\2\23<\3\2\2\2"+
-		"\25N\3\2\2\2\27P\3\2\2\2\31^\3\2\2\2\33\34\7.\2\2\34\4\3\2\2\2\35\36\7"+
-		"]\2\2\36\6\3\2\2\2\37 \7_\2\2 \b\3\2\2\2!\"\7*\2\2\"\n\3\2\2\2#$\7+\2"+
-		"\2$\f\3\2\2\2%\'\4\62;\2&%\3\2\2\2\'(\3\2\2\2(&\3\2\2\2()\3\2\2\2)\16"+
-		"\3\2\2\2*,\4\62;\2+*\3\2\2\2,-\3\2\2\2-+\3\2\2\2-.\3\2\2\2./\3\2\2\2/"+
-		"\61\7\60\2\2\60\62\4\62;\2\61\60\3\2\2\2\62\63\3\2\2\2\63\61\3\2\2\2\63"+
-		"\64\3\2\2\2\64\20\3\2\2\2\659\t\2\2\2\668\t\3\2\2\67\66\3\2\2\28;\3\2"+
-		"\2\29\67\3\2\2\29:\3\2\2\2:\22\3\2\2\2;9\3\2\2\2<=\n\4\2\2=\24\3\2\2\2"+
-		">B\7$\2\2?A\5\23\n\2@?\3\2\2\2AD\3\2\2\2B@\3\2\2\2BC\3\2\2\2CE\3\2\2\2"+
-		"DB\3\2\2\2EO\7$\2\2FJ\7)\2\2GI\5\23\n\2HG\3\2\2\2IL\3\2\2\2JH\3\2\2\2"+
-		"JK\3\2\2\2KM\3\2\2\2LJ\3\2\2\2MO\7)\2\2N>\3\2\2\2NF\3\2\2\2O\26\3\2\2"+
-		"\2PQ\7\61\2\2QR\7\61\2\2RT\3\2\2\2SU\13\2\2\2TS\3\2\2\2UV\3\2\2\2VW\3"+
-		"\2\2\2VT\3\2\2\2WY\3\2\2\2XZ\t\5\2\2YX\3\2\2\2Z[\3\2\2\2[\\\b\f\2\2\\"+
-		"\30\3\2\2\2]_\t\6\2\2^]\3\2\2\2_`\3\2\2\2`^\3\2\2\2`a\3\2\2\2ab\3\2\2"+
-		"\2bc\b\r\2\2c\32\3\2\2\2\r\2(-\639BJNVY`\3\b\2\2";
-	public static final ATN _ATN =
-		new ATNDeserializer().deserialize(_serializedATN.toCharArray());
-	static {
-		_decisionToDFA = new DFA[_ATN.getNumberOfDecisions()];
-		for (int i = 0; i < _ATN.getNumberOfDecisions(); i++) {
-			_decisionToDFA[i] = new DFA(_ATN.getDecisionState(i), i);
-		}
-	}
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationListener.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationListener.java b/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationListener.java
deleted file mode 100644
index c9673cb..0000000
--- a/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationListener.java
+++ /dev/null
@@ -1,177 +0,0 @@
-// Generated from org/apache/metron/common/transformation/generated/Transformation.g4 by ANTLR 4.5
-package org.apache.metron.common.transformation.generated;
-
-//CHECKSTYLE:OFF
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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.
- */
-
-import org.antlr.v4.runtime.misc.NotNull;
-import org.antlr.v4.runtime.tree.ParseTreeListener;
-
-/**
- * This interface defines a complete listener for a parse tree produced by
- * {@link TransformationParser}.
- */
-public interface TransformationListener extends ParseTreeListener {
-	/**
-	 * Enter a parse tree produced by {@link TransformationParser#transformation}.
-	 * @param ctx the parse tree
-	 */
-	void enterTransformation(TransformationParser.TransformationContext ctx);
-	/**
-	 * Exit a parse tree produced by {@link TransformationParser#transformation}.
-	 * @param ctx the parse tree
-	 */
-	void exitTransformation(TransformationParser.TransformationContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code TransformationExpr}
-	 * labeled alternative in {@link TransformationParser#transformation_expr}.
-	 * @param ctx the parse tree
-	 */
-	void enterTransformationExpr(TransformationParser.TransformationExprContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code TransformationExpr}
-	 * labeled alternative in {@link TransformationParser#transformation_expr}.
-	 * @param ctx the parse tree
-	 */
-	void exitTransformationExpr(TransformationParser.TransformationExprContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code TransformationEntity}
-	 * labeled alternative in {@link TransformationParser#transformation_expr}.
-	 * @param ctx the parse tree
-	 */
-	void enterTransformationEntity(TransformationParser.TransformationEntityContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code TransformationEntity}
-	 * labeled alternative in {@link TransformationParser#transformation_expr}.
-	 * @param ctx the parse tree
-	 */
-	void exitTransformationEntity(TransformationParser.TransformationEntityContext ctx);
-	/**
-	 * Enter a parse tree produced by {@link TransformationParser#transformation_entity}.
-	 * @param ctx the parse tree
-	 */
-	void enterTransformation_entity(TransformationParser.Transformation_entityContext ctx);
-	/**
-	 * Exit a parse tree produced by {@link TransformationParser#transformation_entity}.
-	 * @param ctx the parse tree
-	 */
-	void exitTransformation_entity(TransformationParser.Transformation_entityContext ctx);
-	/**
-	 * Enter a parse tree produced by {@link TransformationParser#func_args}.
-	 * @param ctx the parse tree
-	 */
-	void enterFunc_args(TransformationParser.Func_argsContext ctx);
-	/**
-	 * Exit a parse tree produced by {@link TransformationParser#func_args}.
-	 * @param ctx the parse tree
-	 */
-	void exitFunc_args(TransformationParser.Func_argsContext ctx);
-	/**
-	 * Enter a parse tree produced by {@link TransformationParser#op_list}.
-	 * @param ctx the parse tree
-	 */
-	void enterOp_list(TransformationParser.Op_listContext ctx);
-	/**
-	 * Exit a parse tree produced by {@link TransformationParser#op_list}.
-	 * @param ctx the parse tree
-	 */
-	void exitOp_list(TransformationParser.Op_listContext ctx);
-	/**
-	 * Enter a parse tree produced by {@link TransformationParser#list_entity}.
-	 * @param ctx the parse tree
-	 */
-	void enterList_entity(TransformationParser.List_entityContext ctx);
-	/**
-	 * Exit a parse tree produced by {@link TransformationParser#list_entity}.
-	 * @param ctx the parse tree
-	 */
-	void exitList_entity(TransformationParser.List_entityContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code StringLiteral}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void enterStringLiteral(TransformationParser.StringLiteralContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code StringLiteral}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void exitStringLiteral(TransformationParser.StringLiteralContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code IntegerLiteral}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void enterIntegerLiteral(TransformationParser.IntegerLiteralContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code IntegerLiteral}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void exitIntegerLiteral(TransformationParser.IntegerLiteralContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code DoubleLiteral}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void enterDoubleLiteral(TransformationParser.DoubleLiteralContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code DoubleLiteral}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void exitDoubleLiteral(TransformationParser.DoubleLiteralContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code Variable}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void enterVariable(TransformationParser.VariableContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code Variable}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void exitVariable(TransformationParser.VariableContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code TransformationFunc}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void enterTransformationFunc(TransformationParser.TransformationFuncContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code TransformationFunc}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void exitTransformationFunc(TransformationParser.TransformationFuncContext ctx);
-	/**
-	 * Enter a parse tree produced by the {@code List}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void enterList(TransformationParser.ListContext ctx);
-	/**
-	 * Exit a parse tree produced by the {@code List}
-	 * labeled alternative in {@link TransformationParser#identifier_operand}.
-	 * @param ctx the parse tree
-	 */
-	void exitList(TransformationParser.ListContext ctx);
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationParser.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationParser.java b/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationParser.java
deleted file mode 100644
index 48fd820..0000000
--- a/metron-platform/metron-common/src/main/java/org/apache/metron/common/transformation/generated/TransformationParser.java
+++ /dev/null
@@ -1,640 +0,0 @@
-// Generated from org/apache/metron/common/transformation/generated/Transformation.g4 by ANTLR 4.5
-package org.apache.metron.common.transformation.generated;
-
-//CHECKSTYLE:OFF
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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.
- */
-
-import org.antlr.v4.runtime.atn.*;
-import org.antlr.v4.runtime.dfa.DFA;
-import org.antlr.v4.runtime.*;
-import org.antlr.v4.runtime.misc.*;
-import org.antlr.v4.runtime.tree.*;
-import java.util.List;
-import java.util.Iterator;
-import java.util.ArrayList;
-
-@SuppressWarnings({"all", "warnings", "unchecked", "unused", "cast"})
-public class TransformationParser extends Parser {
-	static { RuntimeMetaData.checkVersion("4.5", RuntimeMetaData.VERSION); }
-
-	protected static final DFA[] _decisionToDFA;
-	protected static final PredictionContextCache _sharedContextCache =
-		new PredictionContextCache();
-	public static final int
-		COMMA=1, LBRACKET=2, RBRACKET=3, LPAREN=4, RPAREN=5, INT_LITERAL=6, DOUBLE_LITERAL=7, 
-		IDENTIFIER=8, STRING_LITERAL=9, COMMENT=10, WS=11;
-	public static final int
-		RULE_transformation = 0, RULE_transformation_expr = 1, RULE_transformation_entity = 2, 
-		RULE_func_args = 3, RULE_op_list = 4, RULE_list_entity = 5, RULE_identifier_operand = 6;
-	public static final String[] ruleNames = {
-		"transformation", "transformation_expr", "transformation_entity", "func_args", 
-		"op_list", "list_entity", "identifier_operand"
-	};
-
-	private static final String[] _LITERAL_NAMES = {
-		null, "','", "'['", "']'", "'('", "')'"
-	};
-	private static final String[] _SYMBOLIC_NAMES = {
-		null, "COMMA", "LBRACKET", "RBRACKET", "LPAREN", "RPAREN", "INT_LITERAL", 
-		"DOUBLE_LITERAL", "IDENTIFIER", "STRING_LITERAL", "COMMENT", "WS"
-	};
-	public static final Vocabulary VOCABULARY = new VocabularyImpl(_LITERAL_NAMES, _SYMBOLIC_NAMES);
-
-	/**
-	 * @deprecated Use {@link #VOCABULARY} instead.
-	 */
-	@Deprecated
-	public static final String[] tokenNames;
-	static {
-		tokenNames = new String[_SYMBOLIC_NAMES.length];
-		for (int i = 0; i < tokenNames.length; i++) {
-			tokenNames[i] = VOCABULARY.getLiteralName(i);
-			if (tokenNames[i] == null) {
-				tokenNames[i] = VOCABULARY.getSymbolicName(i);
-			}
-
-			if (tokenNames[i] == null) {
-				tokenNames[i] = "<INVALID>";
-			}
-		}
-	}
-
-	@Override
-	@Deprecated
-	public String[] getTokenNames() {
-		return tokenNames;
-	}
-
-	@Override
-
-	public Vocabulary getVocabulary() {
-		return VOCABULARY;
-	}
-
-	@Override
-	public String getGrammarFileName() { return "Transformation.g4"; }
-
-	@Override
-	public String[] getRuleNames() { return ruleNames; }
-
-	@Override
-	public String getSerializedATN() { return _serializedATN; }
-
-	@Override
-	public ATN getATN() { return _ATN; }
-
-	public TransformationParser(TokenStream input) {
-		super(input);
-		_interp = new ParserATNSimulator(this,_ATN,_decisionToDFA,_sharedContextCache);
-	}
-	public static class TransformationContext extends ParserRuleContext {
-		public Transformation_exprContext transformation_expr() {
-			return getRuleContext(Transformation_exprContext.class,0);
-		}
-		public TerminalNode EOF() { return getToken(TransformationParser.EOF, 0); }
-		public TransformationContext(ParserRuleContext parent, int invokingState) {
-			super(parent, invokingState);
-		}
-		@Override public int getRuleIndex() { return RULE_transformation; }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterTransformation(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitTransformation(this);
-		}
-	}
-
-	public final TransformationContext transformation() throws RecognitionException {
-		TransformationContext _localctx = new TransformationContext(_ctx, getState());
-		enterRule(_localctx, 0, RULE_transformation);
-		try {
-			enterOuterAlt(_localctx, 1);
-			{
-			setState(14);
-			transformation_expr();
-			setState(15);
-			match(EOF);
-			}
-		}
-		catch (RecognitionException re) {
-			_localctx.exception = re;
-			_errHandler.reportError(this, re);
-			_errHandler.recover(this, re);
-		}
-		finally {
-			exitRule();
-		}
-		return _localctx;
-	}
-
-	public static class Transformation_exprContext extends ParserRuleContext {
-		public Transformation_exprContext(ParserRuleContext parent, int invokingState) {
-			super(parent, invokingState);
-		}
-		@Override public int getRuleIndex() { return RULE_transformation_expr; }
-	 
-		public Transformation_exprContext() { }
-		public void copyFrom(Transformation_exprContext ctx) {
-			super.copyFrom(ctx);
-		}
-	}
-	public static class TransformationEntityContext extends Transformation_exprContext {
-		public Transformation_entityContext transformation_entity() {
-			return getRuleContext(Transformation_entityContext.class,0);
-		}
-		public TransformationEntityContext(Transformation_exprContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterTransformationEntity(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitTransformationEntity(this);
-		}
-	}
-	public static class TransformationExprContext extends Transformation_exprContext {
-		public TerminalNode LPAREN() { return getToken(TransformationParser.LPAREN, 0); }
-		public Transformation_exprContext transformation_expr() {
-			return getRuleContext(Transformation_exprContext.class,0);
-		}
-		public TerminalNode RPAREN() { return getToken(TransformationParser.RPAREN, 0); }
-		public TransformationExprContext(Transformation_exprContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterTransformationExpr(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitTransformationExpr(this);
-		}
-	}
-
-	public final Transformation_exprContext transformation_expr() throws RecognitionException {
-		Transformation_exprContext _localctx = new Transformation_exprContext(_ctx, getState());
-		enterRule(_localctx, 2, RULE_transformation_expr);
-		try {
-			setState(22);
-			switch (_input.LA(1)) {
-			case LPAREN:
-				_localctx = new TransformationExprContext(_localctx);
-				enterOuterAlt(_localctx, 1);
-				{
-				setState(17);
-				match(LPAREN);
-				setState(18);
-				transformation_expr();
-				setState(19);
-				match(RPAREN);
-				}
-				break;
-			case LBRACKET:
-			case INT_LITERAL:
-			case DOUBLE_LITERAL:
-			case IDENTIFIER:
-			case STRING_LITERAL:
-				_localctx = new TransformationEntityContext(_localctx);
-				enterOuterAlt(_localctx, 2);
-				{
-				setState(21);
-				transformation_entity();
-				}
-				break;
-			default:
-				throw new NoViableAltException(this);
-			}
-		}
-		catch (RecognitionException re) {
-			_localctx.exception = re;
-			_errHandler.reportError(this, re);
-			_errHandler.recover(this, re);
-		}
-		finally {
-			exitRule();
-		}
-		return _localctx;
-	}
-
-	public static class Transformation_entityContext extends ParserRuleContext {
-		public Identifier_operandContext identifier_operand() {
-			return getRuleContext(Identifier_operandContext.class,0);
-		}
-		public Transformation_entityContext(ParserRuleContext parent, int invokingState) {
-			super(parent, invokingState);
-		}
-		@Override public int getRuleIndex() { return RULE_transformation_entity; }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterTransformation_entity(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitTransformation_entity(this);
-		}
-	}
-
-	public final Transformation_entityContext transformation_entity() throws RecognitionException {
-		Transformation_entityContext _localctx = new Transformation_entityContext(_ctx, getState());
-		enterRule(_localctx, 4, RULE_transformation_entity);
-		try {
-			enterOuterAlt(_localctx, 1);
-			{
-			setState(24);
-			identifier_operand();
-			}
-		}
-		catch (RecognitionException re) {
-			_localctx.exception = re;
-			_errHandler.reportError(this, re);
-			_errHandler.recover(this, re);
-		}
-		finally {
-			exitRule();
-		}
-		return _localctx;
-	}
-
-	public static class Func_argsContext extends ParserRuleContext {
-		public Op_listContext op_list() {
-			return getRuleContext(Op_listContext.class,0);
-		}
-		public Func_argsContext(ParserRuleContext parent, int invokingState) {
-			super(parent, invokingState);
-		}
-		@Override public int getRuleIndex() { return RULE_func_args; }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterFunc_args(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitFunc_args(this);
-		}
-	}
-
-	public final Func_argsContext func_args() throws RecognitionException {
-		Func_argsContext _localctx = new Func_argsContext(_ctx, getState());
-		enterRule(_localctx, 6, RULE_func_args);
-		try {
-			enterOuterAlt(_localctx, 1);
-			{
-			setState(26);
-			op_list(0);
-			}
-		}
-		catch (RecognitionException re) {
-			_localctx.exception = re;
-			_errHandler.reportError(this, re);
-			_errHandler.recover(this, re);
-		}
-		finally {
-			exitRule();
-		}
-		return _localctx;
-	}
-
-	public static class Op_listContext extends ParserRuleContext {
-		public Identifier_operandContext identifier_operand() {
-			return getRuleContext(Identifier_operandContext.class,0);
-		}
-		public Op_listContext op_list() {
-			return getRuleContext(Op_listContext.class,0);
-		}
-		public TerminalNode COMMA() { return getToken(TransformationParser.COMMA, 0); }
-		public Op_listContext(ParserRuleContext parent, int invokingState) {
-			super(parent, invokingState);
-		}
-		@Override public int getRuleIndex() { return RULE_op_list; }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterOp_list(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitOp_list(this);
-		}
-	}
-
-	public final Op_listContext op_list() throws RecognitionException {
-		return op_list(0);
-	}
-
-	private Op_listContext op_list(int _p) throws RecognitionException {
-		ParserRuleContext _parentctx = _ctx;
-		int _parentState = getState();
-		Op_listContext _localctx = new Op_listContext(_ctx, _parentState);
-		Op_listContext _prevctx = _localctx;
-		int _startState = 8;
-		enterRecursionRule(_localctx, 8, RULE_op_list, _p);
-		try {
-			int _alt;
-			enterOuterAlt(_localctx, 1);
-			{
-			{
-			setState(29);
-			identifier_operand();
-			}
-			_ctx.stop = _input.LT(-1);
-			setState(36);
-			_errHandler.sync(this);
-			_alt = getInterpreter().adaptivePredict(_input,1,_ctx);
-			while ( _alt!=2 && _alt!=org.antlr.v4.runtime.atn.ATN.INVALID_ALT_NUMBER ) {
-				if ( _alt==1 ) {
-					if ( _parseListeners!=null ) triggerExitRuleEvent();
-					_prevctx = _localctx;
-					{
-					{
-					_localctx = new Op_listContext(_parentctx, _parentState);
-					pushNewRecursionContext(_localctx, _startState, RULE_op_list);
-					setState(31);
-					if (!(precpred(_ctx, 1))) throw new FailedPredicateException(this, "precpred(_ctx, 1)");
-					setState(32);
-					match(COMMA);
-					setState(33);
-					identifier_operand();
-					}
-					} 
-				}
-				setState(38);
-				_errHandler.sync(this);
-				_alt = getInterpreter().adaptivePredict(_input,1,_ctx);
-			}
-			}
-		}
-		catch (RecognitionException re) {
-			_localctx.exception = re;
-			_errHandler.reportError(this, re);
-			_errHandler.recover(this, re);
-		}
-		finally {
-			unrollRecursionContexts(_parentctx);
-		}
-		return _localctx;
-	}
-
-	public static class List_entityContext extends ParserRuleContext {
-		public TerminalNode LBRACKET() { return getToken(TransformationParser.LBRACKET, 0); }
-		public Op_listContext op_list() {
-			return getRuleContext(Op_listContext.class,0);
-		}
-		public TerminalNode RBRACKET() { return getToken(TransformationParser.RBRACKET, 0); }
-		public List_entityContext(ParserRuleContext parent, int invokingState) {
-			super(parent, invokingState);
-		}
-		@Override public int getRuleIndex() { return RULE_list_entity; }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterList_entity(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitList_entity(this);
-		}
-	}
-
-	public final List_entityContext list_entity() throws RecognitionException {
-		List_entityContext _localctx = new List_entityContext(_ctx, getState());
-		enterRule(_localctx, 10, RULE_list_entity);
-		try {
-			enterOuterAlt(_localctx, 1);
-			{
-			setState(39);
-			match(LBRACKET);
-			setState(40);
-			op_list(0);
-			setState(41);
-			match(RBRACKET);
-			}
-		}
-		catch (RecognitionException re) {
-			_localctx.exception = re;
-			_errHandler.reportError(this, re);
-			_errHandler.recover(this, re);
-		}
-		finally {
-			exitRule();
-		}
-		return _localctx;
-	}
-
-	public static class Identifier_operandContext extends ParserRuleContext {
-		public Identifier_operandContext(ParserRuleContext parent, int invokingState) {
-			super(parent, invokingState);
-		}
-		@Override public int getRuleIndex() { return RULE_identifier_operand; }
-	 
-		public Identifier_operandContext() { }
-		public void copyFrom(Identifier_operandContext ctx) {
-			super.copyFrom(ctx);
-		}
-	}
-	public static class VariableContext extends Identifier_operandContext {
-		public TerminalNode IDENTIFIER() { return getToken(TransformationParser.IDENTIFIER, 0); }
-		public VariableContext(Identifier_operandContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterVariable(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitVariable(this);
-		}
-	}
-	public static class StringLiteralContext extends Identifier_operandContext {
-		public TerminalNode STRING_LITERAL() { return getToken(TransformationParser.STRING_LITERAL, 0); }
-		public StringLiteralContext(Identifier_operandContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterStringLiteral(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitStringLiteral(this);
-		}
-	}
-	public static class TransformationFuncContext extends Identifier_operandContext {
-		public TerminalNode IDENTIFIER() { return getToken(TransformationParser.IDENTIFIER, 0); }
-		public TerminalNode LPAREN() { return getToken(TransformationParser.LPAREN, 0); }
-		public Func_argsContext func_args() {
-			return getRuleContext(Func_argsContext.class,0);
-		}
-		public TerminalNode RPAREN() { return getToken(TransformationParser.RPAREN, 0); }
-		public TransformationFuncContext(Identifier_operandContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterTransformationFunc(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitTransformationFunc(this);
-		}
-	}
-	public static class ListContext extends Identifier_operandContext {
-		public List_entityContext list_entity() {
-			return getRuleContext(List_entityContext.class,0);
-		}
-		public ListContext(Identifier_operandContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterList(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitList(this);
-		}
-	}
-	public static class DoubleLiteralContext extends Identifier_operandContext {
-		public TerminalNode DOUBLE_LITERAL() { return getToken(TransformationParser.DOUBLE_LITERAL, 0); }
-		public DoubleLiteralContext(Identifier_operandContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterDoubleLiteral(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitDoubleLiteral(this);
-		}
-	}
-	public static class IntegerLiteralContext extends Identifier_operandContext {
-		public TerminalNode INT_LITERAL() { return getToken(TransformationParser.INT_LITERAL, 0); }
-		public IntegerLiteralContext(Identifier_operandContext ctx) { copyFrom(ctx); }
-		@Override
-		public void enterRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).enterIntegerLiteral(this);
-		}
-		@Override
-		public void exitRule(ParseTreeListener listener) {
-			if ( listener instanceof TransformationListener ) ((TransformationListener)listener).exitIntegerLiteral(this);
-		}
-	}
-
-	public final Identifier_operandContext identifier_operand() throws RecognitionException {
-		Identifier_operandContext _localctx = new Identifier_operandContext(_ctx, getState());
-		enterRule(_localctx, 12, RULE_identifier_operand);
-		try {
-			setState(53);
-			switch ( getInterpreter().adaptivePredict(_input,2,_ctx) ) {
-			case 1:
-				_localctx = new StringLiteralContext(_localctx);
-				enterOuterAlt(_localctx, 1);
-				{
-				setState(43);
-				match(STRING_LITERAL);
-				}
-				break;
-			case 2:
-				_localctx = new IntegerLiteralContext(_localctx);
-				enterOuterAlt(_localctx, 2);
-				{
-				setState(44);
-				match(INT_LITERAL);
-				}
-				break;
-			case 3:
-				_localctx = new DoubleLiteralContext(_localctx);
-				enterOuterAlt(_localctx, 3);
-				{
-				setState(45);
-				match(DOUBLE_LITERAL);
-				}
-				break;
-			case 4:
-				_localctx = new VariableContext(_localctx);
-				enterOuterAlt(_localctx, 4);
-				{
-				setState(46);
-				match(IDENTIFIER);
-				}
-				break;
-			case 5:
-				_localctx = new TransformationFuncContext(_localctx);
-				enterOuterAlt(_localctx, 5);
-				{
-				setState(47);
-				match(IDENTIFIER);
-				setState(48);
-				match(LPAREN);
-				setState(49);
-				func_args();
-				setState(50);
-				match(RPAREN);
-				}
-				break;
-			case 6:
-				_localctx = new ListContext(_localctx);
-				enterOuterAlt(_localctx, 6);
-				{
-				setState(52);
-				list_entity();
-				}
-				break;
-			}
-		}
-		catch (RecognitionException re) {
-			_localctx.exception = re;
-			_errHandler.reportError(this, re);
-			_errHandler.recover(this, re);
-		}
-		finally {
-			exitRule();
-		}
-		return _localctx;
-	}
-
-	public boolean sempred(RuleContext _localctx, int ruleIndex, int predIndex) {
-		switch (ruleIndex) {
-		case 4:
-			return op_list_sempred((Op_listContext)_localctx, predIndex);
-		}
-		return true;
-	}
-	private boolean op_list_sempred(Op_listContext _localctx, int predIndex) {
-		switch (predIndex) {
-		case 0:
-			return precpred(_ctx, 1);
-		}
-		return true;
-	}
-
-	public static final String _serializedATN =
-		"\3\u0430\ud6d1\u8206\uad2d\u4417\uaef1\u8d80\uaadd\3\r:\4\2\t\2\4\3\t"+
-		"\3\4\4\t\4\4\5\t\5\4\6\t\6\4\7\t\7\4\b\t\b\3\2\3\2\3\2\3\3\3\3\3\3\3\3"+
-		"\3\3\5\3\31\n\3\3\4\3\4\3\5\3\5\3\6\3\6\3\6\3\6\3\6\3\6\7\6%\n\6\f\6\16"+
-		"\6(\13\6\3\7\3\7\3\7\3\7\3\b\3\b\3\b\3\b\3\b\3\b\3\b\3\b\3\b\3\b\5\b8"+
-		"\n\b\3\b\2\3\n\t\2\4\6\b\n\f\16\2\29\2\20\3\2\2\2\4\30\3\2\2\2\6\32\3"+
-		"\2\2\2\b\34\3\2\2\2\n\36\3\2\2\2\f)\3\2\2\2\16\67\3\2\2\2\20\21\5\4\3"+
-		"\2\21\22\7\2\2\3\22\3\3\2\2\2\23\24\7\6\2\2\24\25\5\4\3\2\25\26\7\7\2"+
-		"\2\26\31\3\2\2\2\27\31\5\6\4\2\30\23\3\2\2\2\30\27\3\2\2\2\31\5\3\2\2"+
-		"\2\32\33\5\16\b\2\33\7\3\2\2\2\34\35\5\n\6\2\35\t\3\2\2\2\36\37\b\6\1"+
-		"\2\37 \5\16\b\2 &\3\2\2\2!\"\f\3\2\2\"#\7\3\2\2#%\5\16\b\2$!\3\2\2\2%"+
-		"(\3\2\2\2&$\3\2\2\2&\'\3\2\2\2\'\13\3\2\2\2(&\3\2\2\2)*\7\4\2\2*+\5\n"+
-		"\6\2+,\7\5\2\2,\r\3\2\2\2-8\7\13\2\2.8\7\b\2\2/8\7\t\2\2\608\7\n\2\2\61"+
-		"\62\7\n\2\2\62\63\7\6\2\2\63\64\5\b\5\2\64\65\7\7\2\2\658\3\2\2\2\668"+
-		"\5\f\7\2\67-\3\2\2\2\67.\3\2\2\2\67/\3\2\2\2\67\60\3\2\2\2\67\61\3\2\2"+
-		"\2\67\66\3\2\2\28\17\3\2\2\2\5\30&\67";
-	public static final ATN _ATN =
-		new ATNDeserializer().deserialize(_serializedATN.toCharArray());
-	static {
-		_decisionToDFA = new DFA[_ATN.getNumberOfDecisions()];
-		for (int i = 0; i < _ATN.getNumberOfDecisions(); i++) {
-			_decisionToDFA[i] = new DFA(_ATN.getDecisionState(i), i);
-		}
-	}
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/MTLTransformationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/MTLTransformationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/MTLTransformationTest.java
deleted file mode 100644
index 53373dd..0000000
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/MTLTransformationTest.java
+++ /dev/null
@@ -1,167 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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 org.apache.metron.common.field.transformation;
-
-import com.google.common.collect.Iterables;
-import org.adrianwalker.multilinestring.Multiline;
-import org.apache.hadoop.hbase.util.Bytes;
-import org.apache.metron.common.configuration.FieldTransformer;
-import org.apache.metron.common.configuration.SensorParserConfig;
-import org.json.simple.JSONObject;
-import org.junit.Assert;
-import org.junit.Test;
-
-import java.util.HashMap;
-
-public class MTLTransformationTest {
-  /**
-   {
-    "fieldTransformations" : [
-          {
-           "transformation" : "MTL"
-          ,"output" : "utc_timestamp"
-          ,"config" : {
-            "utc_timestamp" : "TO_EPOCH_TIMESTAMP(timestamp, 'yyyy-MM-dd HH:mm:ss', 'UTC')"
-                      }
-          }
-                      ]
-   }
-   */
-  @Multiline
-  public static String mtlConfig;
-  /**
-   * Test the happy path.  This ensures that a simple transformation, converting a timestamp in a yyyy-MM-dd HH:mm:ss
-   * format can be converted to the expected UTC MS since Epoch.
-   */
-  @Test
-  public void testMTL() throws Exception {
-
-    SensorParserConfig c = SensorParserConfig.fromBytes(Bytes.toBytes(mtlConfig));
-    FieldTransformer handler = Iterables.getFirst(c.getFieldTransformations(), null);
-    JSONObject input = new JSONObject(new HashMap<String, Object>() {{
-      put("timestamp", "2016-01-05 17:02:30");
-    }});
-    handler.transformAndUpdate(input, new HashMap<>());
-    long expected = 1452013350000L;
-    Assert.assertEquals(expected, input.get("utc_timestamp"));
-    Assert.assertTrue(input.containsKey("timestamp"));
-  }
-  /**
-   * Ensures that if we try to transform with a field which does not exist, it does not
-   * 1. throw an exception
-   * 2. do any transformation.
-   */
-  @Test
-  public void testMTL_negative() throws Exception {
-
-    SensorParserConfig c = SensorParserConfig.fromBytes(Bytes.toBytes(mtlConfig));
-    FieldTransformer handler = Iterables.getFirst(c.getFieldTransformations(), null);
-    //no input fields => no transformation
-    JSONObject input = new JSONObject(new HashMap<String, Object>() {{
-    }});
-    handler.transformAndUpdate(input, new HashMap<>());
-    Assert.assertFalse(input.containsKey("utc_timestamp"));
-    Assert.assertTrue(input.isEmpty());
-  }
-
-  /**
-   {
-    "fieldTransformations" : [
-          {
-           "transformation" : "MTL"
-          ,"output" : [ "utc_timestamp", "url_host", "url_protocol" ]
-          ,"config" : {
-            "utc_timestamp" : "TO_EPOCH_TIMESTAMP(timestamp, 'yyyy-MM-dd HH:mm:ss', MAP_GET(dc, dc2tz, 'UTC') )"
-           ,"url_host" : "TO_LOWER(URL_TO_HOST(url))"
-           ,"url_protocol" : "URL_TO_PROTOCOL(url)"
-                      }
-          }
-                      ]
-   ,"parserConfig" : {
-      "dc2tz" : {
-                "nyc" : "EST"
-               ,"la" : "PST"
-               ,"london" : "UTC"
-                }
-    }
-   }
-   */
-  @Multiline
-  public static String mtlConfig_multi;
-
-  /**
-   * A more complicated test where we are transforming multiple fields:
-   * 1. Convert a timestamp field in yyyy-MM-dd HH:mm:ss format to unix epoch while
-   *    looking up the timezone based on a second field, dc, in a map being kept in the parser config.
-   *    If the data center isn't in the map, then the default is UTC
-   * 2. Extract the host from a URL field and convert to lowercase
-   * 3. Extract the protocol of the URL field
-   **/
-  @Test
-  public void testMTL_multi() throws Exception {
-
-    SensorParserConfig c = SensorParserConfig.fromBytes(Bytes.toBytes(mtlConfig_multi));
-    FieldTransformer handler = Iterables.getFirst(c.getFieldTransformations(), null);
-    {
-      //We need a timestamp field, a URL field and a data center field
-      JSONObject input = new JSONObject(new HashMap<String, Object>() {{
-        put("timestamp", "2016-01-05 17:02:30");
-        put("url", "https://caseystella.com/blog");
-        //looking up the data center in portland, which doesn't exist in the map, so we default to UTC
-        put("dc", "portland");
-      }});
-      handler.transformAndUpdate(input, c.getParserConfig());
-      long expected = 1452013350000L;
-      Assert.assertEquals(expected, input.get("utc_timestamp"));
-      Assert.assertEquals("caseystella.com", input.get("url_host"));
-      Assert.assertEquals("https", input.get("url_protocol"));
-      Assert.assertTrue(input.containsKey("timestamp"));
-      Assert.assertTrue(input.containsKey("url"));
-    }
-    {
-      //now we see what happens when we change the data center to london, which is in the map
-      JSONObject input = new JSONObject(new HashMap<String, Object>() {{
-        put("timestamp", "2016-01-05 17:02:30");
-        put("url", "https://caseystella.com/blog");
-        put("dc", "london");
-      }});
-      handler.transformAndUpdate(input, c.getParserConfig());
-      long expected = 1452013350000L;
-      Assert.assertEquals(expected, input.get("utc_timestamp"));
-      Assert.assertEquals("caseystella.com", input.get("url_host"));
-      Assert.assertEquals("https", input.get("url_protocol"));
-      Assert.assertTrue(input.containsKey("timestamp"));
-      Assert.assertTrue(input.containsKey("url"));
-    }
-    //now we ensure that because we don't have a data center field at all, it's defaulted to UTC.
-    {
-      JSONObject input = new JSONObject(new HashMap<String, Object>() {{
-        put("timestamp", "2016-01-05 17:02:30");
-        put("url", "https://caseystella.com/blog");
-      }});
-      handler.transformAndUpdate(input, c.getParserConfig());
-      long expected = 1452013350000L;
-      Assert.assertEquals(expected, input.get("utc_timestamp"));
-      Assert.assertEquals("caseystella.com", input.get("url_host"));
-      Assert.assertEquals("https", input.get("url_protocol"));
-      Assert.assertTrue(input.containsKey("timestamp"));
-      Assert.assertTrue(input.containsKey("url"));
-    }
-  }
-}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/StellarTransformationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/StellarTransformationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/StellarTransformationTest.java
new file mode 100644
index 0000000..7cb1879
--- /dev/null
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/transformation/StellarTransformationTest.java
@@ -0,0 +1,167 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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 org.apache.metron.common.field.transformation;
+
+import com.google.common.collect.Iterables;
+import org.adrianwalker.multilinestring.Multiline;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.metron.common.configuration.FieldTransformer;
+import org.apache.metron.common.configuration.SensorParserConfig;
+import org.json.simple.JSONObject;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.util.HashMap;
+
+public class StellarTransformationTest {
+  /**
+   {
+    "fieldTransformations" : [
+          {
+           "transformation" : "STELLAR"
+          ,"output" : "utc_timestamp"
+          ,"config" : {
+            "utc_timestamp" : "TO_EPOCH_TIMESTAMP(timestamp, 'yyyy-MM-dd HH:mm:ss', 'UTC')"
+                      }
+          }
+                      ]
+   }
+   */
+  @Multiline
+  public static String stellarConfig;
+  /**
+   * Test the happy path.  This ensures that a simple transformation, converting a timestamp in a yyyy-MM-dd HH:mm:ss
+   * format can be converted to the expected UTC MS since Epoch.
+   */
+  @Test
+  public void testStellar() throws Exception {
+
+    SensorParserConfig c = SensorParserConfig.fromBytes(Bytes.toBytes(stellarConfig));
+    FieldTransformer handler = Iterables.getFirst(c.getFieldTransformations(), null);
+    JSONObject input = new JSONObject(new HashMap<String, Object>() {{
+      put("timestamp", "2016-01-05 17:02:30");
+    }});
+    handler.transformAndUpdate(input, new HashMap<>());
+    long expected = 1452013350000L;
+    Assert.assertEquals(expected, input.get("utc_timestamp"));
+    Assert.assertTrue(input.containsKey("timestamp"));
+  }
+  /**
+   * Ensures that if we try to transform with a field which does not exist, it does not
+   * 1. throw an exception
+   * 2. do any transformation.
+   */
+  @Test
+  public void testStellar_negative() throws Exception {
+
+    SensorParserConfig c = SensorParserConfig.fromBytes(Bytes.toBytes(stellarConfig));
+    FieldTransformer handler = Iterables.getFirst(c.getFieldTransformations(), null);
+    //no input fields => no transformation
+    JSONObject input = new JSONObject(new HashMap<String, Object>() {{
+    }});
+    handler.transformAndUpdate(input, new HashMap<>());
+    Assert.assertFalse(input.containsKey("utc_timestamp"));
+    Assert.assertTrue(input.isEmpty());
+  }
+
+  /**
+   {
+    "fieldTransformations" : [
+          {
+           "transformation" : "STELLAR"
+          ,"output" : [ "utc_timestamp", "url_host", "url_protocol" ]
+          ,"config" : {
+            "utc_timestamp" : "TO_EPOCH_TIMESTAMP(timestamp, 'yyyy-MM-dd HH:mm:ss', MAP_GET(dc, dc2tz, 'UTC') )"
+           ,"url_host" : "TO_LOWER(URL_TO_HOST(url))"
+           ,"url_protocol" : "URL_TO_PROTOCOL(url)"
+                      }
+          }
+                      ]
+   ,"parserConfig" : {
+      "dc2tz" : {
+                "nyc" : "EST"
+               ,"la" : "PST"
+               ,"london" : "UTC"
+                }
+    }
+   }
+   */
+  @Multiline
+  public static String stellarConfig_multi;
+
+  /**
+   * A more complicated test where we are transforming multiple fields:
+   * 1. Convert a timestamp field in yyyy-MM-dd HH:mm:ss format to unix epoch while
+   *    looking up the timezone based on a second field, dc, in a map being kept in the parser config.
+   *    If the data center isn't in the map, then the default is UTC
+   * 2. Extract the host from a URL field and convert to lowercase
+   * 3. Extract the protocol of the URL field
+   **/
+  @Test
+  public void testStellar_multi() throws Exception {
+
+    SensorParserConfig c = SensorParserConfig.fromBytes(Bytes.toBytes(stellarConfig_multi));
+    FieldTransformer handler = Iterables.getFirst(c.getFieldTransformations(), null);
+    {
+      //We need a timestamp field, a URL field and a data center field
+      JSONObject input = new JSONObject(new HashMap<String, Object>() {{
+        put("timestamp", "2016-01-05 17:02:30");
+        put("url", "https://caseystella.com/blog");
+        //looking up the data center in portland, which doesn't exist in the map, so we default to UTC
+        put("dc", "portland");
+      }});
+      handler.transformAndUpdate(input, c.getParserConfig());
+      long expected = 1452013350000L;
+      Assert.assertEquals(expected, input.get("utc_timestamp"));
+      Assert.assertEquals("caseystella.com", input.get("url_host"));
+      Assert.assertEquals("https", input.get("url_protocol"));
+      Assert.assertTrue(input.containsKey("timestamp"));
+      Assert.assertTrue(input.containsKey("url"));
+    }
+    {
+      //now we see what happens when we change the data center to london, which is in the map
+      JSONObject input = new JSONObject(new HashMap<String, Object>() {{
+        put("timestamp", "2016-01-05 17:02:30");
+        put("url", "https://caseystella.com/blog");
+        put("dc", "london");
+      }});
+      handler.transformAndUpdate(input, c.getParserConfig());
+      long expected = 1452013350000L;
+      Assert.assertEquals(expected, input.get("utc_timestamp"));
+      Assert.assertEquals("caseystella.com", input.get("url_host"));
+      Assert.assertEquals("https", input.get("url_protocol"));
+      Assert.assertTrue(input.containsKey("timestamp"));
+      Assert.assertTrue(input.containsKey("url"));
+    }
+    //now we ensure that because we don't have a data center field at all, it's defaulted to UTC.
+    {
+      JSONObject input = new JSONObject(new HashMap<String, Object>() {{
+        put("timestamp", "2016-01-05 17:02:30");
+        put("url", "https://caseystella.com/blog");
+      }});
+      handler.transformAndUpdate(input, c.getParserConfig());
+      long expected = 1452013350000L;
+      Assert.assertEquals(expected, input.get("utc_timestamp"));
+      Assert.assertEquals("caseystella.com", input.get("url_host"));
+      Assert.assertEquals("https", input.get("url_protocol"));
+      Assert.assertTrue(input.containsKey("timestamp"));
+      Assert.assertTrue(input.containsKey("url"));
+    }
+  }
+}

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/QueryValidationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/QueryValidationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/QueryValidationTest.java
index 79162dd..708a0be 100644
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/QueryValidationTest.java
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/QueryValidationTest.java
@@ -66,7 +66,7 @@ public class QueryValidationTest extends BaseValidationTest{
           {
            "validation" : "MQL"
           ,"config" : {
-              "condition" : "exi"
+              "condition" : "exi and "
                       }
           }
                          ]

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/DomainValidationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/DomainValidationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/DomainValidationTest.java
index de3cca5..88cf37b 100644
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/DomainValidationTest.java
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/DomainValidationTest.java
@@ -26,7 +26,7 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-import static org.apache.metron.common.query.QueryParserTest.run;
+import static org.apache.metron.common.stellar.StellarTest.runPredicate;
 
 public class DomainValidationTest extends BaseValidationTest{
   /**
@@ -60,30 +60,30 @@ public class DomainValidationTest extends BaseValidationTest{
   @Test
   public void positiveTest_single() throws IOException {
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "caseystella.com")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.com")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.com")));
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "www.hotmail.co.uk")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "www.hotmail.co.uk")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "www.hotmail.co.uk")));
   }
   @Test
   public void negativeTest_single() throws IOException {
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "foo")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "foo")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "foo")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "caseystella.turtle")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.turtle")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.turtle")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", 2.7f)));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", 2.7f)));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", 2.7f)));
   }
   @Test
   public void positiveTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field1", "www.gmail.com", "field2", "www.hotmail.com")));
-    Assert.assertTrue(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "www.gmail.com", "field2", "www.hotmail.com")));
+    Assert.assertTrue(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "www.gmail.com", "field2", "www.hotmail.com")));
   }
 
   @Test
   public void negativeTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field2", "hotmail.edu")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field2", "hotmail.edu")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field2", "hotmail.edu")));
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field1", "", "field2", "gmail.com")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", "gmail.com")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", "gmail.com")));
   }
 }

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/EmailValidationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/EmailValidationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/EmailValidationTest.java
index 22bdde8..c82fe0b 100644
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/EmailValidationTest.java
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/EmailValidationTest.java
@@ -26,7 +26,7 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-import static org.apache.metron.common.query.QueryParserTest.run;
+import static org.apache.metron.common.stellar.StellarTest.runPredicate;
 
 public class EmailValidationTest extends BaseValidationTest {
   /**
@@ -60,32 +60,32 @@ public class EmailValidationTest extends BaseValidationTest {
   @Test
   public void positiveTest_single() throws IOException {
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "me@caseystella.com")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "me@caseystella.com")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "me@caseystella.com")));
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "me@www.hotmail.co.uk")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "me@www.hotmail.co.uk")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "me@www.hotmail.co.uk")));
   }
   @Test
   public void negativeTest_single() throws IOException {
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "me@foo")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "me@foo")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "me@foo")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "caseystella.turtle")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.turtle")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.turtle")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "caseystella.com")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.com")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "caseystella.com")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", 2.7f)));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", 2.7f)));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", 2.7f)));
   }
   @Test
   public void positiveTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field1", "me@www.gmail.com", "field2", "me@www.hotmail.com")));
-    Assert.assertTrue(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "me@www.gmail.com", "field2", "me@www.hotmail.com")));
+    Assert.assertTrue(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "me@www.gmail.com", "field2", "me@www.hotmail.com")));
   }
 
   @Test
   public void negativeTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field2", "me@hotmail.edu")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field2", "me@hotmail.edu")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field2", "me@hotmail.edu")));
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field1", "", "field2", "me@gmail.com")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", "me@gmail.com")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", "me@gmail.com")));
   }
 }

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/IPValidationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/IPValidationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/IPValidationTest.java
index c0a043a..437f61b 100644
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/IPValidationTest.java
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/IPValidationTest.java
@@ -26,7 +26,7 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-import static org.apache.metron.common.query.QueryParserTest.run;
+import static org.apache.metron.common.stellar.StellarTest.runPredicate;
 
 public class IPValidationTest extends BaseValidationTest {
   /**
@@ -62,24 +62,24 @@ public class IPValidationTest extends BaseValidationTest {
   @Test
   public void positiveTest_single() throws IOException {
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "127.0.0.1")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "127.0.0.1")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "127.0.0.1")));
   }
   @Test
   public void negativeTest_single() throws IOException {
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "2014/05/01")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "2014/05/01")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "2014/05/01")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", 2.3f)));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", 2.3f)));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", 2.3f)));
   }
   @Test
   public void positiveTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field1", "192.168.0.1", "field2", "127.0.0.2")));
-    Assert.assertTrue(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "192.168.0.1", "field2", "127.0.0.2")));
+    Assert.assertTrue(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "192.168.0.1", "field2", "127.0.0.2")));
   }
 
   @Test
   public void negativeTest_multiple() throws IOException {
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field1", 1, "field2", "192.168.1")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", 1, "field2", "192.168.1")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", 1, "field2", "192.168.1")));
   }
 }

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/URLValidationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/URLValidationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/URLValidationTest.java
index 4eb5eee..70a69f8 100644
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/URLValidationTest.java
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/network/URLValidationTest.java
@@ -26,7 +26,7 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-import static org.apache.metron.common.query.QueryParserTest.run;
+import static org.apache.metron.common.stellar.StellarTest.runPredicate;
 
 public class URLValidationTest  extends BaseValidationTest {
   /**
@@ -60,32 +60,32 @@ public class URLValidationTest  extends BaseValidationTest {
   @Test
   public void positiveTest_single() throws IOException {
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "http://caseystella.com/foo")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "http://caseystella.com/foo")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "http://caseystella.com/foo")));
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "https://www.hotmail.co.uk")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "https://www.hotmail.co.uk")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "https://www.hotmail.co.uk")));
   }
 
 
   @Test
   public void negativeTest_single() throws IOException {
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "foo")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "foo")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "foo")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "http://caseystella.turtle")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "http://caseystella.turtle")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "http://caseystella.turtle")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", 2.7f)));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", 2.7f)));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", 2.7f)));
   }
   @Test
   public void positiveTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field1", "ftp://www.gmail.com", "field2", "http://www.hotmail.com")));
-    Assert.assertTrue(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "ftp://www.gmail.com", "field2", "http://www.hotmail.com")));
+    Assert.assertTrue(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "ftp://www.gmail.com", "field2", "http://www.hotmail.com")));
   }
 
   @Test
   public void negativeTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field2", "http://hotmail.edu")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field2", "http://hotmail.edu")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field2", "http://hotmail.edu")));
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field1", "", "field2", "http://gmail.com")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", "http://gmail.com")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", "http://gmail.com")));
   }
 }

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/DateValidationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/DateValidationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/DateValidationTest.java
index 4df8cdb..cacc997 100644
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/DateValidationTest.java
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/DateValidationTest.java
@@ -26,7 +26,7 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-import static org.apache.metron.common.query.QueryParserTest.run;
+import static org.apache.metron.common.stellar.StellarTest.runPredicate;
 
 public class DateValidationTest extends BaseValidationTest{
   /**
@@ -67,29 +67,29 @@ public class DateValidationTest extends BaseValidationTest{
   @Test
   public void positiveTest_single() throws IOException {
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "2014-05-01")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "2014-05-01")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "2014-05-01")));
   }
   @Test
   public void negativeTest_single() throws IOException {
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", 2.3f)));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", 2.3f)));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "2014/05/01")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "2014/05/01")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "2014/05/01")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", 2.3f)));
   }
   @Test
   public void positiveTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field1", "2014-06-01", "field2", "2014-06-02")));
-    Assert.assertTrue(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "2014-06-01", "field2", "2014-06-02")));
+    Assert.assertTrue(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "2014-06-01", "field2", "2014-06-02")));
   }
 
   @Test
   public void negativeTest_multiple() throws IOException {
 
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field2", "2014-06-02")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field2", "2014-06-02")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field2", "2014-06-02")));
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field1", 1, "field2", "2014-06-02")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", 1, "field2", "2014-06-02")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", 1, "field2", "2014-06-02")));
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field3", "2014-06-02")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field3", "2014-06-02")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field3", "2014-06-02")));
   }
 }

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/IntegerValidationTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/IntegerValidationTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/IntegerValidationTest.java
index ebbca66..c89d786 100644
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/IntegerValidationTest.java
+++ b/metron-platform/metron-common/src/test/java/org/apache/metron/common/field/validation/primitive/IntegerValidationTest.java
@@ -26,7 +26,7 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-import static org.apache.metron.common.query.QueryParserTest.run;
+import static org.apache.metron.common.stellar.StellarTest.runPredicate;
 
 public class IntegerValidationTest extends BaseValidationTest{
   /**
@@ -60,31 +60,31 @@ public class IntegerValidationTest extends BaseValidationTest{
   @Test
   public void positiveTest_single() throws IOException {
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", 1)));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", 1)));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", 1)));
     Assert.assertTrue(execute(validWithSingleField, ImmutableMap.of("field1", "1")));
-    Assert.assertTrue(run(validWithSingleField_MQL, ImmutableMap.of("field1", "1")));
+    Assert.assertTrue(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "1")));
   }
   @Test
   public void negativeTest_single() throws IOException {
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", "foo")));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", "foo")));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", "foo")));
     Assert.assertFalse(execute(validWithSingleField, ImmutableMap.of("field1", 2.3f)));
-    Assert.assertFalse(run(validWithSingleField_MQL, ImmutableMap.of("field1", 2.3f)));
+    Assert.assertFalse(runPredicate(validWithSingleField_MQL, ImmutableMap.of("field1", 2.3f)));
   }
   @Test
   public void positiveTest_multiple() throws IOException {
     Assert.assertTrue(execute(validWithMultipleFields, ImmutableMap.of("field1", 1, "field2", "2")));
-    Assert.assertTrue(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", 1, "field2", "2")));
+    Assert.assertTrue(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", 1, "field2", "2")));
   }
 
   @Test
   public void negativeTest_multiple() throws IOException {
 
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field2", "foo")));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field2", "foo")));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field2", "foo")));
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field1", "", "field2", 1)));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", 1)));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", "", "field2", 1)));
     Assert.assertFalse(execute(validWithMultipleFields, ImmutableMap.of("field1", " ", "field2", 2)));
-    Assert.assertFalse(run(validWithMultipleFields_MQL, ImmutableMap.of("field1", " ", "field2", 2)));
+    Assert.assertFalse(runPredicate(validWithMultipleFields_MQL, ImmutableMap.of("field1", " ", "field2", 2)));
   }
 }

http://git-wip-us.apache.org/repos/asf/incubator-metron/blob/93054463/metron-platform/metron-common/src/test/java/org/apache/metron/common/query/QueryParserTest.java
----------------------------------------------------------------------
diff --git a/metron-platform/metron-common/src/test/java/org/apache/metron/common/query/QueryParserTest.java b/metron-platform/metron-common/src/test/java/org/apache/metron/common/query/QueryParserTest.java
deleted file mode 100644
index 94236dd..0000000
--- a/metron-platform/metron-common/src/test/java/org/apache/metron/common/query/QueryParserTest.java
+++ /dev/null
@@ -1,223 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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 org.apache.metron.common.query;
-
-import com.google.common.collect.ImmutableList;
-import com.google.common.collect.ImmutableMap;
-import org.apache.metron.common.dsl.MapVariableResolver;
-import org.apache.metron.common.dsl.ParseException;
-import org.apache.metron.common.dsl.VariableResolver;
-import org.junit.Assert;
-import org.junit.Test;
-
-import java.util.HashMap;
-import java.util.Map;
-
-public class QueryParserTest {
-
-  @Test
-  public void testValidation() throws Exception {
-    PredicateProcessor processor = new PredicateProcessor();
-    try {
-      processor.validate("'foo'");
-      Assert.fail("Invalid rule found to be valid - lone value.");
-    }
-    catch(ParseException e) {
-
-    }
-    try {
-      processor.validate("enrichedField1 == 'enrichedValue1");
-      Assert.fail("Invalid rule found to be valid - unclosed single quotes.");
-    }
-    catch(ParseException e) {
-
-    }
-  }
-
-  public static boolean run(String rule, Map resolver) {
-    return run(rule, new MapVariableResolver(resolver));
-  }
-  public static boolean run(String rule, VariableResolver resolver) {
-    PredicateProcessor processor = new PredicateProcessor();
-    Assert.assertTrue(rule + " not valid.", processor.validate(rule));
-    return processor.parse(rule, resolver);
-  }
-
-  @Test
-  public void testSimpleOps() throws Exception {
-    final Map<String, String> variableMap = new HashMap<String, String>() {{
-      put("foo", "casey");
-      put("empty", "");
-      put("spaced", "metron is great");
-      put("foo.bar", "casey");
-    }};
-    Assert.assertTrue(run("'casey' == foo.bar", v -> variableMap.get(v)));
-    Assert.assertTrue(run("'casey' == foo", v -> variableMap.get(v)));
-    Assert.assertFalse(run("'casey' != foo", v -> variableMap.get(v)));
-    Assert.assertTrue(run("'stella' == 'stella'", v -> variableMap.get(v)));
-    Assert.assertFalse(run("'stella' == foo", v -> variableMap.get(v)));
-    Assert.assertTrue(run("foo== foo", v -> variableMap.get(v)));
-    Assert.assertTrue(run("empty== ''", v -> variableMap.get(v)));
-    Assert.assertTrue(run("spaced == 'metron is great'", v -> variableMap.get(v)));
-    Assert.assertTrue(run(null, v -> variableMap.get(v)));
-    Assert.assertTrue(run("", v -> variableMap.get(v)));
-    Assert.assertTrue(run(" ", v -> variableMap.get(v)));
-  }
-
-  @Test
-  public void testBooleanOps() throws Exception {
-    final Map<String, String> variableMap = new HashMap<String, String>() {{
-      put("foo", "casey");
-      put("empty", "");
-      put("spaced", "metron is great");
-    }};
-    Assert.assertFalse(run("not('casey' == foo and true)", v -> variableMap.get(v)));
-    Assert.assertTrue(run("not(not('casey' == foo and true))", v -> variableMap.get(v)));
-    Assert.assertTrue(run("('casey' == foo) && ( false != true )", v -> variableMap.get(v)));
-    Assert.assertFalse(run("('casey' == foo) and (FALSE == TRUE)", v -> variableMap.get(v)));
-    Assert.assertFalse(run("'casey' == foo and FALSE", v -> variableMap.get(v)));
-    Assert.assertTrue(run("'casey' == foo and true", v -> variableMap.get(v)));
-    Assert.assertTrue(run("true", v -> variableMap.get(v)));
-    Assert.assertTrue(run("TRUE", v -> variableMap.get(v)));
-  }
-
-  @Test
-  public void testList() throws Exception {
-    final Map<String, String> variableMap = new HashMap<String, String>() {{
-      put("foo", "casey");
-      put("empty", "");
-      put("spaced", "metron is great");
-    }};
-    Assert.assertTrue(run("foo in [ 'casey', 'david' ]", v -> variableMap.get(v)));
-    Assert.assertTrue(run("foo in [ foo, 'david' ]", v -> variableMap.get(v)));
-    Assert.assertTrue(run("foo in [ 'casey', 'david' ] and 'casey' == foo", v -> variableMap.get(v)));
-    Assert.assertTrue(run("foo in [ 'casey', 'david' ] and foo == 'casey'", v -> variableMap.get(v)));
-    Assert.assertTrue(run("foo in [ 'casey' ]", v -> variableMap.get(v)));
-    Assert.assertFalse(run("foo not in [ 'casey', 'david' ]", v -> variableMap.get(v)));
-    Assert.assertFalse(run("foo not in [ 'casey', 'david' ] and 'casey' == foo", v -> variableMap.get(v)));
-  }
-
-  @Test
-  public void testExists() throws Exception {
-    final Map<String, String> variableMap = new HashMap<String, String>() {{
-      put("foo", "casey");
-      put("empty", "");
-      put("spaced", "metron is great");
-    }};
-    Assert.assertTrue(run("exists(foo)", v -> variableMap.get(v)));
-    Assert.assertFalse(run("exists(bar)", v -> variableMap.get(v)));
-    Assert.assertTrue(run("exists(bar) or true", v -> variableMap.get(v)));
-  }
-
-  @Test
-  public void testStringFunctions() throws Exception {
-    final Map<String, String> variableMap = new HashMap<String, String>() {{
-      put("foo", "casey");
-      put("ip", "192.168.0.1");
-      put("empty", "");
-      put("spaced", "metron is great");
-    }};
-    Assert.assertTrue(run("true and TO_UPPER(foo) == 'CASEY'", v -> variableMap.get(v)));
-    Assert.assertTrue(run("foo in [ TO_LOWER('CASEY'), 'david' ]", v -> variableMap.get(v)));
-    Assert.assertTrue(run("TO_UPPER(foo) in [ TO_UPPER('casey'), 'david' ] and IN_SUBNET(ip, '192.168.0.0/24')", v -> variableMap.get(v)));
-    Assert.assertFalse(run("TO_LOWER(foo) in [ TO_UPPER('casey'), 'david' ]", v -> variableMap.get(v)));
-  }
-
-  @Test
-  public void testStringFunctions_advanced() throws Exception {
-    final Map<String, Object> variableMap = new HashMap<String, Object>() {{
-      put("foo", "casey");
-      put("bar", "bar.casey.grok");
-      put("ip", "192.168.0.1");
-      put("empty", "");
-      put("spaced", "metron is great");
-      put("myList", ImmutableList.of("casey", "apple", "orange"));
-    }};
-    Assert.assertTrue(run("foo in SPLIT(bar, '.')", v -> variableMap.get(v)));
-    Assert.assertFalse(run("foo in SPLIT(ip, '.')", v -> variableMap.get(v)));
-    Assert.assertTrue(run("foo in myList", v -> variableMap.get(v)));
-    Assert.assertFalse(run("foo not in myList", v -> variableMap.get(v)));
-  }
-
-  @Test
-  public void testMapFunctions_advanced() throws Exception {
-    final Map<String, Object> variableMap = new HashMap<String, Object>() {{
-      put("foo", "casey");
-      put("bar", "bar.casey.grok");
-      put("ip", "192.168.0.1");
-      put("empty", "");
-      put("spaced", "metron is great");
-      put("myMap", ImmutableMap.of("casey", "apple"));
-    }};
-    Assert.assertTrue(run("MAP_EXISTS(foo, myMap)", v -> variableMap.get(v)));
-  }
-
-  @Test
-  public void testNumericComparisonFunctions() throws Exception {
-    final Map<String, Object> variableMap = new HashMap<String, Object>() {{
-      put("foo", "casey");
-      put("bar", "bar.casey.grok");
-      put("ip", "192.168.0.1");
-      put("num", 7);
-      put("num2", 8.5);
-      put("num3", 7);
-      put("num4", "8.5");
-      put("empty", "");
-      put("spaced", "metron is great");
-    }};
-    Assert.assertTrue(run("num == 7", v -> variableMap.get(v)));
-    Assert.assertTrue(run("num < num2", v -> variableMap.get(v)));
-    Assert.assertTrue(run("num < TO_DOUBLE(num2)", v -> variableMap.get(v)));
-    Assert.assertTrue(run("num < TO_DOUBLE(num4)", v -> variableMap.get(v)));
-    Assert.assertTrue(run("num < 100", v -> variableMap.get(v)));
-    Assert.assertTrue(run("num == num3", v -> variableMap.get(v)));
-    Assert.assertFalse(run("num == num2", v -> variableMap.get(v)));
-    Assert.assertTrue(run("num == num2 || true", v -> variableMap.get(v)));
-    Assert.assertFalse(run("num > num2", v -> variableMap.get(v)));
-    Assert.assertTrue(run("num == 7 && num > 2", v -> variableMap.get(v)));
-  }
-  @Test
-  public void testLogicalFunctions() throws Exception {
-    final Map<String, String> variableMap = new HashMap<String, String>() {{
-      put("foo", "casey");
-      put("ip", "192.168.0.1");
-      put("ip_src_addr", "192.168.0.1");
-      put("ip_dst_addr", "10.0.0.1");
-      put("other_ip", "10.168.0.1");
-      put("empty", "");
-      put("spaced", "metron is great");
-    }};
-    Assert.assertTrue(run("IN_SUBNET(ip, '192.168.0.0/24')", v -> variableMap.get(v)));
-    Assert.assertTrue(run("IN_SUBNET(ip, '192.168.0.0/24', '11.0.0.0/24')", v -> variableMap.get(v)));
-    Assert.assertFalse(run("IN_SUBNET(ip_dst_addr, '192.168.0.0/24', '11.0.0.0/24')", v -> variableMap.get(v)));
-    Assert.assertFalse(run("IN_SUBNET(other_ip, '192.168.0.0/24')", v -> variableMap.get(v)));
-    Assert.assertFalse(run("IN_SUBNET(blah, '192.168.0.0/24')", v -> variableMap.get(v)));
-    Assert.assertTrue(run("true and STARTS_WITH(foo, 'ca')", v -> variableMap.get(v)));
-    Assert.assertTrue(run("true and STARTS_WITH(TO_UPPER(foo), 'CA')", v -> variableMap.get(v)));
-    Assert.assertTrue(run("(true and STARTS_WITH(TO_UPPER(foo), 'CA')) || true", v -> variableMap.get(v)));
-    Assert.assertTrue(run("true and ENDS_WITH(foo, 'sey')", v -> variableMap.get(v)));
-    Assert.assertTrue(run("not(IN_SUBNET(ip_src_addr, '192.168.0.0/24') and IN_SUBNET(ip_dst_addr, '192.168.0.0/24'))", v-> variableMap.get(v)));
-    Assert.assertTrue(run("IN_SUBNET(ip_src_addr, '192.168.0.0/24')", v-> variableMap.get(v)));
-    Assert.assertFalse(run("not(IN_SUBNET(ip_src_addr, '192.168.0.0/24'))", v-> variableMap.get(v)));
-    Assert.assertFalse(run("IN_SUBNET(ip_dst_addr, '192.168.0.0/24')", v-> variableMap.get(v)));
-    Assert.assertTrue(run("not(IN_SUBNET(ip_dst_addr, '192.168.0.0/24'))", v-> variableMap.get(v)));
-  }
-
-
-}



Mime
View raw message