extend Scala API

Author: novakov-alexey

modules/scala-api/src/main/scala/org/apache/flinkx/api/DataStream.scala

@@ -609,6 +609,19 @@ class DataStream[T](stream: JavaStream[T]) {
     }
     filter(filterFun)
   }
+  
+  /** Creates a new DataStream that contains only the elements not satisfying the given filter predicate.
+    */
+  def filterNot(fun: T => Boolean): DataStream[T] = {
+    if (fun == null) {
+      throw new NullPointerException("FilteNot function must not be null.")
+    }
+    val cleanFun = clean(fun)
+    val filterFun = new FilterFunction[T] {
+      def filter(in: T): Boolean = !cleanFun(in)
+    }
+    filter(filterFun)
+  }
 
   /** Windows this [[DataStream]] into sliding count windows.
     *

modules/scala-api/src/main/scala/org/apache/flinkx/api/StreamExecutionEnvironment.scala

@@ -825,6 +825,15 @@ object StreamExecutionEnvironment {
     new StreamExecutionEnvironment(JavaEnv.getExecutionEnvironment)
   }
 
+  /** Creates an execution environment that represents the context in which the program is currently executed.
+    *    
+    * @param configuration
+    *  Pass a custom configuration into the cluster.
+    */ 
+  def getExecutionEnvironment(configuration: Configuration): StreamExecutionEnvironment = {
+    new StreamExecutionEnvironment(JavaEnv.getExecutionEnvironment(configuration))
+  }
+
   // --------------------------------------------------------------------------
   //  local environment
   // --------------------------------------------------------------------------