JDSA commit

tatoliop · Dec 11, 2018 · 7b5ac99 · 7b5ac99
1 parent 5933964
commit 7b5ac99
Show file tree

Hide file tree

Showing 141 changed files with 18,098 additions and 1,933 deletions.
diff --git a/README b/README
@@ -1,12 +1,14 @@
-A Flink application project using Scala and SBT.
-
-A parallel approach using the parallel, advanced, advanced vp and pmcod algorithms for distance based outlier detection on streams.
+A parallel approach using the parallel, advanced, slicing and pmcod algorithms with the grid and metric partitioning for distance based outlier detection on streams.
 
 Parameters:
 --input <Input path of data>
+--treeInput (Optional) <Input path for the creation of the tree in metric partitioning>
 --window <window size>
 --slide <slide size>
---dataset <dataset for spatial partitioning (works on stock, tao, fc, gauss)>
+--dataset <dataset name for grid partitioning (works on stock, tao, fc, gauss)>
 --k <number of neighbors>
 --range <range for distance>
---algorithm <parallel,advanced,advanced_vp,pmcod>
+--algorithm <parallel,advanced,advanced_vp,slicing,pmcod>
+--part (Optional) <Partitioning type - grid,metric>
+--VPcount (Optional) <Number of elements for tree creation in metric partitioning>
+--parallelism <Parallelism degree for Flink>
diff --git a/build.sbt b/build.sbt
@@ -4,15 +4,19 @@ name := "Ourliers"
 
 version := "1.0.0"
 
-organization := "org.delab"
+organization := "org.auth.csd.datalab"
 
 scalaVersion in ThisBuild := "2.11.6"
 
 val flinkVersion = "1.4.0"
+//val flinkVersion = "1.6.2"
 
 val flinkDependencies = Seq(
   "org.apache.flink" %% "flink-scala" % flinkVersion % "provided",
-  "org.apache.flink" %% "flink-streaming-scala" % flinkVersion % "provided")
+  "org.apache.flink" %% "flink-streaming-scala" % flinkVersion % "provided"
+  //"org.apache.flink" %% "flink-table" % flinkVersion % "provided",
+  //"com.esotericsoftware" %% "kryo" % "4.0.1"
+)
 
 libraryDependencies ++= Seq(
   "org.scalanlp" %% "breeze" % "0.12",

diff --git a/project/assembly.sbt b/project/assembly.sbt
@@ -1 +1 @@
-addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.14.1")
+addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.14.7")
diff --git a/project/project/target/config-classes/$369d05e0bacddbfb1d9e$.class b/project/project/target/config-classes/$369d05e0bacddbfb1d9e$.class
diff --git a/project/project/target/config-classes/$369d05e0bacddbfb1d9e.cache b/project/project/target/config-classes/$369d05e0bacddbfb1d9e.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/project/target/config-classes/$369d05e0bacddbfb1d9e.class b/project/project/target/config-classes/$369d05e0bacddbfb1d9e.class
diff --git a/project/target/config-classes/$103db83b7cb49c9a6fe2$.class b/project/target/config-classes/$103db83b7cb49c9a6fe2$.class
diff --git a/project/target/config-classes/$103db83b7cb49c9a6fe2.cache b/project/target/config-classes/$103db83b7cb49c9a6fe2.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$103db83b7cb49c9a6fe2.class b/project/target/config-classes/$103db83b7cb49c9a6fe2.class
diff --git a/...ect/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$1$$anonfun$apply$1.class b/...ect/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$1$$anonfun$apply$1.class
diff --git a/project/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$1.class b/project/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$2.class b/project/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$2.class
diff --git a/project/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$3.class b/project/target/config-classes/$2093b6200c2303c5fbbc$$anonfun$$sbtdef$3.class
diff --git a/project/target/config-classes/$2093b6200c2303c5fbbc$.class b/project/target/config-classes/$2093b6200c2303c5fbbc$.class
diff --git a/project/target/config-classes/$2093b6200c2303c5fbbc.cache b/project/target/config-classes/$2093b6200c2303c5fbbc.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$2093b6200c2303c5fbbc.class b/project/target/config-classes/$2093b6200c2303c5fbbc.class
diff --git a/project/target/config-classes/$304430fdfb648e8fce28$$anonfun$$sbtdef$1.class b/project/target/config-classes/$304430fdfb648e8fce28$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$304430fdfb648e8fce28$.class b/project/target/config-classes/$304430fdfb648e8fce28$.class
diff --git a/project/target/config-classes/$304430fdfb648e8fce28.cache b/project/target/config-classes/$304430fdfb648e8fce28.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$304430fdfb648e8fce28.class b/project/target/config-classes/$304430fdfb648e8fce28.class
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$1.class b/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$1.class
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$2.class b/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$2.class
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$3.class b/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$3.class
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$4.class b/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$4.class
diff --git a/.../target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$5$$anonfun$apply$1.class b/.../target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$5$$anonfun$apply$1.class
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$5.class b/project/target/config-classes/$6ce554c135bf1d9df7a7$$anonfun$mainRunner$5.class
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7$.class b/project/target/config-classes/$6ce554c135bf1d9df7a7$.class
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7.cache b/project/target/config-classes/$6ce554c135bf1d9df7a7.cache
@@ -0,0 +1 @@
+mainRunner
diff --git a/project/target/config-classes/$6ce554c135bf1d9df7a7.class b/project/target/config-classes/$6ce554c135bf1d9df7a7.class
diff --git a/project/target/config-classes/$71efb24d194ee4375796$$anonfun$$sbtdef$1.class b/project/target/config-classes/$71efb24d194ee4375796$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$71efb24d194ee4375796$.class b/project/target/config-classes/$71efb24d194ee4375796$.class
diff --git a/project/target/config-classes/$71efb24d194ee4375796.cache b/project/target/config-classes/$71efb24d194ee4375796.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$71efb24d194ee4375796.class b/project/target/config-classes/$71efb24d194ee4375796.class
diff --git a/project/target/config-classes/$7a441bf2d46b659d33fe$$anonfun$$sbtdef$1.class b/project/target/config-classes/$7a441bf2d46b659d33fe$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$7a441bf2d46b659d33fe$.class b/project/target/config-classes/$7a441bf2d46b659d33fe$.class
diff --git a/project/target/config-classes/$7a441bf2d46b659d33fe.cache b/project/target/config-classes/$7a441bf2d46b659d33fe.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$7a441bf2d46b659d33fe.class b/project/target/config-classes/$7a441bf2d46b659d33fe.class
diff --git a/project/target/config-classes/$7c680a1d5bddfeddf824$$anonfun$$sbtdef$1.class b/project/target/config-classes/$7c680a1d5bddfeddf824$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$7c680a1d5bddfeddf824$.class b/project/target/config-classes/$7c680a1d5bddfeddf824$.class
diff --git a/project/target/config-classes/$7c680a1d5bddfeddf824.cache b/project/target/config-classes/$7c680a1d5bddfeddf824.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$7c680a1d5bddfeddf824.class b/project/target/config-classes/$7c680a1d5bddfeddf824.class
diff --git a/project/target/config-classes/$8636886c592d76aed1b8$$anonfun$$sbtdef$1.class b/project/target/config-classes/$8636886c592d76aed1b8$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$8636886c592d76aed1b8$.class b/project/target/config-classes/$8636886c592d76aed1b8$.class
diff --git a/project/target/config-classes/$8636886c592d76aed1b8.cache b/project/target/config-classes/$8636886c592d76aed1b8.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$8636886c592d76aed1b8.class b/project/target/config-classes/$8636886c592d76aed1b8.class
diff --git a/project/target/config-classes/$8681d4b3e865a100f5a4$$anonfun$$sbtdef$1.class b/project/target/config-classes/$8681d4b3e865a100f5a4$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$8681d4b3e865a100f5a4$.class b/project/target/config-classes/$8681d4b3e865a100f5a4$.class
diff --git a/project/target/config-classes/$8681d4b3e865a100f5a4.cache b/project/target/config-classes/$8681d4b3e865a100f5a4.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$8681d4b3e865a100f5a4.class b/project/target/config-classes/$8681d4b3e865a100f5a4.class
diff --git a/project/target/config-classes/$9e00826230d290aa0870$$anonfun$$sbtdef$1.class b/project/target/config-classes/$9e00826230d290aa0870$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$9e00826230d290aa0870$.class b/project/target/config-classes/$9e00826230d290aa0870$.class
diff --git a/project/target/config-classes/$9e00826230d290aa0870.cache b/project/target/config-classes/$9e00826230d290aa0870.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$9e00826230d290aa0870.class b/project/target/config-classes/$9e00826230d290aa0870.class
diff --git a/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$1.class b/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$1.class
diff --git a/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$2.class b/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$2.class
diff --git a/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$3.class b/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$3.class
diff --git a/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$4.class b/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$4.class
diff --git a/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$5.class b/project/target/config-classes/$cf480740975a13d44c01$$anonfun$root$5.class
diff --git a/project/target/config-classes/$cf480740975a13d44c01$.class b/project/target/config-classes/$cf480740975a13d44c01$.class
diff --git a/project/target/config-classes/$cf480740975a13d44c01.cache b/project/target/config-classes/$cf480740975a13d44c01.cache
@@ -0,0 +1 @@
+root
diff --git a/project/target/config-classes/$cf480740975a13d44c01.class b/project/target/config-classes/$cf480740975a13d44c01.class
diff --git a/project/target/config-classes/$f858db4f4695634dab1b$$anonfun$$sbtdef$1.class b/project/target/config-classes/$f858db4f4695634dab1b$$anonfun$$sbtdef$1.class
diff --git a/project/target/config-classes/$f858db4f4695634dab1b$.class b/project/target/config-classes/$f858db4f4695634dab1b$.class
diff --git a/project/target/config-classes/$f858db4f4695634dab1b.cache b/project/target/config-classes/$f858db4f4695634dab1b.cache
@@ -0,0 +1 @@
+sbt.internals.DslEntry
diff --git a/project/target/config-classes/$f858db4f4695634dab1b.class b/project/target/config-classes/$f858db4f4695634dab1b.class
diff --git a/...ion-cache/default/ourliers-build/scala_2.10/sbt_0.13/0.1-SNAPSHOT/resolved.xml.properties b/...ion-cache/default/ourliers-build/scala_2.10/sbt_0.13/0.1-SNAPSHOT/resolved.xml.properties
@@ -0,0 +1,7 @@
+#default#ourliers-build;0.1-SNAPSHOT resolved revisions
+#Wed Dec 05 14:50:47 EET 2018
++organisation\:\#@\#\:+org.scala-sbt\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+sbt\:\#@\#\:+revision\:\#@\#\:+0.13.16\:\#@\#\:=0.13.16 release 0.13.16 null
++organisation\:\#@\#\:+org.scala-lang\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+scala-library\:\#@\#\:+revision\:\#@\#\:+2.10.6\:\#@\#\:=2.10.6 ? 2.10.6 null
++organisation\:\#@\#\:+org.scala-lang\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+scala-compiler\:\#@\#\:+revision\:\#@\#\:+2.10.6\:\#@\#\:=2.10.6 release 2.10.6 null
++e\:sbtVersion\:\#@\#\:+0.13\:\#@\#\:+module\:\#@\#\:+sbt-assembly\:\#@\#\:+e\:scalaVersion\:\#@\#\:+2.10\:\#@\#\:+organisation\:\#@\#\:+com.eed3si9n\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+revision\:\#@\#\:+0.14.7\:\#@\#\:=0.14.7 release 0.14.7 null
++e\:sbtVersion\:\#@\#\:+0.13\:\#@\#\:+module\:\#@\#\:+global-plugins\:\#@\#\:+e\:scalaVersion\:\#@\#\:+2.10\:\#@\#\:+organisation\:\#@\#\:+org.scala-sbt\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+revision\:\#@\#\:+0.0\:\#@\#\:=0.0 integration 0.0 null
diff --git a/...resolution-cache/default/ourliers-build/scala_2.10/sbt_0.13/0.1-SNAPSHOT/resolved.xml.xml b/...resolution-cache/default/ourliers-build/scala_2.10/sbt_0.13/0.1-SNAPSHOT/resolved.xml.xml
@@ -0,0 +1,47 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<ivy-module version="2.0" xmlns:e="http://ant.apache.org/ivy/extra">
+	<info organisation="default"
+		module="ourliers-build"
+		revision="0.1-SNAPSHOT"
+		status="integration"
+		publication="20181205145041"
+		e:sbtVersion="0.13" e:scalaVersion="2.10"
+	>
+		<description>
+		ourliers-build
+		</description>
+	</info>
+	<configurations>
+		<conf name="compile" visibility="public" description=""/>
+		<conf name="runtime" visibility="public" description="" extends="compile"/>
+		<conf name="test" visibility="public" description="" extends="runtime"/>
+		<conf name="provided" visibility="public" description=""/>
+		<conf name="optional" visibility="public" description=""/>
+		<conf name="compile-internal" visibility="private" description="" extends="compile,optional,provided"/>
+		<conf name="runtime-internal" visibility="private" description="" extends="runtime,optional"/>
+		<conf name="test-internal" visibility="private" description="" extends="test,optional,provided"/>
+		<conf name="plugin" visibility="private" description=""/>
+		<conf name="sources" visibility="public" description=""/>
+		<conf name="docs" visibility="public" description=""/>
+		<conf name="pom" visibility="public" description=""/>
+		<conf name="scala-tool" visibility="private" description=""/>
+	</configurations>
+	<publications>
+		<artifact name="ourliers-build" type="pom" ext="pom" conf="pom"/>
+		<artifact name="ourliers-build" type="jar" ext="jar" conf="compile"/>
+		<artifact name="ourliers-build" type="src" ext="jar" conf="sources" e:classifier="sources"/>
+		<artifact name="ourliers-build" type="doc" ext="jar" conf="docs" e:classifier="javadoc"/>
+	</publications>
+	<dependencies>
+		<dependency org="org.scala-lang" name="scala-compiler" rev="2.10.6" conf="scala-tool->default,optional(default)"/>
+		<dependency org="org.scala-lang" name="scala-library" rev="2.10.6" conf="scala-tool->default,optional(default);provided->default(compile)"/>
+		<dependency org="org.scala-sbt" name="sbt" rev="0.13.16" conf="provided->default(compile)"/>
+		<dependency org="org.scala-sbt" name="global-plugins" rev="0.0" conf="compile->default(compile)" e:sbtVersion="0.13" e:scalaVersion="2.10">
+			<artifact name="global-plugins" type="pom" ext="pom" conf="pom"/>
+			<artifact name="global-plugins" type="jar" ext="jar" conf="compile"/>
+			<artifact name="global-plugins" type="src" ext="jar" conf="sources" e:classifier="sources"/>
+			<artifact name="global-plugins" type="doc" ext="jar" conf="docs" e:classifier="javadoc"/>
+		</dependency>
+		<dependency org="com.eed3si9n" name="sbt-assembly" rev="0.14.7" conf="compile->default(compile)" e:sbtVersion="0.13" e:scalaVersion="2.10"/>
+	</dependencies>
+</ivy-module>