001/* 002 * Copyright (c) 2016 Chris K Wensel <chris@wensel.net>. All Rights Reserved. 003 * Copyright (c) 2007-2017 Xplenty, Inc. All Rights Reserved. 004 * 005 * Project and contact information: http://www.cascading.org/ 006 * 007 * This file is part of the Cascading project. 008 * 009 * Licensed under the Apache License, Version 2.0 (the "License"); 010 * you may not use this file except in compliance with the License. 011 * You may obtain a copy of the License at 012 * 013 * http://www.apache.org/licenses/LICENSE-2.0 014 * 015 * Unless required by applicable law or agreed to in writing, software 016 * distributed under the License is distributed on an "AS IS" BASIS, 017 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 018 * See the License for the specific language governing permissions and 019 * limitations under the License. 020 */ 021 022package cascading.flow.planner.rule.expressiongraph; 023 024import cascading.flow.planner.graph.Extent; 025import cascading.flow.planner.iso.expression.AnnotationExpression; 026import cascading.flow.planner.iso.expression.ElementCapture; 027import cascading.flow.planner.iso.expression.ExpressionGraph; 028import cascading.flow.planner.iso.expression.FlowElementExpression; 029import cascading.flow.stream.annotations.RoleMode; 030import cascading.pipe.Boundary; 031import cascading.pipe.Group; 032import cascading.pipe.HashJoin; 033import cascading.pipe.Merge; 034import cascading.tap.Tap; 035 036import static cascading.flow.planner.iso.expression.AndElementExpression.and; 037import static cascading.flow.planner.iso.expression.NotElementExpression.not; 038import static cascading.flow.planner.iso.expression.OrElementExpression.or; 039 040/** 041 * 042 */ 043public class NoGroupJoinMergeBoundaryTapExpressionGraph extends ExpressionGraph 044 { 045 public NoGroupJoinMergeBoundaryTapExpressionGraph() 046 { 047 super( 048 not( 049 or( 050 ElementCapture.Primary, 051 new FlowElementExpression( Extent.class ), 052 new FlowElementExpression( Group.class ), 053 new FlowElementExpression( HashJoin.class ), 054 and( new FlowElementExpression( Merge.class ), not( new AnnotationExpression( RoleMode.Logical ) ) ), 055 new FlowElementExpression( Boundary.class ), 056 new FlowElementExpression( Tap.class ) 057 ) 058 ) 059 ); 060 } 061 }