Migrate Subscription model to use new ScriptImplementor (#192)

* Migrate Subscription model to use new ScriptImplementor

* Fix build

Author: jogrogan

Makefile

@@ -52,7 +52,7 @@ undeploy-demo: undeploy
 deploy-flink: deploy
 	kubectl create namespace flink || echo "skipping"
 	kubectl create -f https://github.com/jetstack/cert-manager/releases/download/v1.8.2/cert-manager.yaml || echo "skipping"
-	helm repo add flink-operator-repo https://downloads.apache.org/flink/flink-kubernetes-operator-1.11.0/
+	helm repo add flink-operator-repo https://downloads.apache.org/flink/flink-kubernetes-operator-1.13.0/
 	helm upgrade --install --atomic --set webhook.create=false,image.pullPolicy=Never,image.repository=docker.io/library/hoptimator-flink-operator,image.tag=latest --set-json='watchNamespaces=["default","flink"]' flink-kubernetes-operator flink-operator-repo/flink-kubernetes-operator
 	kubectl apply -f ./deploy/dev/flink-session-cluster.yaml
 	kubectl apply -f ./deploy/dev/flink-sql-gateway.yaml

hoptimator-catalog/src/main/java/com/linkedin/hoptimator/catalog/DataType.java

@@ -3,6 +3,7 @@
 import java.util.Collections;
 import java.util.stream.Collectors;
 
+import com.linkedin.hoptimator.util.planner.ScriptImplementor;
 import org.apache.calcite.rel.type.RelDataType;
 import org.apache.calcite.rel.type.RelDataTypeFactory;
 import org.apache.calcite.rel.type.RelDataTypeField;

hoptimator-catalog/src/main/java/com/linkedin/hoptimator/catalog/HopTable.java

@@ -4,6 +4,7 @@
 import java.util.Collections;
 import java.util.Map;
 
+import com.linkedin.hoptimator.util.planner.ScriptImplementor;
 import org.apache.calcite.plan.RelOptCluster;
 import org.apache.calcite.plan.RelOptTable;
 import org.apache.calcite.rel.RelNode;
@@ -46,7 +47,7 @@ public HopTable(String database, String name, RelDataType rowType, Collection<Re
   public HopTable(String database, String name, RelDataType rowType, Collection<Resource> readResources,
       Collection<Resource> writeResources, Map<String, String> connectorConfig) {
     this(database, name, rowType, readResources, writeResources,
-        new ScriptImplementor.ConnectorImplementor(database, name, rowType, connectorConfig));
+        new ScriptImplementor.ConnectorImplementor(null, database, name, null, rowType, connectorConfig));
   }
 
   /** Convenience constructor for HopTables that only need a connector config. */