RawTextHelper (Spark 3.5.0 JavaDoc)

public class RawTextHelper
extends Object

Constructors
Constructor and Description
`RawTextHelper()`

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static long`	`add(long v1, long v2)`
`static long`	`max(long v1, long v2)`
`static scala.collection.Iterator<scala.Tuple2<String,Object>>`	`splitAndCountPartitions(scala.collection.Iterator<String> iter)` Splits lines and counts the words.
`static long`	`subtract(long v1, long v2)`
`static scala.collection.Iterator<scala.Tuple2<String,Object>>`	`topK(scala.collection.Iterator<scala.Tuple2<String,Object>> data, int k)` Gets the top k words in terms of word counts.
`static void`	`warmUp(SparkContext sc)` Warms up the SparkContext in master and executor by running tasks to force JIT kick in before real workload starts.

Methods inherited from class Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public static scala.collection.Iterator<scala.Tuple2<String,Object>> splitAndCountPartitions(scala.collection.Iterator<String> iter)

Splits lines and counts the words.

public static long add(long v1,
                       long v2)

public static long subtract(long v1,
                            long v2)

public static long max(long v1,
                       long v2)

Class RawTextHelper