From 51f549251bc54f112490014fa7ec5d41da7717d6 Mon Sep 17 00:00:00 2001
From: Tyler Akidau <takidau@apache.org>
Date: Thu, 15 Jun 2017 18:04:43 -0700
Subject: [PATCH] Remove unused BeamPipelineCreator class

---
 .../dsls/sql/planner/BeamPipelineCreator.java | 58 -------------------
 .../dsls/sql/planner/BeamQueryPlanner.java    |  1 -
 .../apache/beam/dsls/sql/rel/BeamRelNode.java |  4 +-
 3 files changed, 2 insertions(+), 61 deletions(-)
 delete mode 100644 dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamPipelineCreator.java

diff --git a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamPipelineCreator.java b/dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamPipelineCreator.java
deleted file mode 100644
index 38e039f2e06d..000000000000
--- a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamPipelineCreator.java
+++ /dev/null
@@ -1,58 +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.beam.dsls.sql.planner;
-
-import java.util.Map;
-import org.apache.beam.dsls.sql.rel.BeamRelNode;
-import org.apache.beam.dsls.sql.schema.BaseBeamTable;
-import org.apache.beam.sdk.Pipeline;
-
-/**
- * {@link BeamPipelineCreator} converts a {@link BeamRelNode} tree, into a Beam
- * pipeline.
- *
- */
-class BeamPipelineCreator {
-  private Map<String, BaseBeamTable> sourceTables;
-
-  private Pipeline pipeline;
-
-  private boolean hasPersistent = false;
-
-  public BeamPipelineCreator(Map<String, BaseBeamTable> sourceTables, Pipeline basePipeline) {
-    this.sourceTables = sourceTables;
-    this.pipeline = basePipeline;
-  }
-
-  public Map<String, BaseBeamTable> getSourceTables() {
-    return sourceTables;
-  }
-
-  public Pipeline getPipeline() {
-    return pipeline;
-  }
-
-  public boolean hasPersistent() {
-    return hasPersistent;
-  }
-
-  public void setHasPersistent(boolean hasPersistent) {
-    this.hasPersistent = hasPersistent;
-  }
-
-}
diff --git a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamQueryPlanner.java b/dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamQueryPlanner.java
index 98580cb7b55b..ef71b534c14d 100644
--- a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamQueryPlanner.java
+++ b/dsls/sql/src/main/java/org/apache/beam/dsls/sql/planner/BeamQueryPlanner.java
@@ -110,7 +110,6 @@ public PCollection<BeamSqlRow> compileBeamPipeline(String sqlStatement, Pipeline
       throws Exception {
     BeamRelNode relNode = convertToBeamRel(sqlStatement);
 
-    BeamPipelineCreator planCreator = new BeamPipelineCreator(sourceTables, basePipeline);
     // the input PCollectionTuple is empty, and be rebuilt in BeamIOSourceRel.
     return relNode.buildBeamPipeline(PCollectionTuple.empty(basePipeline));
   }
diff --git a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamRelNode.java b/dsls/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamRelNode.java
index 0233ccffe41b..aed4b06b0773 100644
--- a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamRelNode.java
+++ b/dsls/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamRelNode.java
@@ -24,13 +24,13 @@
 
 /**
  * A new method {@link #buildBeamPipeline(PCollectionTuple)} is added, it's
- * called by {@code BeamPipelineCreator}.
+ * called by {@code BeamQueryPlanner}.
  */
 public interface BeamRelNode extends RelNode {
 
   /**
    * A {@link BeamRelNode} is a recursive structure, the
-   * {@code BeamPipelineCreator} visits it with a DFS(Depth-First-Search)
+   * {@code BeamQueryPlanner} visits it with a DFS(Depth-First-Search)
    * algorithm.
    */
   PCollection<BeamSqlRow> buildBeamPipeline(PCollectionTuple inputPCollections) throws Exception;