- Minimize permissions

- Calculate in threads - Do not include python home in jar - Move data_analysis.py to correct location in vfs
graalvm · Jan 13, 2025 · bb78651 · bb78651
1 parent 667bf2e
commit bb78651
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 10 deletions.
diff --git a/graalpy/graalpy-apache-arrow-guide/pom.xml b/graalpy/graalpy-apache-arrow-guide/pom.xml
@@ -63,6 +63,10 @@
                                 <package>pandas</package>
                                 <package>pyarrow</package>
                             </packages>
+                            <pythonHome>
+                                <includes></includes>
+                                <excludes>.*</excludes>
+                            </pythonHome>
                         </configuration>
                         <goals>
                             <goal>process-graalpy-resources</goal>
@@ -73,4 +77,4 @@
         </plugins>
     </build>
 
-</project>
+</project>
diff --git a/graalpy/graalpy-apache-arrow-guide/src/main/java/com/example/Main.java b/graalpy/graalpy-apache-arrow-guide/src/main/java/com/example/Main.java
@@ -4,6 +4,7 @@
 import org.apache.arrow.memory.RootAllocator;
 import org.apache.arrow.vector.Float8Vector;
 import org.graalvm.polyglot.Context;
+import org.graalvm.polyglot.HostAccess;
 import org.graalvm.polyglot.Value;
 import org.graalvm.python.embedding.utils.GraalPyResources;
 
@@ -17,7 +18,13 @@ public class Main {
     private static final Integer PASSING_RATE_COLUMN_INDEX = 3;
 
     public static Context initContext() {
-        return GraalPyResources.contextBuilder().allowAllAccess(true).build();
+        return GraalPyResources.contextBuilder()
+            .option("python.PythonHome", "")
+            .option("python.WarnExperimentalFeatures", "false")
+            .allowHostAccess(HostAccess.ALL)
+            .allowHostClassLookup(c -> true)
+            .allowNativeAccess(true)
+            .build();
     }
 
     public static void initDataAnalysisPyModule(Context context) {
@@ -33,17 +40,21 @@ public static void main(String[] args) throws IOException, InterruptedException
              Float8Vector jsVector = new Float8Vector("jsPassingRate", allocator)
         ) {
             initDataAnalysisPyModule(context);
-            Thread pyThread = new Thread(() -> DownloadUtils.downloadAndStore(PYTHON_URL, PASSING_RATE_COLUMN_INDEX, pyVector));
-            Thread jsThread = new Thread(() -> DownloadUtils.downloadAndStore(JAVASCRIPT_URL, PASSING_RATE_COLUMN_INDEX, jsVector));
+            Thread pyThread = new Thread(() -> {
+                DownloadUtils.downloadAndStore(PYTHON_URL, PASSING_RATE_COLUMN_INDEX, pyVector);
+                System.out.println("Python mean: " + dataAnalysisPyModule.calculateMean(pyVector));
+                System.out.println("Python median: " + dataAnalysisPyModule.calculateMedian(pyVector));
+            });
+            Thread jsThread = new Thread(() -> {
+                DownloadUtils.downloadAndStore(JAVASCRIPT_URL, PASSING_RATE_COLUMN_INDEX, jsVector);
+                System.out.println("JS mean: " + dataAnalysisPyModule.calculateMean(jsVector));
+                System.out.println("JS median: " + dataAnalysisPyModule.calculateMedian(jsVector));
+            });
             pyThread.start();
             jsThread.start();
             pyThread.join();
             jsThread.join();
 
-            System.out.println("Python mean: " + dataAnalysisPyModule.calculateMean(pyVector));
-            System.out.println("Python median: " + dataAnalysisPyModule.calculateMedian(pyVector));
-            System.out.println("JS mean: " + dataAnalysisPyModule.calculateMean(jsVector));
-            System.out.println("JS median: " + dataAnalysisPyModule.calculateMedian(jsVector));
         }
     }
-}
+}
diff --git a/...y-apache-arrow-guide/src/data_analysis.py → ...g.graalvm.python.vfs/src/data_analysis.py b/...y-apache-arrow-guide/src/data_analysis.py → ...g.graalvm.python.vfs/src/data_analysis.py
@@ -7,4 +7,4 @@ def calculateMean(valueVector: Float8Vector) -> float:
 
 def calculateMedian(valueVector: Float8Vector) -> float:
     series = pd.Series(valueVector, dtype="float64[pyarrow]")
-    return series.median()
+    return series.median()