AZ
Size: a a a
AZ
AZ
K
AZ
K
AZ
AZ
AZ
SS
NN
SS
NN
AG
DM
N
АБ
АБ
SparkSession spark = SparkSession.builder()
.appName("Read stream")
.master("local")
.getOrCreate();
Dataset<Row> df = spark
.readStream()
.format("socket")
.option("host", "localhost")
.option("port", 3001)
.load();
StreamingQuery query = df
.writeStream()
.outputMode(OutputMode.Append())
.format("console")
.start();
t
AS