Mastering Apache Flink, Learning Apache Flink

flink

book

5星 · 超过95%的资源需积分: 0 183 浏览量更新于2023-05-29 评论 2 收藏 5.88MB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

试读

229页

书名叫Mastering Apache Flink, Learning Apache Flink，英文高清版，支持复制

资源详情

资源评论

资源推荐

TableofContents
LearningApacheFlink
Credits
AbouttheAuthor
AbouttheReviewers
www.PacktPub.com
Whysubscribe?
CustomerFeedback
Preface
Whatthisbookcovers
Whatyouneedforthisbook
Whothisbookisfor
Conventions
Readerfeedback
Customersupport
Downloadingtheexamplecode
Downloadingthecolorimagesofthisbook
Errata
Piracy
Questions
1.IntroductiontoApacheFlink
History
Architecture
Distributedexecution
JobManager
Actorsystem
Scheduler
Checkpointing
Taskmanager
Jobclient
Features
Highperformance
Exactly-oncestatefulcomputation
Flexiblestreamingwindows
Faulttolerance
Memorymanagement
Optimizer
Streamandbatchinoneplatform
Libraries
Eventtimesemantics
Quickstartsetup
Pre-requisite
InstallingonWindows
InstallingonLinux

Clustersetup
SSHconfigurations
Javainstallation
Flinkinstallation
Configurations
Startingdaemons
AddingadditionalJob/TaskManagers
Stoppingdaemonsandcluster
Runningsampleapplication
Summary
2.DataProcessingUsingtheDataStreamAPI
Executionenvironment
Datasources
Socket-based
File-based
Transformations
Map
FlatMap
Filter
KeyBy
Reduce
Fold
Aggregations
Window
Globalwindows
Tumblingwindows
Slidingwindows
Sessionwindows
WindowAll
Union
Windowjoin
Split
Select
Project
Physicalpartitioning
Custompartitioning
Randompartitioning
Rebalancingpartitioning
Rescaling
Broadcasting
Datasinks
Eventtimeandwatermarks
Eventtime
Processingtime
Ingestiontime
Connectors
Kafkaconnector

Twitterconnector
RabbitMQconnector
ElasticSearchconnector
Embeddednodemode
Transportclientmode
Cassandraconnector
Usecase-sensordataanalytics
Summary
3.DataProcessingUsingtheBatchProcessingAPI
Datasources
File-based
Collection-based
Genericsources
Compressedfiles
Transformations
Map
Flatmap
Filter
Project
Reduceongroupeddatasets
Reduceongroupeddatasetsbyfieldpositionkey
Groupcombine
Aggregateonagroupedtupledataset
MinByonagroupedtupledataset
MaxByonagroupedtupledataset
Reduceonfulldataset
Groupreduceonafulldataset
Aggregateonafulltupledataset
MinByonafulltupledataset
MaxByonafulltupledataset
Distinct
Join
Cross
Union
Rebalance
Hashpartition
Rangepartition
Sortpartition
First-n
Broadcastvariables
Datasinks
Connectors
Filesystems
HDFS
AmazonS3
Alluxio
Avro

MicrosoftAzurestorage
MongoDB
Iterations
Iteratoroperator
Deltaiterator
Usecase-AthletesdatainsightsusingFlinkbatchAPI
Summary
4.DataProcessingUsingtheTableAPI
Registeringtables
Registeringadataset
Registeringadatastream
Registeringatable
Registeringexternaltablesources
CSVtablesource
KafkaJSONtablesource
Accessingtheregisteredtable
Operators
Theselectoperator
Thewhereoperator
Thefilteroperator
Theasoperator
ThegroupByoperator
Thejoinoperator
TheleftOuterJoinoperator
TherightOuterJoinoperator
ThefullOuterJoinoperator
Theunionoperator
TheunionAlloperator
Theintersectoperator
TheintersectAlloperator
Theminusoperator
TheminusAlloperator
Thedistinctoperator
TheorderByoperator
Thelimitoperator
Datatypes
SQL
SQLondatastream
SupportedSQLsyntax
Scalarfunctions
ScalarfunctionsinthetableAPI
ScalafunctionsinSQL
Usecase-AthletesdatainsightsusingFlinkTableAPI
Summary
5.ComplexEventProcessing
Whatiscomplexeventprocessing?
FlinkCEP