first work to enable the distribution

FusRoman · Jan 11, 2023 · 561402b · 561402b
1 parent c68685a
commit 561402b
Show file tree

Hide file tree

Showing 5 changed files with 424 additions and 3 deletions.
diff --git a/.flake8 b/.flake8
@@ -12,4 +12,5 @@ exclude =
 per-file-ignores =
     ../Fink_GRB/fink_grb/online/ztf_join_gcn.py:W503,E402
     ../Fink_GRB/fink_grb/offline/spark_offline.py:W503,W605
-    ../Fink_GRB/fink_grb/utils/fun_utils.py:F811
+    ../Fink_GRB/fink_grb/utils/fun_utils.py:F811
+    ../Fink_GRB/fink_grb/distribution/distribution.py:W503
diff --git a/fink_grb/conf/fink_grb_schema_version_1.0.avsc b/fink_grb/conf/fink_grb_schema_version_1.0.avsc
@@ -0,0 +1,184 @@
+{
+  "type": "record",
+  "name": "topLevelRecord",
+  "fields": [
+    {
+      "name": "objectId",
+      "type": [
+        "string",
+        "null"
+      ]
+    },
+    {
+      "name": "candid",
+      "type": [
+        "long",
+        "null"
+      ]
+    },
+    {
+      "name": "ztf_ra",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "ztf_dec",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "fid",
+      "type": [
+        "long",
+        "null"
+      ]
+    },
+    {
+      "name": "jdstarthist",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "rb",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "jd",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "instrument_or_event",
+      "type": [
+        "string",
+        "null"
+      ]
+    },
+    {
+      "name": "platform",
+      "type": [
+        "string",
+        "null"
+      ]
+    },
+    {
+      "name": "triggerId",
+      "type": [
+        "long",
+        "null"
+      ]
+    },
+    {
+      "name": "grb_ra",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "grb_dec",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "grb_loc_error",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "triggerTimeUTC",
+      "type": [
+        "string",
+        "null"
+      ]
+    },
+    {
+      "name": "grb_proba",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "fink_class",
+      "type": [
+        "string",
+        "null"
+      ]
+    },
+    {
+      "name": "delta_mag",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "rate",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "from_upper",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "start_vartime",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "diff_vartime",
+      "type": [
+        "double",
+        "null"
+      ]
+    },
+    {
+      "name": "timestamp",
+      "type": [
+        {
+          "type": "long",
+          "logicalType": "timestamp-micros"
+        },
+        "null"
+      ]
+    },
+    {
+      "name": "month",
+      "type": [
+        "long",
+        "null"
+      ]
+    },
+    {
+      "name": "day",
+      "type": [
+        "long",
+        "null"
+      ]
+    }
+  ]
+}