Font size
WorksheetsSpark Streaming бойынша тест
Total questions: 106
Worksheet time: 53mins
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()
Spark SQL-да деректерді сұрыптау үшін қай әдіс пайдаланылады?
ORDER BY
GROUP BY
DISTINCT
JOIN
FILTER BY
Spark Streaming-да уақыт терезелері бойынша деректерді агрегаттау үшін қай әдіс пайдаланылады?
reduceByWindow()
map()
join()
filter()
collect()
Spark Streaming-да деректер ағындарын фильтрлеу үшін қай әдіс пайдаланылады?
filter()
map()
Spark Streaming-да деректер ағындарын фильтрлеу үшін қай әдіс пайдаланылады?
filter()
map()
reduce()
collect()
Spark Streaming-да деректерді қабылдау және беру үшін қай компонент жауапты?
Receiver
Executor
Worker
Driver
Cluster Manager
SQL-кестесінен деректерді алу үшін қай Spark SQL әдісі пайдаланылады?
SELECT
JOIN
GROUP BY
DISTINCT
ORDER BY
DStream-ді кілт бойынша топтастыратын Spark Streaming-да қай әдіс пайдаланылады?
reduceByKey()
map()
filter()
collect()
Spark Streaming-да деректер ағынында орташа мәнді есептеуге мүмкіндік беретін функция қандай?
averageByKey()
reduce()
count()
map()
collect()
Spark SQL-да дерекқордан кестені жою үшін қай әдіс пайдаланылады?
DROP TABLE
DELETE TABLE
REMOVE TABLE
TRUNCATE TABLE
CLEAR TABLE
Spark Streaming-да деректерді уақыт аралығында біріктіретін функция қандай?
window()
reduce()
map()
filter()
collect()
Spark SQL-да мәтін деректерін көрсету үшін қандай деректер түрі пайдаланылады?
StringType
IntegerType
BooleanType
FloatType
DateType
Spark SQL-да кестеде бірегей(уникальный) жазбаларды санау үшін қай әдіс пайдаланылады?
COUNT(DISTINCT)
COUNT(ALL)
SUM(DISTINCT)
AVG(ALL)
TOTAL(DISTINCT)
Spark DataFrame-да алғашқы N жазбаларды шығару үшін қай әдіс пайдаланылады?
show(N)
collect(N)
display(N)
print(N)
fetch(N)
Spark SQL-да бағанды қайта атау үшін қандай кілт сөз пайдаланылады?
AS
WITH
LIKE
RENAME
DEFINE
Spark SQL-да орташа мәнді есептеу үшін қай әдіс пайдаланылады?
AVG
SUM
MIN
MAX
COUNT
Spark SQL-да орташа мәнді есептеу үшін қай әдіс пайдаланылады?
AVG
SUM
MIN
MAX
COUNT
Spark SQL-да көрсетілген бағандарда сәйкес мәндері бар жолдарды біріктіретін әдіс қандай?
JOIN
UNION
INTERSECT
COMBINE
MERGE
Spark DataFrame-да деректерді топтастыру үшін қай әдіс пайдаланылады?
groupBy()
collect()
join()
map()
union()
Spark SQL-да бағандағы максималды мәнді қайтаратын функция қандай?
MAX
MIN
AVG
SUM
COUNT
DataFrame-да деректерді кеміту бойынша сұрыптау үшін қай әдіс пайдаланылады?
orderBy(desc())
groupBy(desc())
sort(desc())
filter(desc())
arrange(desc())
Spark SQL-да бағандағы мәндердің қосындысын есептеу үшін қай әдіс пайдаланылады?
SUM
AVG
MAX
MIN
COUNT
Spark SQL-да бағандағы бірегей(уникальные) мәндерді таңдау үшін қай әдіс пайдаланылады?
DISTINCT
SELECT
UNIQUE
COLLECT
FILTER
Сол жақ DataFrame-мен сәйкес келетін барлық жолдарды біріктіретін қосылу түрі қандай?
LEFT JOIN
INNER JOIN
RIGHT JOIN
FULL JOIN
CROSS JOIN
Жолдарды фильтрлеу үшін Spark SQL-да қай әдіс пайдаланылады?
filter()
collect()
reduce()
map()
apply()
SQL-де қай кілт сөз таңдау нәтижесіндегі қайталанатын жолдарды жою үшін пайдаланылады?
DISTINCT
UNIQUE
REMOVE
DELETE
EXCEPT
DataFrame-ды RDD-ге түрлендіру үшін қай әдіс пайдаланылады?
rdd
toRDD()
convertToRDD()
asRDD()
createRDD()
Деректерді бағандар бойынша агрегациялау үшін Spark SQL-да қай әдіс пайдаланылады?
groupBy()
select()
filter()
collect()
join()
Spark Streaming-да деректер ағынын DataFrame-ге түрлендіретін әдіс қандай?
createDataFrame()
collect()
union()
filter()
Spark Streaming-да деректер ағынын DataFrame-ге түрлендіретін әдіс қандай?
createDataFrame()
collect()
union()
filter()
transform()
Spark Streaming-да ағынды бірнеше ағынға бөлу үшін қай әдіс пайдаланылады?
split()
divide()
par&&on()
branch()
segment()
Spark Streaming-да деректерді уақыт аралықтарына негізделген өңдеу үшін қай әдіс пайдаланылады?
window()
&me()
interval()
session()
range()
Spark Streaming-да екі деректер ағынын бір ағынға біріктіруге мүмкіндік беретін әдіс қандай?
union()
join()
collect()
filter()
reduce()
Spark Streaming-да ағындағы әр элементті түрлендіру үшін қай әдіс пайдаланылады?
map()
filter()
union()
collect()
reduce()
Spark Streaming-да ағындағы деректердің орташа мәнін есептеуге мүмкіндік беретін әдіс қандай?
reduceByKeyAndWindow()
count()
collect()
map()
join()
Spark Streaming-да ағындағы барлық элементтерді санау үшін қай әдіс пайдаланылады?
count()
map()
filter()
collect()
reduce()
Spark Streaming-да ағындық қосымшаны тоқтату үшін қай әдіс пайдаланылады?
stop()
pause()
exit()
terminate()
shutdown()
Spark Streaming-да деректерді нақты уақытта шығару үшін қай әдіс пайдаланылады?
print()
write()
show()
display()
output()
Spark Streaming-да уақыт терезелері бойынша агрегаттарды жасауға мүмкіндік беретін әдіс қандай?
window()
&meWindow()
interval()
range()
period()
Spark Streaming-да деректерді дерекқорға жіберуге мүмкіндік беретін әдіс қандай?
foreachRDD()
union()
map()
filter()
collect()
Кілттерге негізделген деректер ағындарын біріктіру үшін қай әдіс пайдаланылады?
join()
union()
collect()
filter()
map()
Кілттерге негізделген деректер ағындарын біріктіру үшін қай әдіс пайдаланылады?
join()
union()
collect()
filter()
map()
Spark Streaming-да жаңа терезелер жасау үшін қай әдіс пайдаланылады?
window()
session()
&me()
interval()
slice()
Spark SQL-да уақытша кесте жасау үшін қай әдіс пайдаланылады?
createOrReplaceTempView()
select()
join()
filter()
map()
Spark Streaming-да кілттер бойынша операцияларды орындау үшін қай әдіс пайдаланылады?
reduceByKey()
union()
collect()
map()
filter()
Spark SQL-да бірдей схемалары бар екі DataFrame-ді біріктіру үшін қай әдіс пайдаланылады?
UNION
JOIN
CONCAT
MERGE
INTERSECT
Spark SQL-да барлық жазбаларды төмендетілген тәртіпте шығару үшін қай әдіс пайдаланылады?
orderBy(desc())
groupBy(desc())
filter(desc())
select(desc())
arrange(desc())
Spark Streaming-да уақыт аралығында оқиғаларды нақты уақытта өңдеу үшін қай әдіс пайдаланылады?
window()
&meInterval()
eventTime()
streamingWindow()
realTime()
Spark SQL-да шарттарға негізделген DataFrame-ден жазбаларды жою үшін қай әдіс пайдаланылады?
filter()
select()
delete()
remove()
exclude()
Spark-да SUM, AVG, MAX сияқты агрегаттық функцияларды орындау үшін қай әдіс пайдаланылады?
agg()
reduce()
apply()
group()
collect()
Spark SQL-да өнімділікті оңтайландыру үшін кэшталған DataFrame жасау үшін қай әдіс пайдаланылады?
cache()
store()
save()
persist()
buffer()
Spark SQL-да үлкен сандарды сақтау үшін қай деректер түрі пайдаланылады?
BIGINT
SMALLINT
INT
TINYINT
MEDIUMINT
Spark Streaming-да ағындағы бірегей мәндерді санау үшін қай функция пайдаланылады?
countByValue()
sumByValue()
avgByValue()
Spark Streaming-да ағындағы бірегей мәндерді санау үшін қай функция пайдаланылады?
countByValue()
sumByValue()
avgByValue()
uniqueCount()
totalDistinct()
Spark-да ағымдағы SQL сессиясын жаңарту үшін қай әдіс пайдаланылады?
refreshTable()
updateSession()
clearCache()
renewSession()
reloadSession()
Spark SQL-да мәндерді дөңгелектеу операциясын орындауға арналған әдіс қандай?
round()
ceil()
floor()
truncate()
adjust()
Spark Streaming-да ағындағы JSON деректерін өңдеу үшін қай әдіс пайдаланылады?
json()
parse()
loadJson()
readJson()
fetchJson()
Spark SQL-да DataFrame-дегі жолдарды кілттік мәндерге негізделген біріктіру үшін қай әдіс пайдаланылады?
JOIN
UNION
GROUP BY
MERGE
ORDER BY
Spark SQL-да DataFrame-дағы бағандардың тәртібін өзгерту үшін қай әдіс пайдаланылады?
select()
arrange()
orderBy()
groupBy()
sortBy()
Spark SQL-да белгілі бір шартқа сәйкес келетін жолдарды таңдау үшін қай әдіс пайдаланылады?
filter()
groupBy()
orderBy()
limit()
range()
Spark SQL-да DataFrame-ді бағандардағы мәндер бойынша біріктіру үшін қай әдіс пайдаланылады?
innerJoin()
concat()
zip()
add()
insert()
Spark Streaming-да Apache Kafka-мен интеграцияны қолдайтын әдіс қандай?
readStream()
writeStream()
startStream()
runStream()
processStream()
Spark SQL-да DataFrame-ге тұрақты деректерді қосу үшін қай әдіс пайдаланылады?
withColumn()
select()
create()
fill()
append()
Spark SQL-да DataFrame-дегі жазбалардың санын санау үшін қай әдіс пайдаланылады?
count()
sum()
total()
numberOfRecords()
countRecords()
Spark SQL-да бағанда минималды мәнді есептеу үшін қай әдіс пайдаланылады?
MIN
AVG
SUM
Spark SQL-да бағанда минималды мәнді есептеу үшін қай әдіс пайдаланылады?
MIN
AVG
SUM
MAX
COUNT
Spark SQL-да шарт бойынша жолдарды сүзу үшін қай әдіс пайдаланылады?
filter()
groupBy()
orderBy()
collect()
select()
Spark Streaming-да ағынды дерекқорға қосу үшін қай әдіс пайдаланылады?
foreachBatch()
save()
store()
update()
collectBatch()
Spark SQL-да бар DataFrame-ге деректерді қосу үшін қай әдіс пайдаланылады?
union()
append()
add()
insert()
combine()
Spark Streaming-да мәтін форматындағы жолдарды өңдеу үшін қай әдіс пайдаланылады?
textFileStream()
readText()
parseText()
fileStream()
collectText()
Spark SQL-да шарттарға негізделген жолдарды біріктіру үшін қай әдіс пайдаланылады?
JOIN
UNION
SELECT
GROUP BY
FILTER
Spark SQL-да екі DataFrame-нің жолдарын қиылыстыру үшін қай әдіс пайдаланылады?
intersect()
union()
merge()
combine()
join()
Spark SQL-да DataFrame-дегі деректерді өсу тәртібімен сұрыптау үшін қай әдіс пайдаланылады?
orderBy()
groupBy()
collect()
filter()
sortBy()
Spark Streaming-да Apache Kaa-дан деректерді өңдеу үшін қай әдіс пайдаланылады?
readStream()
readKaa()
collectStream()
processKaa()
fetchStream()
Spark SQL-да бағанда уникалды мәндердің санын санау үшін қай әдіс пайдаланылады?
countDis&nct()
uniqueCount()
dis&nctCount()
sumDis&nct()
countUnique()
Spark SQL-да бірнеше DataFrame-ді біріктіру операцияларын орындау үшін қай әдіс пайдаланылады?
union()
join()
concat()
merge()
link()
Spark Streaming-да ағынды деректердің нәтижелерін консольға жіберу үшін қай әдіс пайдаланылады?
outputMode()
consoleOutp
Spark Streaming-да ағынды деректердің нәтижелерін консольға жіберу үшін қай әдіс пайдаланылады?
outputMode()
consoleOutput()
sendToConsole()
display()
printToConsole™
Spark SQL-да деректерді күрделі фильтрлермен өңдеу үшін қай әдіс пайдаланылады?
where()
select()
join()
order()
range()
Spark Streaming-да деректерді нақты уақыт режимінде агрегаттау үшін қай әдіс пайдаланылады?
aggregate()
union()
reduce()
map()
join()
Spark SQL-да екі DataFrame арасындағы жолдарды қиып алу үшін қай әдіс пайдаланылады?
intersect()
union()
merge()
collect()
zip()
Spark SQL-да DataFrame-да уникалды мәндерді фильтрлеу үшін қай әдіс пайдаланылады?
dropDuplicates()
collect()
unique()
filterDistinct()
removeDuplicates()
Spark SQL-да деректерді талдау жүргізу үшін қай әдіс пайдаланылады?
groupBy()
collect()
select()
show()
reduce()
Spark Streaming-да файлдардан ағынды деректерді өңдеу үшін қай әдіс пайдаланылады?
fileStream()
textStream()
readFile()
openStream()
fetchFile()
Spark SQL-да деректерді белгілі бір бағандарға сәйкес топтастыру үшін қай әдіс пайдаланылады?
groupBy()
orderBy()
count()
filter()
aggregateBy()
Spark SQL-да бағанның атын өзгерту үшін қай әдіс пайдаланылады?
withColumnRenamed()
select()
rename()
updateColumn()
changeColumnName()
Spark Streaming-да нәтижелерді консольға шығару үшін қай әдіс пайдаланылады?
outputMode("console")
display()
show()
log()
consoleDisplay()
Spark SQL-да бағанның деректер типін өзгерту үшін қай әдіс пайдаланылады?
cast()
convert()
changeType()
transform()
updateType™
Spark-тың қай компоненті кластердегі орындаушылар арасында тапсырмаларды бөлуге жауап береді?
Драйвер (Driver)
Экзекьютор (Executor)
Плэйсхолдер (Placeholder)
Разделитель (Par&&oner)
Менеджер кластера (Cluster Manager)
Spark-да сұраныстарды орындау жоспарларын оңтайландыру үшін қай механизм пайдаланылады?
Catalyst
Tungsten
Core
Shuffle
Streaming
Tungsten жобасындағы қай оптимизация деңгейі жадпен және процессормен жұмысты оңтайландырады?
Физикалық оптимизация деңгейі
Логикалық деңгей
SQL деңгей
Аналитикалық деңгей
Пайдаланушылық(пользовательский) деңгей
Spark-тың қай компоненті кластердің ресурстарын басқаруға жауап береді?
Cluster Manager
Driver
Executor
Scheduler
DataFrame API
Spark-да үлкен деректер жиынтығын кішігірім бөліктерге бөлу үшін қай әдіс пайдаланылады?
par&&onBy()
cache()
aggregate()
shuffle()
join()
Spark-тың қай компоненті DataFrame және Dataset-термен операцияларды өңдейді және жоспарлайды?
Catalyst
Tungsten
Core
Par&&on
DataFrame
Tungsten-да өнімділікті арттыру үшін қандай оптимизация векторизацияны пайдаланады?
Векторизация (Vectoriza&on)
Кодогенерация (Code Genera&on)
Деректерді сжатие (Data Compression)
Жадты бөлу (Memory Alloca&on)
Ағынмен беру (Streaming)
Spark-та құрылымсыз деректермен жұмыс істеуге мүмкіндік беретін объект?
DataFrame
Dataset
Table
SQLContext
Stream
Catalyst-да сұраныс орындалу логикалық жоспарларын құру үшін қай әдіс пайдаланылады?
LogicalPlan()
PhysicalPlan()
Execu&onPlan()
PlanOp&mizer()
QueryExecutor()
