Spark Streaming бойынша тест

Spark Streaming қолданбасын іске қосу үшін қай əдіс пайдаланылады?

• start()

• submit()

• execute()

• launch()

• run()

Spark Streaming нақты уақыт режимінде деректерді беру үшін қандай деректер түрін қолдайды?

• DStream

• RDD

• DataFrame

• Dataset

• Table

Spark Streaming-да деректер ағындарын түрлендіретін функция қандай?

• transform()

• filter()

• collect()

• join()

• map()

Spark Streaming-да ағындық өңдеуді тоқтататын əдіс қандай?

• stop()

• halt()

• pause()

• end()

• terminate()

Spark Streaming-да элементтерді санау үшін қай әдіс пайдаланылады?

• count()

• map()

• filter()

• reduce()

• sum()

Файлдық жүйеден деректерді оқу үшін Spark Streaming-да қандай дереккөз қолдау көрсетіледі?

• textFileStream()

• read.csv()

• jsonFile()

• parquetFile()

• jdbc()

Spark Streaming-да екі деректер ағынын біріктіру үшін қай әдіс пайдаланылады?

• join()

• union()

• map()

• filter()

• groupBy()

Spark Streaming-да DStream-ді DataFrame-ге түрлендіретін әдіс қандай?

• createDataFrame()

• collect()

• map()

• filter()

• reduce()

Ағындық өңдеу нәтижелерін дерекқорға сақтау үшін қай функция пайдаланылады?

• foreachRDD()

• join()

• union()

• filter()

• map()

Spark Streaming-да уақыт аралықтарындағы оқиғаларды санау үшін қандай агрегация түрі қол жетімді?

• window()

• filter()

• map()

• join()

• groupBy()