Class RawTextSender

Object
org.apache.spark.streaming.util.RawTextSender

public class RawTextSender extends Object
A helper program that sends blocks of Kryo-serialized text strings out on a socket at a specified rate. Used to feed data into RawInputDStream.
  • Constructor Details

    • RawTextSender

      public RawTextSender()
  • Method Details

    • main

      public static void main(String[] args)
    • org$apache$spark$internal$Logging$$log_

      public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
    • org$apache$spark$internal$Logging$$log__$eq

      public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
    • LogStringContext

      public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)