001    /*
002     * Copyright (c) 2007-2015 Concurrent, Inc. All Rights Reserved.
003     *
004     * Project and contact information: http://www.cascading.org/
005     *
006     * This file is part of the Cascading project.
007     *
008     * Licensed under the Apache License, Version 2.0 (the "License");
009     * you may not use this file except in compliance with the License.
010     * You may obtain a copy of the License at
011     *
012     *     http://www.apache.org/licenses/LICENSE-2.0
013     *
014     * Unless required by applicable law or agreed to in writing, software
015     * distributed under the License is distributed on an "AS IS" BASIS,
016     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
017     * See the License for the specific language governing permissions and
018     * limitations under the License.
019     */
020    
021    package cascading.flow.local;
022    
023    import java.util.Map;
024    
025    import cascading.flow.FlowConnector;
026    import cascading.flow.local.planner.LocalPlanner;
027    import cascading.flow.planner.FlowPlanner;
028    import cascading.scheme.Scheme;
029    
030    /**
031     * Use the LocalFlowConnector to link source and sink {@link cascading.tap.Tap} instances with an assembly of {@link cascading.pipe.Pipe} instances into
032     * an executable {@link LocalFlow} for execution in local memory.
033     *
034     * @see cascading.property.AppProps
035     * @see cascading.flow.FlowConnectorProps
036     * @see cascading.flow.FlowDef
037     */
038    public class LocalFlowConnector extends FlowConnector
039      {
040      /** Constructor LocalFlowConnector creates a default instance. */
041      public LocalFlowConnector()
042        {
043        }
044    
045      /**
046       * Constructor LocalFlowConnector creates a new instance using any of the given properties.
047       *
048       * @param properties of type Map
049       */
050      public LocalFlowConnector( Map<Object, Object> properties )
051        {
052        super( properties );
053        }
054    
055      @Override
056      protected Class<? extends Scheme> getDefaultIntermediateSchemeClass()
057        {
058        return null;
059        }
060    
061      @Override
062      protected FlowPlanner createFlowPlanner()
063        {
064        return new LocalPlanner();
065        }
066      }