RawTextSender (Spark 4.1.0-preview3 JavaDoc)

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 Summary

Constructors

Constructor

Description

RawTextSender()
Method Summary

Modifier and Type

Method

Description

static org.apache.spark.internal.Logging.LogStringContext

LogStringContext(scala.StringContext sc)

static void

main(String[] args)

static org.slf4j.Logger

org$apache$spark$internal$Logging$$log_()

static void

org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)

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

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)