This repository was archived by the owner on May 6, 2022. It is now read-only.
Switch to other serialization format #42
Description
- Allow serialization in memory or on disk
- Use Kryo as tried before or use another format like ByteArray or Apache Arrow.
conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer"); conf.registerKryoClasses(new Class[]{ MetricTimeSeries.class, MetricObservation.class, MetricDimensions.class, MetricTimeSeriesKey.class, MetricTimeSeriesOrdering.class, FilterObservationByTimestamp.class, ChronixRDD.class, ChronixSparkContext.class, ChronixSolrCloudStorage.class});