streamBuilder.addField(new TypedField(leftFieldName, Type.getPrimitive(Type.TypeName.INT)));
streamBuilder.addField(new TypedField(rightFieldName, Type.getPrimitive(Type.TypeName.INT)));
streamBuilder.addEvent("1,-1");
streamBuilder.addEvent("2,-2");
streamBuilder.addEvent("3,-3");
StreamSymbol stream = streamBuilder.build();
getSymbolTable().addSymbol(stream);
getConf().set(SelectStmt.CLIENT_SELECT_TARGET_KEY, "testSelect");
// With all configuration complete, connect to the environment.