Logical plan generator with optimizations now.

Author: LorenzBuehmann

sansa-inference-common/pom.xml

@@ -97,7 +97,7 @@
   </dependencies>
 
   <build>
-    <sourceDirectory>src/main/scala</sourceDirectory>
+    <sourceDirectory>src/main/scala,src/main/resources</sourceDirectory>
     <testSourceDirectory>src/test/scala</testSourceDirectory>
     <!--<outputDirectory>target/scala-${scala.binary.version}/classes</outputDirectory>-->
     <!--<testOutputDirectory>target/scala-${scala.binary.version}/test-classes</testOutputDirectory>-->

sansa-inference-common/src/main/resources/log4j.properties

@@ -0,0 +1,22 @@
+# Root logger option
+log4j.rootLogger=INFO, stdout
+
+# Direct log messages to a log file
+log4j.appender.file=org.apache.log4j.RollingFileAppender
+log4j.appender.file.File=C:\\logging.log
+log4j.appender.file.MaxFileSize=10MB
+log4j.appender.file.MaxBackupIndex=10
+log4j.appender.file.layout=org.apache.log4j.PatternLayout
+log4j.appender.file.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %C{1}:%L - %m%n
+
+# Direct log messages to stdout
+log4j.appender.stdout=org.apache.log4j.ConsoleAppender
+log4j.appender.stdout.Target=System.out
+log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
+log4j.appender.stdout.layout.ConversionPattern=%r %-5p %C:%L - %m%n
+
+log4j.logger.akka.event.slf4j.Slf4jLogger=ERROR
+log4j.logger.akka.remote.Remoting=ERROR
+
+log4j.logger.org.apache.hadoop=ERROR
+log4j.logger.org.apache.calcite=ERROR

sansa-inference-common/src/main/scala/net/sansa_stack/inference/rules/plan/SimpleCalciteConnection.scala

@@ -20,7 +20,7 @@ import org.apache.calcite.tools.Frameworks
 class SimpleCalciteConnection extends CalciteConnection{
 
   val rootSchema = Frameworks.createRootSchema(true)
-  var schema: String = ""
+  var schema: String = null
 
   override def config(): CalciteConnectionConfig = null
 
@@ -32,7 +32,7 @@ class SimpleCalciteConnection extends CalciteConnection{
 
   override def getProperties: Properties = null
 
-  override def setSchema(schema: String): Unit = {}
+  override def setSchema(s: String): Unit = schema = s
 
   override def setAutoCommit(autoCommit: Boolean): Unit = {}