Twitter Source () reads streaming tweet data in real time from Twitter (now known as X).
It connects using Twitter’s Streaming APIs and filters tweets based on language, keywords, and selected fields.

Parameters of Twitter Source

• Language
  Language code of tweet status (e.g. en, id, fr)
  Only tweets matching the specified language are read
• Selected Fields
  Fields of the tweet status to be extracted
  Examples:
  • id
  • text
  • created_at
  • user.name
  • retweet_count
  • favorite_count
• Selected Term
  Keyword or term that must appear in the tweet
  Used to filter the Twitter stream in real time
• Consumer Key
  Twitter application Consumer Key
  Required for OAuth authentication
• Consumer Secret
  Twitter application Consumer Secret
• Toke
  Access Token for the Twitter bot/application
• Token Secret
  Access Token Secret for the Twitter bot/application

Supported Engines

Map Reduce	Spark 1.x RDD	Spark 2.x RDD	Spark 2.x Dataset	Apache Beam 2.29.0 Batch	Apache Beam 2.29.0 Streaming	Apache Flink 1.12.0 Batch	Apache Flink 1.12.0 Streaming	Apache Tez 0.9.1	PySpark