wayground logo

Free Printable Worksheets

Font size

S
M
L
XL
Worksheets

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

Total questions: 106

Worksheet time: 53mins

Name
Class
Date
1.

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

a)

start()

b)

submit()

c)

execute()

d)

launch()

e)

run()

2.

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

a)

DStream

b)

RDD

c)

DataFrame

d)

Dataset

e)

Table

3.

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

a)

transform()

b)

filter()

c)

collect()

d)

join()

e)

map()

4.

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

a)

stop()

b)

halt()

c)

pause()

d)

end()

e)

terminate()

5.

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

a)

count()

b)

map()

c)

filter()

d)

reduce()

e)

sum()

6.

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

a)

textFileStream()

b)

read.csv()

c)

jsonFile()

d)

parquetFile()

e)

jdbc()

7.

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

a)

join()

b)

union()

c)

map()

d)

filter()

e)

groupBy()

8.

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

a)

createDataFrame()

b)

collect()

c)

map()

d)

filter()

e)

reduce()

9.

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

a)

foreachRDD()

b)

join()

c)

union()

d)

filter()

e)

map()

10.

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

a)

window()

b)

filter()

c)

map()

d)

join()

e)

groupBy()

11.

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

a)

ORDER BY

b)

GROUP BY

c)

DISTINCT

d)

JOIN

e)

FILTER BY

12.

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

a)

reduceByWindow()

b)

map()

c)

join()

d)

filter()

e)

collect()

13.

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

a)

filter()

b)

map()

14.

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

a)

filter()

b)

map()

c)

reduce()

d)

collect()

15.

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

a)

Receiver

b)

Executor

c)

Worker

d)

Driver

e)

Cluster Manager

16.

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

a)

SELECT

b)

JOIN

c)

GROUP BY

d)

DISTINCT

e)

ORDER BY

17.

DStream-ді кілт бойынша топтастыратын Spark Streaming-да қай әдіс пайдаланылады?

a)

reduceByKey()

b)

map()

c)

filter()

d)

collect()

18.

Spark Streaming-да деректер ағынында орташа мәнді есептеуге мүмкіндік беретін функция қандай?

a)

averageByKey()

b)

reduce()

c)

count()

d)

map()

e)

collect()

19.

Spark SQL-да дерекқордан кестені жою үшін қай әдіс пайдаланылады?

a)

DROP TABLE

b)

DELETE TABLE

c)

REMOVE TABLE

d)

TRUNCATE TABLE

e)

CLEAR TABLE

20.

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

a)

window()

b)

reduce()

c)

map()

d)

filter()

e)

collect()

21.

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

a)

StringType

b)

IntegerType

c)

BooleanType

d)

FloatType

e)

DateType

22.

Spark SQL-да кестеде бірегей(уникальный) жазбаларды санау үшін қай әдіс пайдаланылады?

a)

COUNT(DISTINCT)

b)

COUNT(ALL)

c)

SUM(DISTINCT)

d)

AVG(ALL)

e)

TOTAL(DISTINCT)

23.

Spark DataFrame-да алғашқы N жазбаларды шығару үшін қай әдіс пайдаланылады?

a)

show(N)

b)

collect(N)

c)

display(N)

d)

print(N)

e)

fetch(N)

24.

Spark SQL-да бағанды қайта атау үшін қандай кілт сөз пайдаланылады?

a)

AS

b)

WITH

c)

LIKE

d)

RENAME

e)

DEFINE

25.

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

a)

AVG

b)

SUM

c)

MIN

d)

MAX

e)

COUNT

26.

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

a)

AVG

b)

SUM

c)

MIN

d)

MAX

e)

COUNT

27.

Spark SQL-да көрсетілген бағандарда сәйкес мәндері бар жолдарды біріктіретін әдіс қандай?

a)

JOIN

b)

UNION

c)

INTERSECT

d)

COMBINE

e)

MERGE

28.

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

a)

groupBy()

b)

collect()

c)

join()

d)

map()

e)

union()

29.

Spark SQL-да бағандағы максималды мәнді қайтаратын функция қандай?

a)

MAX

b)

MIN

c)

AVG

d)

SUM

e)

COUNT

30.

DataFrame-да деректерді кеміту бойынша сұрыптау үшін қай әдіс пайдаланылады?

a)

orderBy(desc())

b)

groupBy(desc())

c)

sort(desc())

d)

filter(desc())

e)

arrange(desc())

31.

Spark SQL-да бағандағы мәндердің қосындысын есептеу үшін қай әдіс пайдаланылады?

a)

SUM

b)

AVG

c)

MAX

d)

MIN

e)

COUNT

32.

Spark SQL-да бағандағы бірегей(уникальные) мәндерді таңдау үшін қай әдіс пайдаланылады?

a)

DISTINCT

b)

SELECT

c)

UNIQUE

d)

COLLECT

e)

FILTER

33.

Сол жақ DataFrame-мен сәйкес келетін барлық жолдарды біріктіретін қосылу түрі қандай?

a)

LEFT JOIN

b)

INNER JOIN

c)

RIGHT JOIN

d)

FULL JOIN

e)

CROSS JOIN

34.

Жолдарды фильтрлеу үшін Spark SQL-да қай әдіс пайдаланылады?

a)

filter()

b)

collect()

c)

reduce()

d)

map()

e)

apply()

35.

SQL-де қай кілт сөз таңдау нәтижесіндегі қайталанатын жолдарды жою үшін пайдаланылады?

a)

DISTINCT

b)

UNIQUE

c)

REMOVE

d)

DELETE

e)

EXCEPT

36.

DataFrame-ды RDD-ге түрлендіру үшін қай әдіс пайдаланылады?

a)

rdd

b)

toRDD()

c)

convertToRDD()

d)

asRDD()

e)

createRDD()

37.

Деректерді бағандар бойынша агрегациялау үшін Spark SQL-да қай әдіс пайдаланылады?

a)

groupBy()

b)

select()

c)

filter()

d)

collect()

e)

join()

38.

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

a)

createDataFrame()

b)

collect()

c)

union()

d)

filter()

39.

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

a)

createDataFrame()

b)

collect()

c)

union()

d)

filter()

e)

transform()

40.

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

a)

split()

b)

divide()

c)

par&&on()

d)

branch()

e)

segment()

41.

Spark Streaming-да деректерді уақыт аралықтарына негізделген өңдеу үшін қай әдіс пайдаланылады?

a)

window()

b)

&me()

c)

interval()

d)

session()

e)

range()

42.

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

a)

union()

b)

join()

c)

collect()

d)

filter()

e)

reduce()

43.

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

a)

map()

b)

filter()

c)

union()

d)

collect()

e)

reduce()

44.

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

a)

reduceByKeyAndWindow()

b)

count()

c)

collect()

d)

map()

e)

join()

45.

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

a)

count()

b)

map()

c)

filter()

d)

collect()

e)

reduce()

46.

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

a)

stop()

b)

pause()

c)

exit()

d)

terminate()

e)

shutdown()

47.

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

a)

print()

b)

write()

c)

show()

d)

display()

e)

output()

48.

Spark Streaming-да уақыт терезелері бойынша агрегаттарды жасауға мүмкіндік беретін әдіс қандай?

a)

window()

b)

&meWindow()

c)

interval()

d)

range()

e)

period()

49.

Spark Streaming-да деректерді дерекқорға жіберуге мүмкіндік беретін әдіс қандай?

a)

foreachRDD()

b)

union()

c)

map()

d)

filter()

e)

collect()

50.

Кілттерге негізделген деректер ағындарын біріктіру үшін қай әдіс пайдаланылады?

a)

join()

b)

union()

c)

collect()

d)

filter()

e)

map()

51.

Кілттерге негізделген деректер ағындарын біріктіру үшін қай әдіс пайдаланылады?

a)

join()

b)

union()

c)

collect()

d)

filter()

e)

map()

52.

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

a)

window()

b)

session()

c)

&me()

d)

interval()

e)

slice()

53.

Spark SQL-да уақытша кесте жасау үшін қай әдіс пайдаланылады?

a)

createOrReplaceTempView()

b)

select()

c)

join()

d)

filter()

e)

map()

54.

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

a)

reduceByKey()

b)

union()

c)

collect()

d)

map()

e)

filter()

55.

Spark SQL-да бірдей схемалары бар екі DataFrame-ді біріктіру үшін қай әдіс пайдаланылады?

a)

UNION

b)

JOIN

c)

CONCAT

d)

MERGE

e)

INTERSECT

56.

Spark SQL-да барлық жазбаларды төмендетілген тәртіпте шығару үшін қай әдіс пайдаланылады?

a)

orderBy(desc())

b)

groupBy(desc())

c)

filter(desc())

d)

select(desc())

e)

arrange(desc())

57.

Spark Streaming-да уақыт аралығында оқиғаларды нақты уақытта өңдеу үшін қай әдіс пайдаланылады?

a)

window()

b)

&meInterval()

c)

eventTime()

d)

streamingWindow()

e)

realTime()

58.

Spark SQL-да шарттарға негізделген DataFrame-ден жазбаларды жою үшін қай әдіс пайдаланылады?

a)

filter()

b)

select()

c)

delete()

d)

remove()

e)

exclude()

59.

Spark-да SUM, AVG, MAX сияқты агрегаттық функцияларды орындау үшін қай әдіс пайдаланылады?

a)

agg()

b)

reduce()

c)

apply()

d)

group()

e)

collect()

60.

Spark SQL-да өнімділікті оңтайландыру үшін кэшталған DataFrame жасау үшін қай әдіс пайдаланылады?

a)

cache()

b)

store()

c)

save()

d)

persist()

e)

buffer()

61.

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

a)

BIGINT

b)

SMALLINT

c)

INT

d)

TINYINT

e)

MEDIUMINT

62.

Spark Streaming-да ағындағы бірегей мәндерді санау үшін қай функция пайдаланылады?

a)

countByValue()

b)

sumByValue()

c)

avgByValue()

63.

Spark Streaming-да ағындағы бірегей мәндерді санау үшін қай функция пайдаланылады?

a)

countByValue()

b)

sumByValue()

c)

avgByValue()

d)

uniqueCount()

e)

totalDistinct()

64.

Spark-да ағымдағы SQL сессиясын жаңарту үшін қай әдіс пайдаланылады?

a)

refreshTable()

b)

updateSession()

c)

clearCache()

d)

renewSession()

e)

reloadSession()

65.

Spark SQL-да мәндерді дөңгелектеу операциясын орындауға арналған әдіс қандай?

a)

round()

b)

ceil()

c)

floor()

d)

truncate()

e)

adjust()

66.

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

a)

json()

b)

parse()

c)

loadJson()

d)

readJson()

e)

fetchJson()

67.

Spark SQL-да DataFrame-дегі жолдарды кілттік мәндерге негізделген біріктіру үшін қай әдіс пайдаланылады?

a)

JOIN

b)

UNION

c)

GROUP BY

d)

MERGE

e)

ORDER BY

68.

Spark SQL-да DataFrame-дағы бағандардың тәртібін өзгерту үшін қай әдіс пайдаланылады?

a)

select()

b)

arrange()

c)

orderBy()

d)

groupBy()

e)

sortBy()

69.

Spark SQL-да белгілі бір шартқа сәйкес келетін жолдарды таңдау үшін қай әдіс пайдаланылады?

a)

filter()

b)

groupBy()

c)

orderBy()

d)

limit()

e)

range()

70.

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

a)

innerJoin()

b)

concat()

c)

zip()

d)

add()

e)

insert()

71.

Spark Streaming-да Apache Kafka-мен интеграцияны қолдайтын әдіс қандай?

a)

readStream()

b)

writeStream()

c)

startStream()

d)

runStream()

e)

processStream()

72.

Spark SQL-да DataFrame-ге тұрақты деректерді қосу үшін қай әдіс пайдаланылады?

a)

withColumn()

b)

select()

c)

create()

d)

fill()

e)

append()

73.

Spark SQL-да DataFrame-дегі жазбалардың санын санау үшін қай әдіс пайдаланылады?

a)

count()

b)

sum()

c)

total()

d)

numberOfRecords()

e)

countRecords()

74.

Spark SQL-да бағанда минималды мәнді есептеу үшін қай әдіс пайдаланылады?

a)

MIN

b)

AVG

c)

SUM

75.

Spark SQL-да бағанда минималды мәнді есептеу үшін қай әдіс пайдаланылады?

a)

MIN

b)

AVG

c)

SUM

d)

MAX

e)

COUNT

76.

Spark SQL-да шарт бойынша жолдарды сүзу үшін қай әдіс пайдаланылады?

a)

filter()

b)

groupBy()

c)

orderBy()

d)

collect()

e)

select()

77.

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

a)

foreachBatch()

b)

save()

c)

store()

d)

update()

e)

collectBatch()

78.

Spark SQL-да бар DataFrame-ге деректерді қосу үшін қай әдіс пайдаланылады?

a)

union()

b)

append()

c)

add()

d)

insert()

e)

combine()

79.

Spark Streaming-да мәтін форматындағы жолдарды өңдеу үшін қай әдіс пайдаланылады?

a)

textFileStream()

b)

readText()

c)

parseText()

d)

fileStream()

e)

collectText()

80.

Spark SQL-да шарттарға негізделген жолдарды біріктіру үшін қай әдіс пайдаланылады?

a)

JOIN

b)

UNION

c)

SELECT

d)

GROUP BY

e)

FILTER

81.

Spark SQL-да екі DataFrame-нің жолдарын қиылыстыру үшін қай әдіс пайдаланылады?

a)

intersect()

b)

union()

c)

merge()

d)

combine()

e)

join()

82.

Spark SQL-да DataFrame-дегі деректерді өсу тәртібімен сұрыптау үшін қай әдіс пайдаланылады?

a)

orderBy()

b)

groupBy()

c)

collect()

d)

filter()

e)

sortBy()

83.

Spark Streaming-да Apache KaŒa-дан деректерді өңдеу үшін қай әдіс пайдаланылады?

a)

readStream()

b)

readKaŒa()

c)

collectStream()

d)

processKaŒa()

e)

fetchStream()

84.

Spark SQL-да бағанда уникалды мәндердің санын санау үшін қай әдіс пайдаланылады?

a)

countDis&nct()

b)

uniqueCount()

c)

dis&nctCount()

d)

sumDis&nct()

e)

countUnique()

85.

Spark SQL-да бірнеше DataFrame-ді біріктіру операцияларын орындау үшін қай әдіс пайдаланылады?

a)

union()

b)

join()

c)

concat()

d)

merge()

e)

link()

86.

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

a)

outputMode()

b)

consoleOutp

87.

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

a)

outputMode()

b)

consoleOutput()

c)

sendToConsole()

d)

display()

e)

printToConsole™

88.

Spark SQL-да деректерді күрделі фильтрлермен өңдеу үшін қай әдіс пайдаланылады?

a)

where()

b)

select()

c)

join()

d)

order()

e)

range()

89.

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

a)

aggregate()

b)

union()

c)

reduce()

d)

map()

e)

join()

90.

Spark SQL-да екі DataFrame арасындағы жолдарды қиып алу үшін қай әдіс пайдаланылады?

a)

intersect()

b)

union()

c)

merge()

d)

collect()

e)

zip()

91.

Spark SQL-да DataFrame-да уникалды мәндерді фильтрлеу үшін қай әдіс пайдаланылады?

a)

dropDuplicates()

b)

collect()

c)

unique()

d)

filterDistinct()

e)

removeDuplicates()

92.

Spark SQL-да деректерді талдау жүргізу үшін қай әдіс пайдаланылады?

a)

groupBy()

b)

collect()

c)

select()

d)

show()

e)

reduce()

93.

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

a)

fileStream()

b)

textStream()

c)

readFile()

d)

openStream()

e)

fetchFile()

94.

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

a)

groupBy()

b)

orderBy()

c)

count()

d)

filter()

e)

aggregateBy()

95.

Spark SQL-да бағанның атын өзгерту үшін қай әдіс пайдаланылады?

a)

withColumnRenamed()

b)

select()

c)

rename()

d)

updateColumn()

e)

changeColumnName()

96.

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

a)

outputMode("console")

b)

display()

c)

show()

d)

log()

e)

consoleDisplay()

97.

Spark SQL-да бағанның деректер типін өзгерту үшін қай әдіс пайдаланылады?

a)

cast()

b)

convert()

c)

changeType()

d)

transform()

e)

updateType™

98.

Spark-тың қай компоненті кластердегі орындаушылар арасында тапсырмаларды бөлуге жауап береді?

a)

Драйвер (Driver)

b)

Экзекьютор (Executor)

c)

Плэйсхолдер (Placeholder)

d)

Разделитель (Par&&oner)

e)

Менеджер кластера (Cluster Manager)

99.

Spark-да сұраныстарды орындау жоспарларын оңтайландыру үшін қай механизм пайдаланылады?

a)

Catalyst

b)

Tungsten

c)

Core

d)

Shuffle

e)

Streaming

100.

Tungsten жобасындағы қай оптимизация деңгейі жадпен және процессормен жұмысты оңтайландырады?

a)

Физикалық оптимизация деңгейі

b)

Логикалық деңгей

c)

SQL деңгей

d)

Аналитикалық деңгей

e)

Пайдаланушылық(пользовательский) деңгей

101.

Spark-тың қай компоненті кластердің ресурстарын басқаруға жауап береді?

a)

Cluster Manager

b)

Driver

c)

Executor

d)

Scheduler

e)

DataFrame API

102.

Spark-да үлкен деректер жиынтығын кішігірім бөліктерге бөлу үшін қай әдіс пайдаланылады?

a)

par&&onBy()

b)

cache()

c)

aggregate()

d)

shuffle()

e)

join()

103.

Spark-тың қай компоненті DataFrame және Dataset-термен операцияларды өңдейді және жоспарлайды?

a)

Catalyst

b)

Tungsten

c)

Core

d)

Par&&on

e)

DataFrame

104.

Tungsten-да өнімділікті арттыру үшін қандай оптимизация векторизацияны пайдаланады?

a)

Векторизация (Vectoriza&on)

b)

Кодогенерация (Code Genera&on)

c)

Деректерді сжатие (Data Compression)

d)

Жадты бөлу (Memory Alloca&on)

e)

Ағынмен беру (Streaming)

105.

Spark-та құрылымсыз деректермен жұмыс істеуге мүмкіндік беретін объект?

a)

DataFrame

b)

Dataset

c)

Table

d)

SQLContext

e)

Stream

106.

Catalyst-да сұраныс орындалу логикалық жоспарларын құру үшін қай әдіс пайдаланылады?

a)

LogicalPlan()

b)

PhysicalPlan()

c)

Execu&onPlan()

d)

PlanOp&mizer()

e)

QueryExecutor()