Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
CREATE STREAM twitter_raw
(CreatedAt bigint,
Id bigint,
Text VARCHAR,
SOURCE VARCHAR,
Truncated VARCHAR,
InReplyToStatusId VARCHAR,
InReplyToUserId VARCHAR,
InReplyToScreenName VARCHAR,
GeoLocation VARCHAR,
Place VARCHAR,
Favorited VARCHAR,
Retweeted VARCHAR,
FavoriteCount VARCHAR,
User VARCHAR,
Retweet VARCHAR,
Contributors VARCHAR,
RetweetCount VARCHAR,
RetweetedByMe VARCHAR,
CurrentUserRetweetId VARCHAR,
PossiblySensitive VARCHAR,
Lang VARCHAR,
WithheldInCountries VARCHAR,
HashtagEntities VARCHAR,
UserMentionEntities VARCHAR,
MediaEntities VARCHAR,
SymbolEntities VARCHAR,
URLEntities VARCHAR)
WITH (KAFKA_TOPIC='twitter_json_01',
VALUE_FORMAT='JSON');
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment