com.pb.bigdata.routing.spark.api
Include a routing dataset by specifying the path to the dataset's directory.
Include a routing dataset by specifying the path to the dataset's directory. If using a remote path then include a DownloadManger when using this builder. Otherwise use a local path to the dataset that exists on every worker node.
the path to the dataset's directory
this builder with the addition of this dataset
Include routing datasets by specifying the paths to the dataset directories.
Include routing datasets by specifying the paths to the dataset directories. If using remote paths then include a DownloadManger when using this builder. Otherwise use local paths to the dataset that exists on every worker node.
the paths to the dataset directories
this builder with the addition of the datasets
Builds the IGRAInstance
Builds the IGRAInstance
the IGRAInstance to use for routing requests
Add a DownloadManager to help resolve any remote dataset paths.
Add a DownloadManager to help resolve any remote dataset paths. DownloadManagers are created using the DownloadManagerBuilder
the DownloadManager to use
this builder with the addition of the DownloadManager specified
Add additional options to use when the GRAInstance is created.
Add additional options to use when the GRAInstance is created. Options are created using the Options.Builder
new Options.Builder().isoTimeout(60000).build()
the options to use
this builder with the addition of the Options specified
Builder for an IGRAInstance that behaves efficiently in Spark. The IGRAInstance will be serializable from the driver to the executors. All tasks in an executor will share a single IGRAInstance.
For example: