Package cz.o2.proxima.beam.util

Class RunnerUtils

  • @Internal
public class RunnerUtils
extends java.lang.Object

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.io.File createJarFromDynamicClasses​(java.util.Map<? extends java.lang.Class<?>,​byte[]> classes)
      Generate jar from provided map of dynamic classes.
      static void injectJarIntoContextClassLoader​(java.util.Collection<java.io.File> paths)
      Inject given paths to class loader of given (local) runner.
      static void registerToPipeline​(org.apache.beam.sdk.options.PipelineOptions opts, java.lang.String runnerName, java.util.Collection<java.io.File> paths)
      Register given set of jars to runner.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • registerToPipeline

        public static void registerToPipeline​(org.apache.beam.sdk.options.PipelineOptions opts,
                                      java.lang.String runnerName,
                                      java.util.Collection<java.io.File> paths)
        Register given set of jars to runner.

      • injectJarIntoContextClassLoader

        public static void injectJarIntoContextClassLoader​(java.util.Collection<java.io.File> paths)
        Inject given paths to class loader of given (local) runner.

      • createJarFromDynamicClasses

        public static java.io.File createJarFromDynamicClasses​(java.util.Map<? extends java.lang.Class<?>,​byte[]> classes)
                                                throws java.io.IOException
        Generate jar from provided map of dynamic classes.
        Parameters:
        classes - map of class to bytecode
        Returns:
        generated File
        Throws:
        java.io.IOException