Sahith Nallapareddy created BEAM-7963:
-----------------------------------------
Summary: Unnesting with large schema causes error
Key: BEAM-7963
URL: https://issues.apache.org/jira/browse/BEAM-7963
Project: Beam
Issue Type: Bug
Components: dsl-sql
Affects Versions: 2.16.0
Reporter: Sahith Nallapareddy
query: select id from table a, UNNEST(a.nested_field) this causes the following
error if table a has a relatively large schema, especially with either
Row<Array<Row>> or Array<Row<Array<Row>> (nested repeated records or records
with repeated records)
{noformat}
Aug 13, 2019 10:17:01 AM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO: SQL:
SELECT `a`.`artist_gid`
FROM `beam`.`endpoint1` AS `a`,
UNNEST(`a`.`genre`.`genres`) AS `genres`
Aug 13, 2019 10:17:01 AM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO: SQLPlan>
LogicalProject(artist_gid=[$0])
LogicalCorrelate(correlation=[$cor0], joinType=[inner],
requiredColumns=[{87}])
LogicalProject(artist_gid=[$0], artist_uri=[$1], date=[$2], id=[$3.id],
gid=[$3.gid], name=[$3.name], redirect=[$3.redirect], fuzzyname=[$3.fuzzyname],
inserted=[$3.inserted], echo_nest_artists=[$4], id10=[$5.id],
similars=[$5.similars], gid12=[$6.gid], version=[$6.version],
vector=[$6.vector], value=[$7.value], gid16=[$7.gid], domains=[$7.domains],
playlist_adds=[$8], uri=[$9.uri], gid20=[$9.gid], region=[$9.region],
popularity_raw=[$9.popularity_raw],
popularity_normalized=[$9.popularity_normalized], percentile=[$9.percentile],
rank=[$9.rank], popularity_regional=[$10], gid27=[$11.gid],
artist_name=[$11.artist_name], bios=[$11.bios],
ancestor_artists=[$11.ancestor_artists],
descendant_artists=[$11.descendant_artists],
asserted_similars=[$11.asserted_similars], tags=[$11.tags],
genres=[$11.genres], members=[$11.members], members_past=[$11.members_past],
meanings=[$11.meanings], country=[$11.country],
voted_descriptions=[$11.voted_descriptions], years_active=[$11.years_active],
amazon_urls=[$11.amazon_urls], itunes_urls=[$11.itunes_urls],
lastfm_urls=[$11.lastfm_urls], facebook_urls=[$11.facebook_urls],
urbandictionary_urls=[$11.urbandictionary_urls],
wikipedia_urls=[$11.wikipedia_urls],
twitter_screennames=[$11.twitter_screennames], categories=[$11.categories],
childrens=[$11.category.childrens], classical=[$11.category.classical],
curated=[$11.category.curated], deceptive=[$11.category.deceptive],
generic=[$11.category.generic], inactive=[$11.category.inactive],
karaoke=[$11.category.karaoke], non_artist=[$11.category.non_artist],
soundalike=[$11.category.soundalike], unpreferred=[$11.category.unpreferred],
offensive=[$11.category.offensive],
do_not_recommend=[$11.category.do_not_recommend],
do_not_support=[$11.category.do_not_support],
pass_on_programming=[$11.category.pass_on_programming],
deceased=[$11.category.deceased], edited_terms=[$11.edited_terms],
edited_text_terms=[$11.edited_text_terms],
free_text_terms=[$11.free_text_terms], display_terms=[$11.display_terms],
extra=[$11.extra], force_curated_sims=[$11.sims_curation.force_curated_sims],
curated_sims_uris=[$11.sims_curation.curated_sims_uris],
blacklisted_sims_uris=[$11.sims_curation.blacklisted_sims_uris],
display_bios=[$11.display_bios], discogs_uri=[$11.discogs_uri],
musicbrainz_uri=[$11.musicbrainz_uri], rovi_music_uri=[$11.rovi_music_uri],
blocked_display_bio_providers=[$11.blocked_display_bio_providers],
portrait=[$11.portrait], hidden_portraits=[$11.hidden_portraits],
primary_portrait=[$11.primary_portrait], imdb_urls=[$11.imdb_urls],
instagram_screennames=[$11.instagram_screennames],
myspace_urls=[$11.myspace_urls], tumblr_screennames=[$11.tumblr_screennames],
youtube_urls=[$11.youtube_urls], gid85=[$12.gid],
acousticVector=[$12.acousticVector], gid87=[$13.gid], genres88=[$13.genres],
extended_genres=[$13.extended_genres], currency=[$14])
BeamIOSourceRel(table=[[beam, endpoint1]])
Uncollect
LogicalProject(genres=[$cor0.genres_88])
LogicalValues(tuples=[[{ 0 }]])
org.apache.beam.sdk.extensions.sql.impl.SqlConversionException: Unable to
convert query select artist_gid from endpoint1 a, UNNEST(a.genre.genres) as
genres
at
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner.convertToBeamRel(CalciteQueryPlanner.java:170)
at
org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.parseQuery(BeamSqlEnv.java:103)
at
org.apache.beam.sdk.extensions.sql.SqlTransform.expand(SqlTransform.java:124)
at
org.apache.beam.sdk.extensions.sql.SqlTransform.expand(SqlTransform.java:82)
at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:539)
at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:473)
at
org.apache.beam.sdk.values.PCollectionTuple.apply(PCollectionTuple.java:248)
at com.spotify.data.sql.SqlExecutor.run(SqlExecutor.java:93)
at
com.spotify.data.sql.SqlExecutorTest.testBigQueryRow2(SqlExecutorTest.java:246)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
at
com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47)
at
com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
at
com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
Caused by:
org.apache.beam.repackaged.sql.org.apache.calcite.plan.RelOptPlanner$CannotPlanException:
There are not enough rules to produce a node with desired properties:
convention=BEAM_LOGICAL. All the inputs have relevant nodes, however the cost
is still infinite.
Root: rel#51:Subset#6.BEAM_LOGICAL
Original rel:
LogicalProject(subset=[rel#51:Subset#6.BEAM_LOGICAL], artist_gid=[$0]):
rowcount = 1.0, cumulative cost = {inf}, id = 49
LogicalCorrelate(subset=[rel#48:Subset#5.NONE], correlation=[$cor0],
joinType=[inner], requiredColumns=[{87}]): rowcount = 1.0, cumulative cost =
{inf}, id = 47
LogicalProject(subset=[rel#41:Subset#1.NONE], artist_gid=[$0],
artist_uri=[$1], date=[$2], id=[$3.id], gid=[$3.gid], name=[$3.name],
redirect=[$3.redirect], fuzzyname=[$3.fuzzyname], inserted=[$3.inserted],
echo_nest_artists=[$4], id10=[$5.id], similars=[$5.similars], gid12=[$6.gid],
version=[$6.version], vector=[$6.vector], value=[$7.value], gid16=[$7.gid],
domains=[$7.domains], playlist_adds=[$8], uri=[$9.uri], gid20=[$9.gid],
region=[$9.region], popularity_raw=[$9.popularity_raw],
popularity_normalized=[$9.popularity_normalized], percentile=[$9.percentile],
rank=[$9.rank], popularity_regional=[$10], gid27=[$11.gid],
artist_name=[$11.artist_name], bios=[$11.bios],
ancestor_artists=[$11.ancestor_artists],
descendant_artists=[$11.descendant_artists],
asserted_similars=[$11.asserted_similars], tags=[$11.tags],
genres=[$11.genres], members=[$11.members], members_past=[$11.members_past],
meanings=[$11.meanings], country=[$11.country],
voted_descriptions=[$11.voted_descriptions], years_active=[$11.years_active],
amazon_urls=[$11.amazon_urls], itunes_urls=[$11.itunes_urls],
lastfm_urls=[$11.lastfm_urls], facebook_urls=[$11.facebook_urls],
urbandictionary_urls=[$11.urbandictionary_urls],
wikipedia_urls=[$11.wikipedia_urls],
twitter_screennames=[$11.twitter_screennames], categories=[$11.categories],
childrens=[$11.category.childrens], classical=[$11.category.classical],
curated=[$11.category.curated], deceptive=[$11.category.deceptive],
generic=[$11.category.generic], inactive=[$11.category.inactive],
karaoke=[$11.category.karaoke], non_artist=[$11.category.non_artist],
soundalike=[$11.category.soundalike], unpreferred=[$11.category.unpreferred],
offensive=[$11.category.offensive],
do_not_recommend=[$11.category.do_not_recommend],
do_not_support=[$11.category.do_not_support],
pass_on_programming=[$11.category.pass_on_programming],
deceased=[$11.category.deceased], edited_terms=[$11.edited_terms],
edited_text_terms=[$11.edited_text_terms],
free_text_terms=[$11.free_text_terms], display_terms=[$11.display_terms],
extra=[$11.extra], force_curated_sims=[$11.sims_curation.force_curated_sims],
curated_sims_uris=[$11.sims_curation.curated_sims_uris],
blacklisted_sims_uris=[$11.sims_curation.blacklisted_sims_uris],
display_bios=[$11.display_bios], discogs_uri=[$11.discogs_uri],
musicbrainz_uri=[$11.musicbrainz_uri], rovi_music_uri=[$11.rovi_music_uri],
blocked_display_bio_providers=[$11.blocked_display_bio_providers],
portrait=[$11.portrait], hidden_portraits=[$11.hidden_portraits],
primary_portrait=[$11.primary_portrait], imdb_urls=[$11.imdb_urls],
instagram_screennames=[$11.instagram_screennames],
myspace_urls=[$11.myspace_urls], tumblr_screennames=[$11.tumblr_screennames],
youtube_urls=[$11.youtube_urls], gid85=[$12.gid],
acousticVector=[$12.acousticVector], gid87=[$13.gid], genres88=[$13.genres],
extended_genres=[$13.extended_genres], currency=[$14]): rowcount = 100.0,
cumulative cost = {inf}, id = 40
BeamIOSourceRel(subset=[rel#39:Subset#0.BEAM_LOGICAL], table=[[beam,
endpoint1]]): rowcount = 100.0, cumulative cost = {100.0 cpu, 0.0 cpuRate }, id
= 6
Uncollect(subset=[rel#46:Subset#4.NONE]): rowcount = 1.0, cumulative cost =
{inf}, id = 45
LogicalProject(subset=[rel#44:Subset#3.NONE], genres=[$cor0.genres_88]):
rowcount = 1.0, cumulative cost = {inf}, id = 43
LogicalValues(subset=[rel#42:Subset#2.NONE], tuples=[[{ 0 }]]):
rowcount = 1.0, cumulative cost = {inf}, id = 8
Sets:
Set#0, type: RecordType(VARCHAR artist_gid, VARCHAR artist_uri, VARCHAR date,
RecordType(BIGINT id, VARCHAR gid, VARCHAR name, BIGINT redirect, VARCHAR
fuzzyname, BIGINT inserted) metadata_artist, RecordType(VARCHAR en_id, VARCHAR
name, VARCHAR spotify_best_match_gid, VARCHAR ARRAY spotify_gids, VARCHAR ARRAY
aliases, VARCHAR ARRAY urls, RecordType(VARCHAR attribution_url, VARCHAR
attribution, RecordType(VARCHAR name, VARCHAR url, VARCHAR version) license,
VARCHAR biography, VARCHAR biography_site, VARCHAR biography_url) ARRAY
biographies, RecordType(VARCHAR name, VARCHAR language) ARRAY display_aliases,
RecordType(VARCHAR name, BIGINT rank, VARCHAR spotify_gid) ARRAY genres,
RecordType(VARCHAR name, BIGINT count, VARCHAR spotify_gid) ARRAY
inferred_genres, VARCHAR ARRAY meta_genres, VARCHAR ARRAY merge_names,
RecordType(VARCHAR en_id, DOUBLE score) ARRAY computed_similar_en_ids,
RecordType(VARCHAR key, VARCHAR value) ARRAY url_map, VARCHAR country, VARCHAR
country_code, DOUBLE latitude, DOUBLE longitude, VARCHAR location, VARCHAR
location_raw, VARCHAR region, VARCHAR town, RecordType(BIGINT start, BIGINT
stop) ARRAY years_active_ranges, RecordType(DOUBLE score, BIGINT rank)
discovery, RecordType(DOUBLE score, BIGINT rank) familiarity, RecordType(DOUBLE
score, BIGINT rank) hotttnesss, RecordType(VARCHAR name, DOUBLE frequency,
BIGINT weight) ARRAY display_top_terms, RecordType(VARCHAR name, DOUBLE
frequency, BIGINT weight) ARRAY edited_top_terms, RecordType(VARCHAR name,
DOUBLE frequency, BIGINT weight) ARRAY edited_text_top_terms,
RecordType(VARCHAR name, DOUBLE frequency, BIGINT weight) ARRAY
free_text_top_terms, VARCHAR ARRAY descendant_en_ids, VARCHAR ARRAY
crawled_genres, VARCHAR ARRAY ancestor_en_ids, VARCHAR ARRAY shared_members,
VARCHAR ARRAY members, VARCHAR ARRAY crawled_similar_en_ids, VARCHAR ARRAY
styles, VARCHAR ARRAY tags, BOOLEAN ambiguous, BOOLEAN kids_music, VARCHAR
ARRAY musicbrainz_ids) ARRAY echo_nest_artists, RecordType(VARCHAR id,
RecordType(VARCHAR id, DOUBLE score, RecordType(VARCHAR field,
RecordType(VARCHAR value, DOUBLE query_boost) ARRAY matched_values) ARRAY
explain_info, BOOLEAN curated) ARRAY similars) artist_sims, RecordType(VARCHAR
gid, VARCHAR version, DOUBLE ARRAY vector) vector, RecordType(BIGINT value,
VARCHAR gid, VARCHAR ARRAY domains) followers, RecordType(BIGINT value, VARCHAR
gid, VARCHAR country) ARRAY playlist_adds, RecordType(VARCHAR uri, VARCHAR gid,
VARCHAR region, DOUBLE popularity_raw, DOUBLE popularity_normalized, DOUBLE
percentile, BIGINT rank) popularity_global, RecordType(VARCHAR uri, VARCHAR
gid, VARCHAR region, DOUBLE popularity_raw, DOUBLE popularity_normalized,
DOUBLE percentile, BIGINT rank) ARRAY popularity_regional, RecordType(VARCHAR
gid, VARCHAR artist_name, RecordType(VARCHAR bio_text, VARCHAR bio_url, VARCHAR
license_text, VARCHAR license_url, VARCHAR license_version, VARCHAR
attribution_text, VARCHAR attribution_url, VARCHAR language) ARRAY bios,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY ancestor_artists,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY descendant_artists,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY asserted_similars,
RecordType(VARCHAR tag_text, DOUBLE weight) ARRAY tags, VARCHAR ARRAY genres,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members_past, VARCHAR
ARRAY meanings, VARCHAR country, RecordType(VARCHAR voted_description_text,
BIGINT votes_up, BIGINT votes_down) ARRAY voted_descriptions, RecordType(BIGINT
year_start, BIGINT year_stop) ARRAY years_active, VARCHAR ARRAY amazon_urls,
VARCHAR ARRAY itunes_urls, VARCHAR ARRAY lastfm_urls, VARCHAR ARRAY
facebook_urls, VARCHAR ARRAY urbandictionary_urls, VARCHAR ARRAY
wikipedia_urls, VARCHAR ARRAY twitter_screennames, VARCHAR ARRAY categories,
RecordType(BOOLEAN childrens, BOOLEAN classical, BOOLEAN curated, BOOLEAN
deceptive, BOOLEAN generic, BOOLEAN inactive, BOOLEAN karaoke, BOOLEAN
non_artist, BOOLEAN soundalike, BOOLEAN unpreferred, BOOLEAN offensive, BOOLEAN
do_not_recommend, BOOLEAN do_not_support, BOOLEAN pass_on_programming, BOOLEAN
deceased) category, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE
weight) ARRAY edited_terms, RecordType(VARCHAR term_text, BIGINT frequency,
DOUBLE weight) ARRAY edited_text_terms, RecordType(VARCHAR term_text, BIGINT
frequency, DOUBLE weight) ARRAY free_text_terms, RecordType(VARCHAR term_text,
BIGINT frequency, DOUBLE weight) ARRAY display_terms, RecordType(VARCHAR key,
VARCHAR value) ARRAY extra, RecordType(BOOLEAN force_curated_sims, VARCHAR
ARRAY curated_sims_uris, VARCHAR ARRAY blacklisted_sims_uris) sims_curation,
RecordType(VARCHAR bio_text, VARCHAR bio_url, VARCHAR license_text, VARCHAR
license_url, VARCHAR license_version, VARCHAR attribution_text, VARCHAR
attribution_url, VARCHAR language) ARRAY display_bios, VARCHAR ARRAY
discogs_uri, VARCHAR ARRAY musicbrainz_uri, VARCHAR ARRAY rovi_music_uri,
RecordType(VARCHAR bio_provider, VARCHAR comment) ARRAY
blocked_display_bio_providers, RecordType(VARCHAR rovi_image_id, BIGINT
sort_order, RecordType(VARCHAR size, VARCHAR url, BIGINT width, BIGINT height)
ARRAY sizes) ARRAY portrait, VARCHAR ARRAY hidden_portraits, VARCHAR
primary_portrait, VARCHAR ARRAY imdb_urls, VARCHAR ARRAY instagram_screennames,
VARCHAR ARRAY myspace_urls, VARCHAR ARRAY tumblr_screennames, VARCHAR ARRAY
youtube_urls) voted, RecordType(VARCHAR gid, DOUBLE ARRAY acousticVector)
acoustic_vector_2, RecordType(VARCHAR gid, RecordType(VARCHAR gid, VARCHAR
name) ARRAY genres, RecordType(VARCHAR gid, VARCHAR name) ARRAY
extended_genres) genre, RecordType(DOUBLE value, VARCHAR gid, VARCHAR region)
ARRAY currency)
rel#39:Subset#0.BEAM_LOGICAL, best=rel#6, importance=0.6561
rel#6:BeamIOSourceRel.BEAM_LOGICAL(table=[beam, endpoint1]),
rowcount=100.0, cumulative cost={100.0 cpu, 0.0 cpuRate }
rel#91:Subset#0.ENUMERABLE, best=rel#90, importance=0.32805
rel#90:BeamEnumerableConverter.ENUMERABLE(input=RelSubset#39),
rowcount=100.0, cumulative cost={1.7976931348623157E308 cpu,
1.7976931348623157E308 cpuRate }
Set#1, type: RecordType(VARCHAR artist_gid, VARCHAR artist_uri, VARCHAR date,
BIGINT id, VARCHAR gid, VARCHAR name, BIGINT redirect, VARCHAR fuzzyname,
BIGINT inserted, RecordType(VARCHAR en_id, VARCHAR name, VARCHAR
spotify_best_match_gid, VARCHAR ARRAY spotify_gids, VARCHAR ARRAY aliases,
VARCHAR ARRAY urls, RecordType(VARCHAR attribution_url, VARCHAR attribution,
RecordType(VARCHAR name, VARCHAR url, VARCHAR version) license, VARCHAR
biography, VARCHAR biography_site, VARCHAR biography_url) ARRAY biographies,
RecordType(VARCHAR name, VARCHAR language) ARRAY display_aliases,
RecordType(VARCHAR name, BIGINT rank, VARCHAR spotify_gid) ARRAY genres,
RecordType(VARCHAR name, BIGINT count, VARCHAR spotify_gid) ARRAY
inferred_genres, VARCHAR ARRAY meta_genres, VARCHAR ARRAY merge_names,
RecordType(VARCHAR en_id, DOUBLE score) ARRAY computed_similar_en_ids,
RecordType(VARCHAR key, VARCHAR value) ARRAY url_map, VARCHAR country, VARCHAR
country_code, DOUBLE latitude, DOUBLE longitude, VARCHAR location, VARCHAR
location_raw, VARCHAR region, VARCHAR town, RecordType(BIGINT start, BIGINT
stop) ARRAY years_active_ranges, RecordType(DOUBLE score, BIGINT rank)
discovery, RecordType(DOUBLE score, BIGINT rank) familiarity, RecordType(DOUBLE
score, BIGINT rank) hotttnesss, RecordType(VARCHAR name, DOUBLE frequency,
BIGINT weight) ARRAY display_top_terms, RecordType(VARCHAR name, DOUBLE
frequency, BIGINT weight) ARRAY edited_top_terms, RecordType(VARCHAR name,
DOUBLE frequency, BIGINT weight) ARRAY edited_text_top_terms,
RecordType(VARCHAR name, DOUBLE frequency, BIGINT weight) ARRAY
free_text_top_terms, VARCHAR ARRAY descendant_en_ids, VARCHAR ARRAY
crawled_genres, VARCHAR ARRAY ancestor_en_ids, VARCHAR ARRAY shared_members,
VARCHAR ARRAY members, VARCHAR ARRAY crawled_similar_en_ids, VARCHAR ARRAY
styles, VARCHAR ARRAY tags, BOOLEAN ambiguous, BOOLEAN kids_music, VARCHAR
ARRAY musicbrainz_ids) ARRAY echo_nest_artists, VARCHAR id10,
RecordType(VARCHAR id, DOUBLE score, RecordType(VARCHAR field,
RecordType(VARCHAR value, DOUBLE query_boost) ARRAY matched_values) ARRAY
explain_info, BOOLEAN curated) ARRAY similars, VARCHAR gid12, VARCHAR version,
DOUBLE ARRAY vector, BIGINT value, VARCHAR gid16, VARCHAR ARRAY domains,
RecordType(BIGINT value, VARCHAR gid, VARCHAR country) ARRAY playlist_adds,
VARCHAR uri, VARCHAR gid20, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank, RecordType(VARCHAR uri,
VARCHAR gid, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank) ARRAY
popularity_regional, VARCHAR gid27, VARCHAR artist_name, RecordType(VARCHAR
bio_text, VARCHAR bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR
license_version, VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR
language) ARRAY bios, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
ancestor_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
descendant_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
asserted_similars, RecordType(VARCHAR tag_text, DOUBLE weight) ARRAY tags,
VARCHAR ARRAY genres, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
members, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members_past,
VARCHAR ARRAY meanings, VARCHAR country, RecordType(VARCHAR
voted_description_text, BIGINT votes_up, BIGINT votes_down) ARRAY
voted_descriptions, RecordType(BIGINT year_start, BIGINT year_stop) ARRAY
years_active, VARCHAR ARRAY amazon_urls, VARCHAR ARRAY itunes_urls, VARCHAR
ARRAY lastfm_urls, VARCHAR ARRAY facebook_urls, VARCHAR ARRAY
urbandictionary_urls, VARCHAR ARRAY wikipedia_urls, VARCHAR ARRAY
twitter_screennames, VARCHAR ARRAY categories, BOOLEAN childrens, BOOLEAN
classical, BOOLEAN curated, BOOLEAN deceptive, BOOLEAN generic, BOOLEAN
inactive, BOOLEAN karaoke, BOOLEAN non_artist, BOOLEAN soundalike, BOOLEAN
unpreferred, BOOLEAN offensive, BOOLEAN do_not_recommend, BOOLEAN
do_not_support, BOOLEAN pass_on_programming, BOOLEAN deceased,
RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight) ARRAY
edited_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight)
ARRAY edited_text_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE
weight) ARRAY free_text_terms, RecordType(VARCHAR term_text, BIGINT frequency,
DOUBLE weight) ARRAY display_terms, RecordType(VARCHAR key, VARCHAR value)
ARRAY extra, BOOLEAN force_curated_sims, VARCHAR ARRAY curated_sims_uris,
VARCHAR ARRAY blacklisted_sims_uris, RecordType(VARCHAR bio_text, VARCHAR
bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR license_version,
VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR language) ARRAY
display_bios, VARCHAR ARRAY discogs_uri, VARCHAR ARRAY musicbrainz_uri, VARCHAR
ARRAY rovi_music_uri, RecordType(VARCHAR bio_provider, VARCHAR comment) ARRAY
blocked_display_bio_providers, RecordType(VARCHAR rovi_image_id, BIGINT
sort_order, RecordType(VARCHAR size, VARCHAR url, BIGINT width, BIGINT height)
ARRAY sizes) ARRAY portrait, VARCHAR ARRAY hidden_portraits, VARCHAR
primary_portrait, VARCHAR ARRAY imdb_urls, VARCHAR ARRAY instagram_screennames,
VARCHAR ARRAY myspace_urls, VARCHAR ARRAY tumblr_screennames, VARCHAR ARRAY
youtube_urls, VARCHAR gid85, DOUBLE ARRAY acousticVector, VARCHAR gid87,
RecordType(VARCHAR gid, VARCHAR name) ARRAY genres88, RecordType(VARCHAR gid,
VARCHAR name) ARRAY extended_genres, RecordType(DOUBLE value, VARCHAR gid,
VARCHAR region) ARRAY currency)
rel#41:Subset#1.NONE, best=null, importance=0.7290000000000001
rel#40:LogicalProject.NONE(input=RelSubset#39,artist_gid=$0,artist_uri=$1,date=$2,id=$3.id,gid=$3.gid,name=$3.name,redirect=$3.redirect,fuzzyname=$3.fuzzyname,inserted=$3.inserted,echo_nest_artists=$4,id10=$5.id,similars=$5.similars,gid12=$6.gid,version=$6.version,vector=$6.vector,value=$7.value,gid16=$7.gid,domains=$7.domains,playlist_adds=$8,uri=$9.uri,gid20=$9.gid,region=$9.region,popularity_raw=$9.popularity_raw,popularity_normalized=$9.popularity_normalized,percentile=$9.percentile,rank=$9.rank,popularity_regional=$10,gid27=$11.gid,artist_name=$11.artist_name,bios=$11.bios,ancestor_artists=$11.ancestor_artists,descendant_artists=$11.descendant_artists,asserted_similars=$11.asserted_similars,tags=$11.tags,genres=$11.genres,members=$11.members,members_past=$11.members_past,meanings=$11.meanings,country=$11.country,voted_descriptions=$11.voted_descriptions,years_active=$11.years_active,amazon_urls=$11.amazon_urls,itunes_urls=$11.itunes_urls,lastfm_urls=$11.lastfm_urls,facebook_urls=$11.facebook_urls,urbandictionary_urls=$11.urbandictionary_urls,wikipedia_urls=$11.wikipedia_urls,twitter_screennames=$11.twitter_screennames,categories=$11.categories,childrens=$11.category.childrens,classical=$11.category.classical,curated=$11.category.curated,deceptive=$11.category.deceptive,generic=$11.category.generic,inactive=$11.category.inactive,karaoke=$11.category.karaoke,non_artist=$11.category.non_artist,soundalike=$11.category.soundalike,unpreferred=$11.category.unpreferred,offensive=$11.category.offensive,do_not_recommend=$11.category.do_not_recommend,do_not_support=$11.category.do_not_support,pass_on_programming=$11.category.pass_on_programming,deceased=$11.category.deceased,edited_terms=$11.edited_terms,edited_text_terms=$11.edited_text_terms,free_text_terms=$11.free_text_terms,display_terms=$11.display_terms,extra=$11.extra,force_curated_sims=$11.sims_curation.force_curated_sims,curated_sims_uris=$11.sims_curation.curated_sims_uris,blacklisted_sims_uris=$11.sims_curation.blacklisted_sims_uris,display_bios=$11.display_bios,discogs_uri=$11.discogs_uri,musicbrainz_uri=$11.musicbrainz_uri,rovi_music_uri=$11.rovi_music_uri,blocked_display_bio_providers=$11.blocked_display_bio_providers,portrait=$11.portrait,hidden_portraits=$11.hidden_portraits,primary_portrait=$11.primary_portrait,imdb_urls=$11.imdb_urls,instagram_screennames=$11.instagram_screennames,myspace_urls=$11.myspace_urls,tumblr_screennames=$11.tumblr_screennames,youtube_urls=$11.youtube_urls,gid85=$12.gid,acousticVector=$12.acousticVector,gid87=$13.gid,genres88=$13.genres,extended_genres=$13.extended_genres,currency=$14),
rowcount=100.0, cumulative cost={inf}
rel#64:LogicalCalc.NONE(input=RelSubset#39,expr#0..14={inputs},expr#15=$t3.id,expr#16=$t3.gid,expr#17=$t3.name,expr#18=$t3.redirect,expr#19=$t3.fuzzyname,expr#20=$t3.inserted,expr#21=$t5.id,expr#22=$t5.similars,expr#23=$t6.gid,expr#24=$t6.version,expr#25=$t6.vector,expr#26=$t7.value,expr#27=$t7.gid,expr#28=$t7.domains,expr#29=$t9.uri,expr#30=$t9.gid,expr#31=$t9.region,expr#32=$t9.popularity_raw,expr#33=$t9.popularity_normalized,expr#34=$t9.percentile,expr#35=$t9.rank,expr#36=$t11.gid,expr#37=$t11.artist_name,expr#38=$t11.bios,expr#39=$t11.ancestor_artists,expr#40=$t11.descendant_artists,expr#41=$t11.asserted_similars,expr#42=$t11.tags,expr#43=$t11.genres,expr#44=$t11.members,expr#45=$t11.members_past,expr#46=$t11.meanings,expr#47=$t11.country,expr#48=$t11.voted_descriptions,expr#49=$t11.years_active,expr#50=$t11.amazon_urls,expr#51=$t11.itunes_urls,expr#52=$t11.lastfm_urls,expr#53=$t11.facebook_urls,expr#54=$t11.urbandictionary_urls,expr#55=$t11.wikipedia_urls,expr#56=$t11.twitter_screennames,expr#57=$t11.categories,expr#58=$t11.category,expr#59=$t58.childrens,expr#60=$t58.classical,expr#61=$t58.curated,expr#62=$t58.deceptive,expr#63=$t58.generic,expr#64=$t58.inactive,expr#65=$t58.karaoke,expr#66=$t58.non_artist,expr#67=$t58.soundalike,expr#68=$t58.unpreferred,expr#69=$t58.offensive,expr#70=$t58.do_not_recommend,expr#71=$t58.do_not_support,expr#72=$t58.pass_on_programming,expr#73=$t58.deceased,expr#74=$t11.edited_terms,expr#75=$t11.edited_text_terms,expr#76=$t11.free_text_terms,expr#77=$t11.display_terms,expr#78=$t11.extra,expr#79=$t11.sims_curation,expr#80=$t79.force_curated_sims,expr#81=$t79.curated_sims_uris,expr#82=$t79.blacklisted_sims_uris,expr#83=$t11.display_bios,expr#84=$t11.discogs_uri,expr#85=$t11.musicbrainz_uri,expr#86=$t11.rovi_music_uri,expr#87=$t11.blocked_display_bio_providers,expr#88=$t11.portrait,expr#89=$t11.hidden_portraits,expr#90=$t11.primary_portrait,expr#91=$t11.imdb_urls,expr#92=$t11.instagram_screennames,expr#93=$t11.myspace_urls,expr#94=$t11.tumblr_screennames,expr#95=$t11.youtube_urls,expr#96=$t12.gid,expr#97=$t12.acousticVector,expr#98=$t13.gid,expr#99=$t13.genres,expr#100=$t13.extended_genres,artist_gid=$t0,artist_uri=$t1,date=$t2,id=$t15,gid=$t16,name=$t17,redirect=$t18,fuzzyname=$t19,inserted=$t20,echo_nest_artists=$t4,id10=$t21,similars=$t22,gid12=$t23,version=$t24,vector=$t25,value=$t26,gid16=$t27,domains=$t28,playlist_adds=$t8,uri=$t29,gid20=$t30,region=$t31,popularity_raw=$t32,popularity_normalized=$t33,percentile=$t34,rank=$t35,popularity_regional=$t10,gid27=$t36,artist_name=$t37,bios=$t38,ancestor_artists=$t39,descendant_artists=$t40,asserted_similars=$t41,tags=$t42,genres=$t43,members=$t44,members_past=$t45,meanings=$t46,country=$t47,voted_descriptions=$t48,years_active=$t49,amazon_urls=$t50,itunes_urls=$t51,lastfm_urls=$t52,facebook_urls=$t53,urbandictionary_urls=$t54,wikipedia_urls=$t55,twitter_screennames=$t56,categories=$t57,childrens=$t59,classical=$t60,curated=$t61,deceptive=$t62,generic=$t63,inactive=$t64,karaoke=$t65,non_artist=$t66,soundalike=$t67,unpreferred=$t68,offensive=$t69,do_not_recommend=$t70,do_not_support=$t71,pass_on_programming=$t72,deceased=$t73,edited_terms=$t74,edited_text_terms=$t75,free_text_terms=$t76,display_terms=$t77,extra=$t78,force_curated_sims=$t80,curated_sims_uris=$t81,blacklisted_sims_uris=$t82,display_bios=$t83,discogs_uri=$t84,musicbrainz_uri=$t85,rovi_music_uri=$t86,blocked_display_bio_providers=$t87,portrait=$t88,hidden_portraits=$t89,primary_portrait=$t90,imdb_urls=$t91,instagram_screennames=$t92,myspace_urls=$t93,tumblr_screennames=$t94,youtube_urls=$t95,gid85=$t96,acousticVector=$t97,gid87=$t98,genres88=$t99,extended_genres=$t100,currency=$t14),
rowcount=100.0, cumulative cost={inf}
rel#66:Subset#1.BEAM_LOGICAL, best=rel#65,
importance=0.36450000000000005
rel#65:BeamCalcRel.BEAM_LOGICAL(input=RelSubset#39,expr#0..14={inputs},expr#15=$t3.id,expr#16=$t3.gid,expr#17=$t3.name,expr#18=$t3.redirect,expr#19=$t3.fuzzyname,expr#20=$t3.inserted,expr#21=$t5.id,expr#22=$t5.similars,expr#23=$t6.gid,expr#24=$t6.version,expr#25=$t6.vector,expr#26=$t7.value,expr#27=$t7.gid,expr#28=$t7.domains,expr#29=$t9.uri,expr#30=$t9.gid,expr#31=$t9.region,expr#32=$t9.popularity_raw,expr#33=$t9.popularity_normalized,expr#34=$t9.percentile,expr#35=$t9.rank,expr#36=$t11.gid,expr#37=$t11.artist_name,expr#38=$t11.bios,expr#39=$t11.ancestor_artists,expr#40=$t11.descendant_artists,expr#41=$t11.asserted_similars,expr#42=$t11.tags,expr#43=$t11.genres,expr#44=$t11.members,expr#45=$t11.members_past,expr#46=$t11.meanings,expr#47=$t11.country,expr#48=$t11.voted_descriptions,expr#49=$t11.years_active,expr#50=$t11.amazon_urls,expr#51=$t11.itunes_urls,expr#52=$t11.lastfm_urls,expr#53=$t11.facebook_urls,expr#54=$t11.urbandictionary_urls,expr#55=$t11.wikipedia_urls,expr#56=$t11.twitter_screennames,expr#57=$t11.categories,expr#58=$t11.category,expr#59=$t58.childrens,expr#60=$t58.classical,expr#61=$t58.curated,expr#62=$t58.deceptive,expr#63=$t58.generic,expr#64=$t58.inactive,expr#65=$t58.karaoke,expr#66=$t58.non_artist,expr#67=$t58.soundalike,expr#68=$t58.unpreferred,expr#69=$t58.offensive,expr#70=$t58.do_not_recommend,expr#71=$t58.do_not_support,expr#72=$t58.pass_on_programming,expr#73=$t58.deceased,expr#74=$t11.edited_terms,expr#75=$t11.edited_text_terms,expr#76=$t11.free_text_terms,expr#77=$t11.display_terms,expr#78=$t11.extra,expr#79=$t11.sims_curation,expr#80=$t79.force_curated_sims,expr#81=$t79.curated_sims_uris,expr#82=$t79.blacklisted_sims_uris,expr#83=$t11.display_bios,expr#84=$t11.discogs_uri,expr#85=$t11.musicbrainz_uri,expr#86=$t11.rovi_music_uri,expr#87=$t11.blocked_display_bio_providers,expr#88=$t11.portrait,expr#89=$t11.hidden_portraits,expr#90=$t11.primary_portrait,expr#91=$t11.imdb_urls,expr#92=$t11.instagram_screennames,expr#93=$t11.myspace_urls,expr#94=$t11.tumblr_screennames,expr#95=$t11.youtube_urls,expr#96=$t12.gid,expr#97=$t12.acousticVector,expr#98=$t13.gid,expr#99=$t13.genres,expr#100=$t13.extended_genres,artist_gid=$t0,artist_uri=$t1,date=$t2,id=$t15,gid=$t16,name=$t17,redirect=$t18,fuzzyname=$t19,inserted=$t20,echo_nest_artists=$t4,id10=$t21,similars=$t22,gid12=$t23,version=$t24,vector=$t25,value=$t26,gid16=$t27,domains=$t28,playlist_adds=$t8,uri=$t29,gid20=$t30,region=$t31,popularity_raw=$t32,popularity_normalized=$t33,percentile=$t34,rank=$t35,popularity_regional=$t10,gid27=$t36,artist_name=$t37,bios=$t38,ancestor_artists=$t39,descendant_artists=$t40,asserted_similars=$t41,tags=$t42,genres=$t43,members=$t44,members_past=$t45,meanings=$t46,country=$t47,voted_descriptions=$t48,years_active=$t49,amazon_urls=$t50,itunes_urls=$t51,lastfm_urls=$t52,facebook_urls=$t53,urbandictionary_urls=$t54,wikipedia_urls=$t55,twitter_screennames=$t56,categories=$t57,childrens=$t59,classical=$t60,curated=$t61,deceptive=$t62,generic=$t63,inactive=$t64,karaoke=$t65,non_artist=$t66,soundalike=$t67,unpreferred=$t68,offensive=$t69,do_not_recommend=$t70,do_not_support=$t71,pass_on_programming=$t72,deceased=$t73,edited_terms=$t74,edited_text_terms=$t75,free_text_terms=$t76,display_terms=$t77,extra=$t78,force_curated_sims=$t80,curated_sims_uris=$t81,blacklisted_sims_uris=$t82,display_bios=$t83,discogs_uri=$t84,musicbrainz_uri=$t85,rovi_music_uri=$t86,blocked_display_bio_providers=$t87,portrait=$t88,hidden_portraits=$t89,primary_portrait=$t90,imdb_urls=$t91,instagram_screennames=$t92,myspace_urls=$t93,tumblr_screennames=$t94,youtube_urls=$t95,gid85=$t96,acousticVector=$t97,gid87=$t98,genres88=$t99,extended_genres=$t100,currency=$t14),
rowcount=100.0, cumulative cost={200.0 cpu, 0.0 cpuRate }
rel#77:Subset#1.ENUMERABLE, best=rel#76, importance=0.36450000000000005
rel#76:BeamEnumerableConverter.ENUMERABLE(input=RelSubset#66),
rowcount=100.0, cumulative cost={1.7976931348623157E308 cpu,
1.7976931348623157E308 cpuRate }
Set#2, type: RecordType(INTEGER ZERO)
rel#42:Subset#2.NONE, best=null, importance=0.5904900000000001
rel#8:LogicalValues.NONE(type=RecordType(INTEGER
ZERO),tuples=[{ 0 }]), rowcount=1.0, cumulative cost={inf}
rel#73:Subset#2.BEAM_LOGICAL, best=rel#75,
importance=0.29524500000000004
rel#75:BeamValuesRel.BEAM_LOGICAL(type=RecordType(INTEGER
ZERO),tuples=[{ 0 }]), rowcount=1.0, cumulative cost={1.0 cpu, 0.0 cpuRate }
rel#89:Subset#2.ENUMERABLE, best=rel#88, importance=0.29524500000000004
rel#88:BeamEnumerableConverter.ENUMERABLE(input=RelSubset#73),
rowcount=1.0, cumulative cost={1.7976931348623157E308 cpu,
1.7976931348623157E308 cpuRate }
Set#3, type: RecordType(RecordType(VARCHAR gid, VARCHAR name) ARRAY genres)
rel#44:Subset#3.NONE, best=null, importance=0.6561
rel#43:LogicalProject.NONE(input=RelSubset#42,genres=$cor0.genres_88),
rowcount=1.0, cumulative cost={inf}
rel#72:LogicalCalc.NONE(input=RelSubset#42,expr#0={inputs},expr#1=$cor0,expr#2=$t1.genres_88,genres=$t2),
rowcount=1.0, cumulative cost={inf}
rel#69:Subset#3.BEAM_LOGICAL, best=rel#74, importance=0.32805
rel#74:BeamCalcRel.BEAM_LOGICAL(input=RelSubset#73,expr#0={inputs},expr#1=$cor0,expr#2=$t1.genres_88,genres=$t2),
rowcount=1.0, cumulative cost={2.0 cpu, 0.0 cpuRate }
rel#86:Subset#3.ENUMERABLE, best=rel#85, importance=0.32805
rel#85:BeamEnumerableConverter.ENUMERABLE(input=RelSubset#69),
rowcount=1.0, cumulative cost={1.7976931348623157E308 cpu,
1.7976931348623157E308 cpuRate }
Set#4, type: RecordType(VARCHAR gid, VARCHAR name)
rel#46:Subset#4.NONE, best=null, importance=0.7290000000000001
rel#45:Uncollect.NONE(input=RelSubset#44), rowcount=1.0,
cumulative cost={inf}
rel#71:Subset#4.BEAM_LOGICAL, best=rel#70,
importance=0.36450000000000005
rel#70:BeamUncollectRel.BEAM_LOGICAL(input=RelSubset#69),
rowcount=1.0, cumulative cost={3.0 cpu, 1.0 cpuRate }
rel#81:Subset#4.ENUMERABLE, best=rel#80, importance=0.36450000000000005
rel#80:BeamEnumerableConverter.ENUMERABLE(input=RelSubset#71),
rowcount=1.0, cumulative cost={1.7976931348623157E308 cpu,
1.7976931348623157E308 cpuRate }
Set#5, type: RecordType(VARCHAR artist_gid, VARCHAR artist_uri, VARCHAR date,
BIGINT id, VARCHAR gid, VARCHAR name, BIGINT redirect, VARCHAR fuzzyname,
BIGINT inserted, RecordType(VARCHAR en_id, VARCHAR name, VARCHAR
spotify_best_match_gid, VARCHAR ARRAY spotify_gids, VARCHAR ARRAY aliases,
VARCHAR ARRAY urls, RecordType(VARCHAR attribution_url, VARCHAR attribution,
RecordType(VARCHAR name, VARCHAR url, VARCHAR version) license, VARCHAR
biography, VARCHAR biography_site, VARCHAR biography_url) ARRAY biographies,
RecordType(VARCHAR name, VARCHAR language) ARRAY display_aliases,
RecordType(VARCHAR name, BIGINT rank, VARCHAR spotify_gid) ARRAY genres,
RecordType(VARCHAR name, BIGINT count, VARCHAR spotify_gid) ARRAY
inferred_genres, VARCHAR ARRAY meta_genres, VARCHAR ARRAY merge_names,
RecordType(VARCHAR en_id, DOUBLE score) ARRAY computed_similar_en_ids,
RecordType(VARCHAR key, VARCHAR value) ARRAY url_map, VARCHAR country, VARCHAR
country_code, DOUBLE latitude, DOUBLE longitude, VARCHAR location, VARCHAR
location_raw, VARCHAR region, VARCHAR town, RecordType(BIGINT start, BIGINT
stop) ARRAY years_active_ranges, RecordType(DOUBLE score, BIGINT rank)
discovery, RecordType(DOUBLE score, BIGINT rank) familiarity, RecordType(DOUBLE
score, BIGINT rank) hotttnesss, RecordType(VARCHAR name, DOUBLE frequency,
BIGINT weight) ARRAY display_top_terms, RecordType(VARCHAR name, DOUBLE
frequency, BIGINT weight) ARRAY edited_top_terms, RecordType(VARCHAR name,
DOUBLE frequency, BIGINT weight) ARRAY edited_text_top_terms,
RecordType(VARCHAR name, DOUBLE frequency, BIGINT weight) ARRAY
free_text_top_terms, VARCHAR ARRAY descendant_en_ids, VARCHAR ARRAY
crawled_genres, VARCHAR ARRAY ancestor_en_ids, VARCHAR ARRAY shared_members,
VARCHAR ARRAY members, VARCHAR ARRAY crawled_similar_en_ids, VARCHAR ARRAY
styles, VARCHAR ARRAY tags, BOOLEAN ambiguous, BOOLEAN kids_music, VARCHAR
ARRAY musicbrainz_ids) ARRAY echo_nest_artists, VARCHAR id10,
RecordType(VARCHAR id, DOUBLE score, RecordType(VARCHAR field,
RecordType(VARCHAR value, DOUBLE query_boost) ARRAY matched_values) ARRAY
explain_info, BOOLEAN curated) ARRAY similars, VARCHAR gid12, VARCHAR version,
DOUBLE ARRAY vector, BIGINT value, VARCHAR gid16, VARCHAR ARRAY domains,
RecordType(BIGINT value, VARCHAR gid, VARCHAR country) ARRAY playlist_adds,
VARCHAR uri, VARCHAR gid20, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank, RecordType(VARCHAR uri,
VARCHAR gid, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank) ARRAY
popularity_regional, VARCHAR gid27, VARCHAR artist_name, RecordType(VARCHAR
bio_text, VARCHAR bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR
license_version, VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR
language) ARRAY bios, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
ancestor_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
descendant_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
asserted_similars, RecordType(VARCHAR tag_text, DOUBLE weight) ARRAY tags,
VARCHAR ARRAY genres, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
members, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members_past,
VARCHAR ARRAY meanings, VARCHAR country, RecordType(VARCHAR
voted_description_text, BIGINT votes_up, BIGINT votes_down) ARRAY
voted_descriptions, RecordType(BIGINT year_start, BIGINT year_stop) ARRAY
years_active, VARCHAR ARRAY amazon_urls, VARCHAR ARRAY itunes_urls, VARCHAR
ARRAY lastfm_urls, VARCHAR ARRAY facebook_urls, VARCHAR ARRAY
urbandictionary_urls, VARCHAR ARRAY wikipedia_urls, VARCHAR ARRAY
twitter_screennames, VARCHAR ARRAY categories, BOOLEAN childrens, BOOLEAN
classical, BOOLEAN curated, BOOLEAN deceptive, BOOLEAN generic, BOOLEAN
inactive, BOOLEAN karaoke, BOOLEAN non_artist, BOOLEAN soundalike, BOOLEAN
unpreferred, BOOLEAN offensive, BOOLEAN do_not_recommend, BOOLEAN
do_not_support, BOOLEAN pass_on_programming, BOOLEAN deceased,
RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight) ARRAY
edited_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight)
ARRAY edited_text_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE
weight) ARRAY free_text_terms, RecordType(VARCHAR term_text, BIGINT frequency,
DOUBLE weight) ARRAY display_terms, RecordType(VARCHAR key, VARCHAR value)
ARRAY extra, BOOLEAN force_curated_sims, VARCHAR ARRAY curated_sims_uris,
VARCHAR ARRAY blacklisted_sims_uris, RecordType(VARCHAR bio_text, VARCHAR
bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR license_version,
VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR language) ARRAY
display_bios, VARCHAR ARRAY discogs_uri, VARCHAR ARRAY musicbrainz_uri, VARCHAR
ARRAY rovi_music_uri, RecordType(VARCHAR bio_provider, VARCHAR comment) ARRAY
blocked_display_bio_providers, RecordType(VARCHAR rovi_image_id, BIGINT
sort_order, RecordType(VARCHAR size, VARCHAR url, BIGINT width, BIGINT height)
ARRAY sizes) ARRAY portrait, VARCHAR ARRAY hidden_portraits, VARCHAR
primary_portrait, VARCHAR ARRAY imdb_urls, VARCHAR ARRAY instagram_screennames,
VARCHAR ARRAY myspace_urls, VARCHAR ARRAY tumblr_screennames, VARCHAR ARRAY
youtube_urls, VARCHAR gid85, DOUBLE ARRAY acousticVector, VARCHAR gid87,
RecordType(VARCHAR gid, VARCHAR name) ARRAY genres88, RecordType(VARCHAR gid,
VARCHAR name) ARRAY extended_genres, RecordType(DOUBLE value, VARCHAR gid,
VARCHAR region) ARRAY currency, VARCHAR gid0, VARCHAR name0)
rel#48:Subset#5.NONE, best=null, importance=0.81
rel#47:LogicalCorrelate.NONE(left=RelSubset#41,right=RelSubset#46,correlation=$cor0,joinType=inner,requiredColumns={87}),
rowcount=1.0, cumulative cost={inf}
rel#54:Subset#5.BEAM_LOGICAL, best=null, importance=0.9
rel#60:BeamUnnestRel.BEAM_LOGICAL(input=RelSubset#41,unnestIndex=88),
rowcount=100.0, cumulative cost={inf}
rel#63:Subset#5.ENUMERABLE, best=null, importance=0.45
rel#62:BeamEnumerableConverter.ENUMERABLE(input=RelSubset#54),
rowcount=1.0, cumulative cost={inf}
Set#6, type: RecordType(VARCHAR artist_gid)
rel#50:Subset#6.NONE, best=null, importance=0.9
rel#49:LogicalProject.NONE(input=RelSubset#48,artist_gid=$0),
rowcount=1.0, cumulative cost={inf}
rel#53:LogicalCalc.NONE(input=RelSubset#48,expr#0..92={inputs},artist_gid=$t0),
rowcount=1.0, cumulative cost={inf}
rel#51:Subset#6.BEAM_LOGICAL, best=null, importance=1.0
rel#52:AbstractConverter.BEAM_LOGICAL(input=RelSubset#50,convention=BEAM_LOGICAL),
rowcount=1.0, cumulative cost={inf}
rel#55:BeamCalcRel.BEAM_LOGICAL(input=RelSubset#54,expr#0..92={inputs},artist_gid=$t0),
rowcount=1.0, cumulative cost={inf}
rel#58:Subset#6.ENUMERABLE, best=null, importance=0.5
rel#57:BeamEnumerableConverter.ENUMERABLE(input=RelSubset#51),
rowcount=1.0, cumulative cost={inf}
Graphviz:
digraph G {
root [style=filled,label="Root"];
subgraph cluster0{
label="Set 0 RecordType(VARCHAR artist_gid, VARCHAR artist_uri,
VARCHAR date, RecordType(BIGINT id, VARCHAR gid, VARCHAR name, BIGINT redirect,
VARCHAR fuzzyname, BIGINT inserted) metadata_artist, RecordType(VARCHAR en_id,
VARCHAR name, VARCHAR spotify_best_match_gid, VARCHAR ARRAY spotify_gids,
VARCHAR ARRAY aliases, VARCHAR ARRAY urls, RecordType(VARCHAR attribution_url,
VARCHAR attribution, RecordType(VARCHAR name, VARCHAR url, VARCHAR version)
license, VARCHAR biography, VARCHAR biography_site, VARCHAR biography_url)
ARRAY biographies, RecordType(VARCHAR name, VARCHAR language) ARRAY
display_aliases, RecordType(VARCHAR name, BIGINT rank, VARCHAR spotify_gid)
ARRAY genres, RecordType(VARCHAR name, BIGINT count, VARCHAR spotify_gid) ARRAY
inferred_genres, VARCHAR ARRAY meta_genres, VARCHAR ARRAY merge_names,
RecordType(VARCHAR en_id, DOUBLE score) ARRAY computed_similar_en_ids,
RecordType(VARCHAR key, VARCHAR value) ARRAY url_map, VARCHAR country, VARCHAR
country_code, DOUBLE latitude, DOUBLE longitude, VARCHAR location, VARCHAR
location_raw, VARCHAR region, VARCHAR town, RecordType(BIGINT start, BIGINT
stop) ARRAY years_active_ranges, RecordType(DOUBLE score, BIGINT rank)
discovery, RecordType(DOUBLE score, BIGINT rank) familiarity, RecordType(DOUBLE
score, BIGINT rank) hotttnesss, RecordType(VARCHAR name, DOUBLE frequency,
BIGINT weight) ARRAY display_top_terms, RecordType(VARCHAR name, DOUBLE
frequency, BIGINT weight) ARRAY edited_top_terms, RecordType(VARCHAR name,
DOUBLE frequency, BIGINT weight) ARRAY edited_text_top_terms,
RecordType(VARCHAR name, DOUBLE frequency, BIGINT weight) ARRAY
free_text_top_terms, VARCHAR ARRAY descendant_en_ids, VARCHAR ARRAY
crawled_genres, VARCHAR ARRAY ancestor_en_ids, VARCHAR ARRAY shared_members,
VARCHAR ARRAY members, VARCHAR ARRAY crawled_similar_en_ids, VARCHAR ARRAY
styles, VARCHAR ARRAY tags, BOOLEAN ambiguous, BOOLEAN kids_music, VARCHAR
ARRAY musicbrainz_ids) ARRAY echo_nest_artists, RecordType(VARCHAR id,
RecordType(VARCHAR id, DOUBLE score, RecordType(VARCHAR field,
RecordType(VARCHAR value, DOUBLE query_boost) ARRAY matched_values) ARRAY
explain_info, BOOLEAN curated) ARRAY similars) artist_sims, RecordType(VARCHAR
gid, VARCHAR version, DOUBLE ARRAY vector) vector, RecordType(BIGINT value,
VARCHAR gid, VARCHAR ARRAY domains) followers, RecordType(BIGINT value, VARCHAR
gid, VARCHAR country) ARRAY playlist_adds, RecordType(VARCHAR uri, VARCHAR gid,
VARCHAR region, DOUBLE popularity_raw, DOUBLE popularity_normalized, DOUBLE
percentile, BIGINT rank) popularity_global, RecordType(VARCHAR uri, VARCHAR
gid, VARCHAR region, DOUBLE popularity_raw, DOUBLE popularity_normalized,
DOUBLE percentile, BIGINT rank) ARRAY popularity_regional, RecordType(VARCHAR
gid, VARCHAR artist_name, RecordType(VARCHAR bio_text, VARCHAR bio_url, VARCHAR
license_text, VARCHAR license_url, VARCHAR license_version, VARCHAR
attribution_text, VARCHAR attribution_url, VARCHAR language) ARRAY bios,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY ancestor_artists,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY descendant_artists,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY asserted_similars,
RecordType(VARCHAR tag_text, DOUBLE weight) ARRAY tags, VARCHAR ARRAY genres,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members,
RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members_past, VARCHAR
ARRAY meanings, VARCHAR country, RecordType(VARCHAR voted_description_text,
BIGINT votes_up, BIGINT votes_down) ARRAY voted_descriptions, RecordType(BIGINT
year_start, BIGINT year_stop) ARRAY years_active, VARCHAR ARRAY amazon_urls,
VARCHAR ARRAY itunes_urls, VARCHAR ARRAY lastfm_urls, VARCHAR ARRAY
facebook_urls, VARCHAR ARRAY urbandictionary_urls, VARCHAR ARRAY
wikipedia_urls, VARCHAR ARRAY twitter_screennames, VARCHAR ARRAY categories,
RecordType(BOOLEAN childrens, BOOLEAN classical, BOOLEAN curated, BOOLEAN
deceptive, BOOLEAN generic, BOOLEAN inactive, BOOLEAN karaoke, BOOLEAN
non_artist, BOOLEAN soundalike, BOOLEAN unpreferred, BOOLEAN offensive, BOOLEAN
do_not_recommend, BOOLEAN do_not_support, BOOLEAN pass_on_programming, BOOLEAN
deceased) category, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE
weight) ARRAY edited_terms, RecordType(VARCHAR term_text, BIGINT frequency,
DOUBLE weight) ARRAY edited_text_terms, RecordType(VARCHAR term_text, BIGINT
frequency, DOUBLE weight) ARRAY free_text_terms, RecordType(VARCHAR term_text,
BIGINT frequency, DOUBLE weight) ARRAY display_terms, RecordType(VARCHAR key,
VARCHAR value) ARRAY extra, RecordType(BOOLEAN force_curated_sims, VARCHAR
ARRAY curated_sims_uris, VARCHAR ARRAY blacklisted_sims_uris) sims_curation,
RecordType(VARCHAR bio_text, VARCHAR bio_url, VARCHAR license_text, VARCHAR
license_url, VARCHAR license_version, VARCHAR attribution_text, VARCHAR
attribution_url, VARCHAR language) ARRAY display_bios, VARCHAR ARRAY
discogs_uri, VARCHAR ARRAY musicbrainz_uri, VARCHAR ARRAY rovi_music_uri,
RecordType(VARCHAR bio_provider, VARCHAR comment) ARRAY
blocked_display_bio_providers, RecordType(VARCHAR rovi_image_id, BIGINT
sort_order, RecordType(VARCHAR size, VARCHAR url, BIGINT width, BIGINT height)
ARRAY sizes) ARRAY portrait, VARCHAR ARRAY hidden_portraits, VARCHAR
primary_portrait, VARCHAR ARRAY imdb_urls, VARCHAR ARRAY instagram_screennames,
VARCHAR ARRAY myspace_urls, VARCHAR ARRAY tumblr_screennames, VARCHAR ARRAY
youtube_urls) voted, RecordType(VARCHAR gid, DOUBLE ARRAY acousticVector)
acoustic_vector_2, RecordType(VARCHAR gid, RecordType(VARCHAR gid, VARCHAR
name) ARRAY genres, RecordType(VARCHAR gid, VARCHAR name) ARRAY
extended_genres) genre, RecordType(DOUBLE value, VARCHAR gid, VARCHAR region)
ARRAY currency)";
rel6 [label="rel#6:BeamIOSourceRel\ntable=[beam,
endpoint1]\nrows=100.0, cost={100.0 cpu, 0.0 cpuRate }",color=blue,shape=box]
rel90
[label="rel#90:BeamEnumerableConverter\ninput=RelSubset#39\nrows=100.0,
cost={1.7976931348623157E308 cpu, 1.7976931348623157E308 cpuRate
}",color=blue,shape=box]
subset39 [label="rel#39:Subset#0.BEAM_LOGICAL"]
subset91 [label="rel#91:Subset#0.ENUMERABLE"]
}
subgraph cluster1{
label="Set 1 RecordType(VARCHAR artist_gid, VARCHAR artist_uri,
VARCHAR date, BIGINT id, VARCHAR gid, VARCHAR name, BIGINT redirect, VARCHAR
fuzzyname, BIGINT inserted, RecordType(VARCHAR en_id, VARCHAR name, VARCHAR
spotify_best_match_gid, VARCHAR ARRAY spotify_gids, VARCHAR ARRAY aliases,
VARCHAR ARRAY urls, RecordType(VARCHAR attribution_url, VARCHAR attribution,
RecordType(VARCHAR name, VARCHAR url, VARCHAR version) license, VARCHAR
biography, VARCHAR biography_site, VARCHAR biography_url) ARRAY biographies,
RecordType(VARCHAR name, VARCHAR language) ARRAY display_aliases,
RecordType(VARCHAR name, BIGINT rank, VARCHAR spotify_gid) ARRAY genres,
RecordType(VARCHAR name, BIGINT count, VARCHAR spotify_gid) ARRAY
inferred_genres, VARCHAR ARRAY meta_genres, VARCHAR ARRAY merge_names,
RecordType(VARCHAR en_id, DOUBLE score) ARRAY computed_similar_en_ids,
RecordType(VARCHAR key, VARCHAR value) ARRAY url_map, VARCHAR country, VARCHAR
country_code, DOUBLE latitude, DOUBLE longitude, VARCHAR location, VARCHAR
location_raw, VARCHAR region, VARCHAR town, RecordType(BIGINT start, BIGINT
stop) ARRAY years_active_ranges, RecordType(DOUBLE score, BIGINT rank)
discovery, RecordType(DOUBLE score, BIGINT rank) familiarity, RecordType(DOUBLE
score, BIGINT rank) hotttnesss, RecordType(VARCHAR name, DOUBLE frequency,
BIGINT weight) ARRAY display_top_terms, RecordType(VARCHAR name, DOUBLE
frequency, BIGINT weight) ARRAY edited_top_terms, RecordType(VARCHAR name,
DOUBLE frequency, BIGINT weight) ARRAY edited_text_top_terms,
RecordType(VARCHAR name, DOUBLE frequency, BIGINT weight) ARRAY
free_text_top_terms, VARCHAR ARRAY descendant_en_ids, VARCHAR ARRAY
crawled_genres, VARCHAR ARRAY ancestor_en_ids, VARCHAR ARRAY shared_members,
VARCHAR ARRAY members, VARCHAR ARRAY crawled_similar_en_ids, VARCHAR ARRAY
styles, VARCHAR ARRAY tags, BOOLEAN ambiguous, BOOLEAN kids_music, VARCHAR
ARRAY musicbrainz_ids) ARRAY echo_nest_artists, VARCHAR id10,
RecordType(VARCHAR id, DOUBLE score, RecordType(VARCHAR field,
RecordType(VARCHAR value, DOUBLE query_boost) ARRAY matched_values) ARRAY
explain_info, BOOLEAN curated) ARRAY similars, VARCHAR gid12, VARCHAR version,
DOUBLE ARRAY vector, BIGINT value, VARCHAR gid16, VARCHAR ARRAY domains,
RecordType(BIGINT value, VARCHAR gid, VARCHAR country) ARRAY playlist_adds,
VARCHAR uri, VARCHAR gid20, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank, RecordType(VARCHAR uri,
VARCHAR gid, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank) ARRAY
popularity_regional, VARCHAR gid27, VARCHAR artist_name, RecordType(VARCHAR
bio_text, VARCHAR bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR
license_version, VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR
language) ARRAY bios, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
ancestor_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
descendant_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
asserted_similars, RecordType(VARCHAR tag_text, DOUBLE weight) ARRAY tags,
VARCHAR ARRAY genres, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
members, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members_past,
VARCHAR ARRAY meanings, VARCHAR country, RecordType(VARCHAR
voted_description_text, BIGINT votes_up, BIGINT votes_down) ARRAY
voted_descriptions, RecordType(BIGINT year_start, BIGINT year_stop) ARRAY
years_active, VARCHAR ARRAY amazon_urls, VARCHAR ARRAY itunes_urls, VARCHAR
ARRAY lastfm_urls, VARCHAR ARRAY facebook_urls, VARCHAR ARRAY
urbandictionary_urls, VARCHAR ARRAY wikipedia_urls, VARCHAR ARRAY
twitter_screennames, VARCHAR ARRAY categories, BOOLEAN childrens, BOOLEAN
classical, BOOLEAN curated, BOOLEAN deceptive, BOOLEAN generic, BOOLEAN
inactive, BOOLEAN karaoke, BOOLEAN non_artist, BOOLEAN soundalike, BOOLEAN
unpreferred, BOOLEAN offensive, BOOLEAN do_not_recommend, BOOLEAN
do_not_support, BOOLEAN pass_on_programming, BOOLEAN deceased,
RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight) ARRAY
edited_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight)
ARRAY edited_text_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE
weight) ARRAY free_text_terms, RecordType(VARCHAR term_text, BIGINT frequency,
DOUBLE weight) ARRAY display_terms, RecordType(VARCHAR key, VARCHAR value)
ARRAY extra, BOOLEAN force_curated_sims, VARCHAR ARRAY curated_sims_uris,
VARCHAR ARRAY blacklisted_sims_uris, RecordType(VARCHAR bio_text, VARCHAR
bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR license_version,
VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR language) ARRAY
display_bios, VARCHAR ARRAY discogs_uri, VARCHAR ARRAY musicbrainz_uri, VARCHAR
ARRAY rovi_music_uri, RecordType(VARCHAR bio_provider, VARCHAR comment) ARRAY
blocked_display_bio_providers, RecordType(VARCHAR rovi_image_id, BIGINT
sort_order, RecordType(VARCHAR size, VARCHAR url, BIGINT width, BIGINT height)
ARRAY sizes) ARRAY portrait, VARCHAR ARRAY hidden_portraits, VARCHAR
primary_portrait, VARCHAR ARRAY imdb_urls, VARCHAR ARRAY instagram_screennames,
VARCHAR ARRAY myspace_urls, VARCHAR ARRAY tumblr_screennames, VARCHAR ARRAY
youtube_urls, VARCHAR gid85, DOUBLE ARRAY acousticVector, VARCHAR gid87,
RecordType(VARCHAR gid, VARCHAR name) ARRAY genres88, RecordType(VARCHAR gid,
VARCHAR name) ARRAY extended_genres, RecordType(DOUBLE value, VARCHAR gid,
VARCHAR region) ARRAY currency)";
rel40
[label="rel#40:LogicalProject\ninput=RelSubset#39,artist_gid=$0,artist_uri=$1,date=$2,id=$3.id,gid=$3.gid,name=$3.name,redirect=$3.redirect,fuzzyname=$3.fuzzyname,inserted=$3.inserted,echo_nest_artists=$4,id10=$5.id,similars=$5.similars,gid12=$6.gid,version=$6.version,vector=$6.vector,value=$7.value,gid16=$7.gid,domains=$7.domains,playlist_adds=$8,uri=$9.uri,gid20=$9.gid,region=$9.region,popularity_raw=$9.popularity_raw,popularity_normalized=$9.popularity_normalized,percentile=$9.percentile,rank=$9.rank,popularity_regional=$10,gid27=$11.gid,artist_name=$11.artist_name,bios=$11.bios,ancestor_artists=$11.ancestor_artists,descendant_artists=$11.descendant_artists,asserted_similars=$11.asserted_similars,tags=$11.tags,genres=$11.genres,members=$11.members,members_past=$11.members_past,meanings=$11.meanings,country=$11.country,voted_descriptions=$11.voted_descriptions,years_active=$11.years_active,amazon_urls=$11.amazon_urls,itunes_urls=$11.itunes_urls,lastfm_urls=$11.lastfm_urls,facebook_urls=$11.facebook_urls,urbandictionary_urls=$11.urbandictionary_urls,wikipedia_urls=$11.wikipedia_urls,twitter_screennames=$11.twitter_screennames,categories=$11.categories,childrens=$11.category.childrens,classical=$11.category.classical,curated=$11.category.curated,deceptive=$11.category.deceptive,generic=$11.category.generic,inactive=$11.category.inactive,karaoke=$11.category.karaoke,non_artist=$11.category.non_artist,soundalike=$11.category.soundalike,unpreferred=$11.category.unpreferred,offensive=$11.category.offensive,do_not_recommend=$11.category.do_not_recommend,do_not_support=$11.category.do_not_support,pass_on_programming=$11.category.pass_on_programming,deceased=$11.category.deceased,edited_terms=$11.edited_terms,edited_text_terms=$11.edited_text_terms,free_text_terms=$11.free_text_terms,display_terms=$11.display_terms,extra=$11.extra,force_curated_sims=$11.sims_curation.force_curated_sims,curated_sims_uris=$11.sims_curation.curated_sims_uris,blacklisted_sims_uris=$11.sims_curation.blacklisted_sims_uris,display_bios=$11.display_bios,discogs_uri=$11.discogs_uri,musicbrainz_uri=$11.musicbrainz_uri,rovi_music_uri=$11.rovi_music_uri,blocked_display_bio_providers=$11.blocked_display_bio_providers,portrait=$11.portrait,hidden_portraits=$11.hidden_portraits,primary_portrait=$11.primary_portrait,imdb_urls=$11.imdb_urls,instagram_screennames=$11.instagram_screennames,myspace_urls=$11.myspace_urls,tumblr_screennames=$11.tumblr_screennames,youtube_urls=$11.youtube_urls,gid85=$12.gid,acousticVector=$12.acousticVector,gid87=$13.gid,genres88=$13.genres,extended_genres=$13.extended_genres,currency=$14\nrows=100.0,
cost={inf}",shape=box]
rel64
[label="rel#64:LogicalCalc\ninput=RelSubset#39,expr#0..14={inputs},expr#15=$t3.id,expr#16=$t3.gid,expr#17=$t3.name,expr#18=$t3.redirect,expr#19=$t3.fuzzyname,expr#20=$t3.inserted,expr#21=$t5.id,expr#22=$t5.similars,expr#23=$t6.gid,expr#24=$t6.version,expr#25=$t6.vector,expr#26=$t7.value,expr#27=$t7.gid,expr#28=$t7.domains,expr#29=$t9.uri,expr#30=$t9.gid,expr#31=$t9.region,expr#32=$t9.popularity_raw,expr#33=$t9.popularity_normalized,expr#34=$t9.percentile,expr#35=$t9.rank,expr#36=$t11.gid,expr#37=$t11.artist_name,expr#38=$t11.bios,expr#39=$t11.ancestor_artists,expr#40=$t11.descendant_artists,expr#41=$t11.asserted_similars,expr#42=$t11.tags,expr#43=$t11.genres,expr#44=$t11.members,expr#45=$t11.members_past,expr#46=$t11.meanings,expr#47=$t11.country,expr#48=$t11.voted_descriptions,expr#49=$t11.years_active,expr#50=$t11.amazon_urls,expr#51=$t11.itunes_urls,expr#52=$t11.lastfm_urls,expr#53=$t11.facebook_urls,expr#54=$t11.urbandictionary_urls,expr#55=$t11.wikipedia_urls,expr#56=$t11.twitter_screennames,expr#57=$t11.categories,expr#58=$t11.category,expr#59=$t58.childrens,expr#60=$t58.classical,expr#61=$t58.curated,expr#62=$t58.deceptive,expr#63=$t58.generic,expr#64=$t58.inactive,expr#65=$t58.karaoke,expr#66=$t58.non_artist,expr#67=$t58.soundalike,expr#68=$t58.unpreferred,expr#69=$t58.offensive,expr#70=$t58.do_not_recommend,expr#71=$t58.do_not_support,expr#72=$t58.pass_on_programming,expr#73=$t58.deceased,expr#74=$t11.edited_terms,expr#75=$t11.edited_text_terms,expr#76=$t11.free_text_terms,expr#77=$t11.display_terms,expr#78=$t11.extra,expr#79=$t11.sims_curation,expr#80=$t79.force_curated_sims,expr#81=$t79.curated_sims_uris,expr#82=$t79.blacklisted_sims_uris,expr#83=$t11.display_bios,expr#84=$t11.discogs_uri,expr#85=$t11.musicbrainz_uri,expr#86=$t11.rovi_music_uri,expr#87=$t11.blocked_display_bio_providers,expr#88=$t11.portrait,expr#89=$t11.hidden_portraits,expr#90=$t11.primary_portrait,expr#91=$t11.imdb_urls,expr#92=$t11.instagram_screennames,expr#93=$t11.myspace_urls,expr#94=$t11.tumblr_screennames,expr#95=$t11.youtube_urls,expr#96=$t12.gid,expr#97=$t12.acousticVector,expr#98=$t13.gid,expr#99=$t13.genres,expr#100=$t13.extended_genres,artist_gid=$t0,artist_uri=$t1,date=$t2,id=$t15,gid=$t16,name=$t17,redirect=$t18,fuzzyname=$t19,inserted=$t20,echo_nest_artists=$t4,id10=$t21,similars=$t22,gid12=$t23,version=$t24,vector=$t25,value=$t26,gid16=$t27,domains=$t28,playlist_adds=$t8,uri=$t29,gid20=$t30,region=$t31,popularity_raw=$t32,popularity_normalized=$t33,percentile=$t34,rank=$t35,popularity_regional=$t10,gid27=$t36,artist_name=$t37,bios=$t38,ancestor_artists=$t39,descendant_artists=$t40,asserted_similars=$t41,tags=$t42,genres=$t43,members=$t44,members_past=$t45,meanings=$t46,country=$t47,voted_descriptions=$t48,years_active=$t49,amazon_urls=$t50,itunes_urls=$t51,lastfm_urls=$t52,facebook_urls=$t53,urbandictionary_urls=$t54,wikipedia_urls=$t55,twitter_screennames=$t56,categories=$t57,childrens=$t59,classical=$t60,curated=$t61,deceptive=$t62,generic=$t63,inactive=$t64,karaoke=$t65,non_artist=$t66,soundalike=$t67,unpreferred=$t68,offensive=$t69,do_not_recommend=$t70,do_not_support=$t71,pass_on_programming=$t72,deceased=$t73,edited_terms=$t74,edited_text_terms=$t75,free_text_terms=$t76,display_terms=$t77,extra=$t78,force_curated_sims=$t80,curated_sims_uris=$t81,blacklisted_sims_uris=$t82,display_bios=$t83,discogs_uri=$t84,musicbrainz_uri=$t85,rovi_music_uri=$t86,blocked_display_bio_providers=$t87,portrait=$t88,hidden_portraits=$t89,primary_portrait=$t90,imdb_urls=$t91,instagram_screennames=$t92,myspace_urls=$t93,tumblr_screennames=$t94,youtube_urls=$t95,gid85=$t96,acousticVector=$t97,gid87=$t98,genres88=$t99,extended_genres=$t100,currency=$t14\nrows=100.0,
cost={inf}",shape=box]
rel65
[label="rel#65:BeamCalcRel\ninput=RelSubset#39,expr#0..14={inputs},expr#15=$t3.id,expr#16=$t3.gid,expr#17=$t3.name,expr#18=$t3.redirect,expr#19=$t3.fuzzyname,expr#20=$t3.inserted,expr#21=$t5.id,expr#22=$t5.similars,expr#23=$t6.gid,expr#24=$t6.version,expr#25=$t6.vector,expr#26=$t7.value,expr#27=$t7.gid,expr#28=$t7.domains,expr#29=$t9.uri,expr#30=$t9.gid,expr#31=$t9.region,expr#32=$t9.popularity_raw,expr#33=$t9.popularity_normalized,expr#34=$t9.percentile,expr#35=$t9.rank,expr#36=$t11.gid,expr#37=$t11.artist_name,expr#38=$t11.bios,expr#39=$t11.ancestor_artists,expr#40=$t11.descendant_artists,expr#41=$t11.asserted_similars,expr#42=$t11.tags,expr#43=$t11.genres,expr#44=$t11.members,expr#45=$t11.members_past,expr#46=$t11.meanings,expr#47=$t11.country,expr#48=$t11.voted_descriptions,expr#49=$t11.years_active,expr#50=$t11.amazon_urls,expr#51=$t11.itunes_urls,expr#52=$t11.lastfm_urls,expr#53=$t11.facebook_urls,expr#54=$t11.urbandictionary_urls,expr#55=$t11.wikipedia_urls,expr#56=$t11.twitter_screennames,expr#57=$t11.categories,expr#58=$t11.category,expr#59=$t58.childrens,expr#60=$t58.classical,expr#61=$t58.curated,expr#62=$t58.deceptive,expr#63=$t58.generic,expr#64=$t58.inactive,expr#65=$t58.karaoke,expr#66=$t58.non_artist,expr#67=$t58.soundalike,expr#68=$t58.unpreferred,expr#69=$t58.offensive,expr#70=$t58.do_not_recommend,expr#71=$t58.do_not_support,expr#72=$t58.pass_on_programming,expr#73=$t58.deceased,expr#74=$t11.edited_terms,expr#75=$t11.edited_text_terms,expr#76=$t11.free_text_terms,expr#77=$t11.display_terms,expr#78=$t11.extra,expr#79=$t11.sims_curation,expr#80=$t79.force_curated_sims,expr#81=$t79.curated_sims_uris,expr#82=$t79.blacklisted_sims_uris,expr#83=$t11.display_bios,expr#84=$t11.discogs_uri,expr#85=$t11.musicbrainz_uri,expr#86=$t11.rovi_music_uri,expr#87=$t11.blocked_display_bio_providers,expr#88=$t11.portrait,expr#89=$t11.hidden_portraits,expr#90=$t11.primary_portrait,expr#91=$t11.imdb_urls,expr#92=$t11.instagram_screennames,expr#93=$t11.myspace_urls,expr#94=$t11.tumblr_screennames,expr#95=$t11.youtube_urls,expr#96=$t12.gid,expr#97=$t12.acousticVector,expr#98=$t13.gid,expr#99=$t13.genres,expr#100=$t13.extended_genres,artist_gid=$t0,artist_uri=$t1,date=$t2,id=$t15,gid=$t16,name=$t17,redirect=$t18,fuzzyname=$t19,inserted=$t20,echo_nest_artists=$t4,id10=$t21,similars=$t22,gid12=$t23,version=$t24,vector=$t25,value=$t26,gid16=$t27,domains=$t28,playlist_adds=$t8,uri=$t29,gid20=$t30,region=$t31,popularity_raw=$t32,popularity_normalized=$t33,percentile=$t34,rank=$t35,popularity_regional=$t10,gid27=$t36,artist_name=$t37,bios=$t38,ancestor_artists=$t39,descendant_artists=$t40,asserted_similars=$t41,tags=$t42,genres=$t43,members=$t44,members_past=$t45,meanings=$t46,country=$t47,voted_descriptions=$t48,years_active=$t49,amazon_urls=$t50,itunes_urls=$t51,lastfm_urls=$t52,facebook_urls=$t53,urbandictionary_urls=$t54,wikipedia_urls=$t55,twitter_screennames=$t56,categories=$t57,childrens=$t59,classical=$t60,curated=$t61,deceptive=$t62,generic=$t63,inactive=$t64,karaoke=$t65,non_artist=$t66,soundalike=$t67,unpreferred=$t68,offensive=$t69,do_not_recommend=$t70,do_not_support=$t71,pass_on_programming=$t72,deceased=$t73,edited_terms=$t74,edited_text_terms=$t75,free_text_terms=$t76,display_terms=$t77,extra=$t78,force_curated_sims=$t80,curated_sims_uris=$t81,blacklisted_sims_uris=$t82,display_bios=$t83,discogs_uri=$t84,musicbrainz_uri=$t85,rovi_music_uri=$t86,blocked_display_bio_providers=$t87,portrait=$t88,hidden_portraits=$t89,primary_portrait=$t90,imdb_urls=$t91,instagram_screennames=$t92,myspace_urls=$t93,tumblr_screennames=$t94,youtube_urls=$t95,gid85=$t96,acousticVector=$t97,gid87=$t98,genres88=$t99,extended_genres=$t100,currency=$t14\nrows=100.0,
cost={200.0 cpu, 0.0 cpuRate }",color=blue,shape=box]
rel76
[label="rel#76:BeamEnumerableConverter\ninput=RelSubset#66\nrows=100.0,
cost={1.7976931348623157E308 cpu, 1.7976931348623157E308 cpuRate
}",color=blue,shape=box]
subset41 [label="rel#41:Subset#1.NONE"]
subset66 [label="rel#66:Subset#1.BEAM_LOGICAL"]
subset77 [label="rel#77:Subset#1.ENUMERABLE"]
}
subgraph cluster2{
label="Set 2 RecordType(INTEGER ZERO)";
rel8 [label="rel#8:LogicalValues\ntype=RecordType(INTEGER
ZERO),tuples=[{ 0 }]\nrows=1.0, cost={inf}",shape=box]
rel75 [label="rel#75:BeamValuesRel\ntype=RecordType(INTEGER
ZERO),tuples=[{ 0 }]\nrows=1.0, cost={1.0 cpu, 0.0 cpuRate
}",color=blue,shape=box]
rel88
[label="rel#88:BeamEnumerableConverter\ninput=RelSubset#73\nrows=1.0,
cost={1.7976931348623157E308 cpu, 1.7976931348623157E308 cpuRate
}",color=blue,shape=box]
subset42 [label="rel#42:Subset#2.NONE"]
subset73 [label="rel#73:Subset#2.BEAM_LOGICAL"]
subset89 [label="rel#89:Subset#2.ENUMERABLE"]
}
subgraph cluster3{
label="Set 3 RecordType(RecordType(VARCHAR gid, VARCHAR name)
ARRAY genres)";
rel43
[label="rel#43:LogicalProject\ninput=RelSubset#42,genres=$cor0.genres_88\nrows=1.0,
cost={inf}",shape=box]
rel72
[label="rel#72:LogicalCalc\ninput=RelSubset#42,expr#0={inputs},expr#1=$cor0,expr#2=$t1.genres_88,genres=$t2\nrows=1.0,
cost={inf}",shape=box]
rel74
[label="rel#74:BeamCalcRel\ninput=RelSubset#73,expr#0={inputs},expr#1=$cor0,expr#2=$t1.genres_88,genres=$t2\nrows=1.0,
cost={2.0 cpu, 0.0 cpuRate }",color=blue,shape=box]
rel85
[label="rel#85:BeamEnumerableConverter\ninput=RelSubset#69\nrows=1.0,
cost={1.7976931348623157E308 cpu, 1.7976931348623157E308 cpuRate
}",color=blue,shape=box]
subset44 [label="rel#44:Subset#3.NONE"]
subset69 [label="rel#69:Subset#3.BEAM_LOGICAL"]
subset86 [label="rel#86:Subset#3.ENUMERABLE"]
}
subgraph cluster4{
label="Set 4 RecordType(VARCHAR gid, VARCHAR name)";
rel45 [label="rel#45:Uncollect\ninput=RelSubset#44\nrows=1.0,
cost={inf}",shape=box]
rel70
[label="rel#70:BeamUncollectRel\ninput=RelSubset#69\nrows=1.0, cost={3.0 cpu,
1.0 cpuRate }",color=blue,shape=box]
rel80
[label="rel#80:BeamEnumerableConverter\ninput=RelSubset#71\nrows=1.0,
cost={1.7976931348623157E308 cpu, 1.7976931348623157E308 cpuRate
}",color=blue,shape=box]
subset46 [label="rel#46:Subset#4.NONE"]
subset71 [label="rel#71:Subset#4.BEAM_LOGICAL"]
subset81 [label="rel#81:Subset#4.ENUMERABLE"]
}
subgraph cluster5{
label="Set 5 RecordType(VARCHAR artist_gid, VARCHAR artist_uri,
VARCHAR date, BIGINT id, VARCHAR gid, VARCHAR name, BIGINT redirect, VARCHAR
fuzzyname, BIGINT inserted, RecordType(VARCHAR en_id, VARCHAR name, VARCHAR
spotify_best_match_gid, VARCHAR ARRAY spotify_gids, VARCHAR ARRAY aliases,
VARCHAR ARRAY urls, RecordType(VARCHAR attribution_url, VARCHAR attribution,
RecordType(VARCHAR name, VARCHAR url, VARCHAR version) license, VARCHAR
biography, VARCHAR biography_site, VARCHAR biography_url) ARRAY biographies,
RecordType(VARCHAR name, VARCHAR language) ARRAY display_aliases,
RecordType(VARCHAR name, BIGINT rank, VARCHAR spotify_gid) ARRAY genres,
RecordType(VARCHAR name, BIGINT count, VARCHAR spotify_gid) ARRAY
inferred_genres, VARCHAR ARRAY meta_genres, VARCHAR ARRAY merge_names,
RecordType(VARCHAR en_id, DOUBLE score) ARRAY computed_similar_en_ids,
RecordType(VARCHAR key, VARCHAR value) ARRAY url_map, VARCHAR country, VARCHAR
country_code, DOUBLE latitude, DOUBLE longitude, VARCHAR location, VARCHAR
location_raw, VARCHAR region, VARCHAR town, RecordType(BIGINT start, BIGINT
stop) ARRAY years_active_ranges, RecordType(DOUBLE score, BIGINT rank)
discovery, RecordType(DOUBLE score, BIGINT rank) familiarity, RecordType(DOUBLE
score, BIGINT rank) hotttnesss, RecordType(VARCHAR name, DOUBLE frequency,
BIGINT weight) ARRAY display_top_terms, RecordType(VARCHAR name, DOUBLE
frequency, BIGINT weight) ARRAY edited_top_terms, RecordType(VARCHAR name,
DOUBLE frequency, BIGINT weight) ARRAY edited_text_top_terms,
RecordType(VARCHAR name, DOUBLE frequency, BIGINT weight) ARRAY
free_text_top_terms, VARCHAR ARRAY descendant_en_ids, VARCHAR ARRAY
crawled_genres, VARCHAR ARRAY ancestor_en_ids, VARCHAR ARRAY shared_members,
VARCHAR ARRAY members, VARCHAR ARRAY crawled_similar_en_ids, VARCHAR ARRAY
styles, VARCHAR ARRAY tags, BOOLEAN ambiguous, BOOLEAN kids_music, VARCHAR
ARRAY musicbrainz_ids) ARRAY echo_nest_artists, VARCHAR id10,
RecordType(VARCHAR id, DOUBLE score, RecordType(VARCHAR field,
RecordType(VARCHAR value, DOUBLE query_boost) ARRAY matched_values) ARRAY
explain_info, BOOLEAN curated) ARRAY similars, VARCHAR gid12, VARCHAR version,
DOUBLE ARRAY vector, BIGINT value, VARCHAR gid16, VARCHAR ARRAY domains,
RecordType(BIGINT value, VARCHAR gid, VARCHAR country) ARRAY playlist_adds,
VARCHAR uri, VARCHAR gid20, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank, RecordType(VARCHAR uri,
VARCHAR gid, VARCHAR region, DOUBLE popularity_raw, DOUBLE
popularity_normalized, DOUBLE percentile, BIGINT rank) ARRAY
popularity_regional, VARCHAR gid27, VARCHAR artist_name, RecordType(VARCHAR
bio_text, VARCHAR bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR
license_version, VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR
language) ARRAY bios, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
ancestor_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
descendant_artists, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
asserted_similars, RecordType(VARCHAR tag_text, DOUBLE weight) ARRAY tags,
VARCHAR ARRAY genres, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY
members, RecordType(VARCHAR name, VARCHAR url, VARCHAR gid) ARRAY members_past,
VARCHAR ARRAY meanings, VARCHAR country, RecordType(VARCHAR
voted_description_text, BIGINT votes_up, BIGINT votes_down) ARRAY
voted_descriptions, RecordType(BIGINT year_start, BIGINT year_stop) ARRAY
years_active, VARCHAR ARRAY amazon_urls, VARCHAR ARRAY itunes_urls, VARCHAR
ARRAY lastfm_urls, VARCHAR ARRAY facebook_urls, VARCHAR ARRAY
urbandictionary_urls, VARCHAR ARRAY wikipedia_urls, VARCHAR ARRAY
twitter_screennames, VARCHAR ARRAY categories, BOOLEAN childrens, BOOLEAN
classical, BOOLEAN curated, BOOLEAN deceptive, BOOLEAN generic, BOOLEAN
inactive, BOOLEAN karaoke, BOOLEAN non_artist, BOOLEAN soundalike, BOOLEAN
unpreferred, BOOLEAN offensive, BOOLEAN do_not_recommend, BOOLEAN
do_not_support, BOOLEAN pass_on_programming, BOOLEAN deceased,
RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight) ARRAY
edited_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE weight)
ARRAY edited_text_terms, RecordType(VARCHAR term_text, BIGINT frequency, DOUBLE
weight) ARRAY free_text_terms, RecordType(VARCHAR term_text, BIGINT frequency,
DOUBLE weight) ARRAY display_terms, RecordType(VARCHAR key, VARCHAR value)
ARRAY extra, BOOLEAN force_curated_sims, VARCHAR ARRAY curated_sims_uris,
VARCHAR ARRAY blacklisted_sims_uris, RecordType(VARCHAR bio_text, VARCHAR
bio_url, VARCHAR license_text, VARCHAR license_url, VARCHAR license_version,
VARCHAR attribution_text, VARCHAR attribution_url, VARCHAR language) ARRAY
display_bios, VARCHAR ARRAY discogs_uri, VARCHAR ARRAY musicbrainz_uri, VARCHAR
ARRAY rovi_music_uri, RecordType(VARCHAR bio_provider, VARCHAR comment) ARRAY
blocked_display_bio_providers, RecordType(VARCHAR rovi_image_id, BIGINT
sort_order, RecordType(VARCHAR size, VARCHAR url, BIGINT width, BIGINT height)
ARRAY sizes) ARRAY portrait, VARCHAR ARRAY hidden_portraits, VARCHAR
primary_portrait, VARCHAR ARRAY imdb_urls, VARCHAR ARRAY instagram_screennames,
VARCHAR ARRAY myspace_urls, VARCHAR ARRAY tumblr_screennames, VARCHAR ARRAY
youtube_urls, VARCHAR gid85, DOUBLE ARRAY acousticVector, VARCHAR gid87,
RecordType(VARCHAR gid, VARCHAR name) ARRAY genres88, RecordType(VARCHAR gid,
VARCHAR name) ARRAY extended_genres, RecordType(DOUBLE value, VARCHAR gid,
VARCHAR region) ARRAY currency, VARCHAR gid0, VARCHAR name0)";
rel47
[label="rel#47:LogicalCorrelate\nleft=RelSubset#41,right=RelSubset#46,correlation=$cor0,joinType=inner,requiredColumns={87}\nrows=1.0,
cost={inf}",shape=box]
rel60
[label="rel#60:BeamUnnestRel\ninput=RelSubset#41,unnestIndex=88\nrows=100.0,
cost={inf}",shape=box]
rel62
[label="rel#62:BeamEnumerableConverter\ninput=RelSubset#54\nrows=1.0,
cost={inf}",shape=box]
subset48 [label="rel#48:Subset#5.NONE"]
subset54 [label="rel#54:Subset#5.BEAM_LOGICAL"]
subset63 [label="rel#63:Subset#5.ENUMERABLE"]
}
subgraph cluster6{
label="Set 6 RecordType(VARCHAR artist_gid)";
rel49
[label="rel#49:LogicalProject\ninput=RelSubset#48,artist_gid=$0\nrows=1.0,
cost={inf}",shape=box]
rel52
[label="rel#52:AbstractConverter\ninput=RelSubset#50,convention=BEAM_LOGICAL\nrows=1.0,
cost={inf}",shape=box]
rel53
[label="rel#53:LogicalCalc\ninput=RelSubset#48,expr#0..92={inputs},artist_gid=$t0\nrows=1.0,
cost={inf}",shape=box]
rel55
[label="rel#55:BeamCalcRel\ninput=RelSubset#54,expr#0..92={inputs},artist_gid=$t0\nrows=1.0,
cost={inf}",shape=box]
rel57
[label="rel#57:BeamEnumerableConverter\ninput=RelSubset#51\nrows=1.0,
cost={inf}",shape=box]
subset50 [label="rel#50:Subset#6.NONE"]
subset51 [label="rel#51:Subset#6.BEAM_LOGICAL"]
subset58 [label="rel#58:Subset#6.ENUMERABLE"]
}
root -> subset51;
subset39 -> rel6[color=blue];
subset91 -> rel90[color=blue]; rel90 -> subset39[color=blue];
subset41 -> rel40; rel40 -> subset39;
subset41 -> rel64; rel64 -> subset39;
subset66 -> rel65[color=blue]; rel65 -> subset39[color=blue];
subset77 -> rel76[color=blue]; rel76 -> subset66[color=blue];
subset42 -> rel8;
subset73 -> rel75[color=blue];
subset89 -> rel88[color=blue]; rel88 -> subset73[color=blue];
subset44 -> rel43; rel43 -> subset42;
subset44 -> rel72; rel72 -> subset42;
subset69 -> rel74[color=blue]; rel74 -> subset73[color=blue];
subset86 -> rel85[color=blue]; rel85 -> subset69[color=blue];
subset46 -> rel45; rel45 -> subset44;
subset71 -> rel70[color=blue]; rel70 -> subset69[color=blue];
subset81 -> rel80[color=blue]; rel80 -> subset71[color=blue];
subset48 -> rel47; rel47 -> subset41[label="0"]; rel47 ->
subset46[label="1"];
subset54 -> rel60; rel60 -> subset41;
subset63 -> rel62; rel62 -> subset54;
subset50 -> rel49; rel49 -> subset48;
subset51 -> rel52; rel52 -> subset50;
subset50 -> rel53; rel53 -> subset48;
subset51 -> rel55; rel55 -> subset54;
subset58 -> rel57; rel57 -> subset51;
}
at
org.apache.beam.repackaged.sql.org.apache.calcite.plan.volcano.RelSubset$CheapestPlanReplacer.visit(RelSubset.java:587)
at
org.apache.beam.repackaged.sql.org.apache.calcite.plan.volcano.RelSubset.buildCheapestPlan(RelSubset.java:304)
at
org.apache.beam.repackaged.sql.org.apache.calcite.plan.volcano.VolcanoPlanner.findBestExp(VolcanoPlanner.java:647)
at
org.apache.beam.repackaged.sql.org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:324)
at
org.apache.beam.repackaged.sql.org.apache.calcite.prepare.PlannerImpl.transform(PlannerImpl.java:357)
at
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner.convertToBeamRel(CalciteQueryPlanner.java:166)
... 32 more
{noformat}
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
