JuliaData / JuliaDB.jl

Parallel analytical database in pure Julia
http://juliadb.org/
Other
768 stars 62 forks source link

Error with groupby() on DTable #135

Open claireh93 opened 6 years ago

claireh93 commented 6 years ago

I have a large (~20GB) JuliaDB table saved in 8 chunks that I am now trying to perform some summary functions on. For example, :species is a column of Strings and I would like to know how many instances I have of each unique string. However, I run into errors when using multiple workers (e.g. ERROR: Error deserializing a remote exception from worker 2 Remote(original) exception of type TypeError).

Running it on just one worker seems to give me a more informative error:

using JuliaDB
table = load("output")
result = groupby(length, table, :species)
ERROR: You're using a PooledArray with ref type UInt16, which can only hold 65535 values,
and you just tried to add the 65536th reference.  Please change the ref type
to a larger int type, or use the default ref type (UInt32).

I tested out this function on a smaller test table and it seemed to work fine, could there be a problem with the way I have saved or loaded the data? Thanks!

piever commented 6 years ago

Off-Topic: don't call your data table as that's a pretty useful function that you're overwriting!

What is the output of typeof(column(table, :species))? And what is the length of unique(column(table, :species))? It seems like JuliaDB is trying to use PooledArray, (which is useful to represent a vector of strings with few unique values repeated many times) but failing as you actually hava a lot of different values of species.

Can you try:

using PooledArrays
table2 = setcol(table, :species, PooledArray(column(table, :species), UInt32))
result = groupby(length, table2, :species)

and see if it fixes it?

What the error is telling you is that you used (or JuliaDB.load chose it for you, I don't know) a PooledArray(v, UInt16) which can have up to 2^16 different values, which apparently is not enough for your large dataset, so you need PooledArray(v, UInt32) which can have 2^32 = 4294967296 distinct values and that is certainly enough. Maybe the load function should take care of this for you though, so that the user never have to worry about these issues.

@shashi : why do we use PooledArrays and not CategoricalArrays like DataFrames does? Is it because of having different missing data?

EDIT: this thing that I'm suggesting, I'm not sure if it works also on distributed tables, better try it on the non-distributed (= 1 worker) case.

shashi commented 6 years ago

Could you paste the full stack trace? I could reproduce this crash with some other piece of PooledArray code:

ERROR: You're using a PooledArray with ref type UInt8, which can only hold 255 values,
and you just tried to add the 256th reference.  Please change the ref type
to a larger int type, or use the default ref type (UInt32).
Stacktrace:
 [1] unsafe_pool_push!(::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Float64) at /home/shashi/.julia/v0.6/PooledArrays/src/PooledArrays.jl:330
 [2] getpoolidx(::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Float64) at /home/shashi/.julia/v0.6/PooledArrays/src/PooledArrays.jl:321
 [3] setindex! at /home/shashi/.julia/v0.6/PooledArrays/src/PooledArrays.jl:354 [inlined]
 [4] macro expansion at ./multidimensional.jl:558 [inlined]
 [5] macro expansion at ./cartesian.jl:64 [inlined]
 [6] macro expansion at ./multidimensional.jl:556 [inlined]
 [7] _unsafe_setindex!(::IndexCartesian, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::UnitRange{Int64}) at ./multidimensional.jl:549
 [8] macro expansion at ./multidimensional.jl:541 [inlined]
 [9] _setindex! at ./multidimensional.jl:537 [inlined]
 [10] setindex! at ./abstractarray.jl:968 [inlined]
 [11] typed_vcat(::Type{Float64}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Vararg{PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}},N} where N) at ./abstractarray.jl:1089
 [12] vcat(::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Vararg{PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}},N} where N) at ./abstractarray.jl:1077
 [13] macro expansion at /home/shashi/.julia/v0.6/Revise/src/Revise.jl:775 [inlined]
 [14] (::Revise.##17#18{Base.REPL.REPLBackend})() at ./event.jl:73
shashi commented 6 years ago

Also typeof(table) might help me with figuring out what is failing. (I suspect species column itself is not problematic...)

On Mon, Feb 19, 2018 at 9:08 PM, Shashi Gowda notifications@github.com wrote:

Could you paste the full stack trace? I could reproduce this crash with some other piece of PooledArray code:

ERROR: You're using a PooledArray with ref type UInt8, which can only hold 255 values, and you just tried to add the 256th reference. Please change the ref type to a larger int type, or use the default ref type (UInt32). Stacktrace: [1] unsafe_pool_push!(::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Float64) at /home/shashi/.julia/v0.6/PooledArrays/src/PooledArrays.jl:330 [2] getpoolidx(::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Float64) at /home/shashi/.julia/v0.6/PooledArrays/src/PooledArrays.jl:321 [3] setindex! at /home/shashi/.julia/v0.6/PooledArrays/src/PooledArrays.jl:354 [inlined] [4] macro expansion at ./multidimensional.jl:558 [inlined] [5] macro expansion at ./cartesian.jl:64 [inlined] [6] macro expansion at ./multidimensional.jl:556 [inlined] [7] _unsafe_setindex!(::IndexCartesian, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::UnitRange{Int64}) at ./multidimensional.jl:549 [8] macro expansion at ./multidimensional.jl:541 [inlined] [9] _setindex! at ./multidimensional.jl:537 [inlined] [10] setindex! at ./abstractarray.jl:968 [inlined] [11] typed_vcat(::Type{Float64}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Vararg{PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}},N} where N) at ./abstractarray.jl:1089 [12] vcat(::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}}, ::Vararg{PooledArrays.PooledArray{Float64,UInt8,1,Array{UInt8,1}},N} where N) at ./abstractarray.jl:1077 [13] macro expansion at /home/shashi/.julia/v0.6/Revise/src/Revise.jl:775 [inlined] [14] (::Revise.##17#18{Base.REPL.REPLBackend})() at ./event.jl:73

— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub https://github.com/JuliaComputing/JuliaDB.jl/issues/135#issuecomment-366728655, or mute the thread https://github.com/notifications/unsubscribe-auth/AABlPGdwzpX1Sx11NOUCNt1dIbIouH7Bks5tWZVjgaJpZM4SKgvG .

claireh93 commented 6 years ago

Ah yes, it's not really called table, I just thought that might make it more readable, oops!

typeof(table) gives:

JuliaDB.DNextTable{NamedTuples._NT_phylum_class_order_family_genus_species_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_phylum_class_order_family_genus_species_scientificname{String,String,String,String,String,String,String}}

The rest will take a little while to run on one worker as the data is so big, but I will post the results as soon as I get them - thanks for your help!

shashi commented 6 years ago

Could you also post,

typeof(table.chunks[1]) or typeof(collect(table.chunks[1]))?

claireh93 commented 6 years ago

typeof(table.chunks[1]) gives:

Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_phylum_class_order_family_genus_species_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_phylum_class_order_family_genus_species_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1}}}},MemPool.DRef}

typeof(collect(table.chunks[1])) gives:

IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_phylum_class_order_family_genus_species_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_phylum_class_order_family_genus_species_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1}}}}
claireh93 commented 6 years ago

Okay so full stack trace is:

ERROR: You're using a PooledArray with ref type UInt16, which can only hold 65535 values,
and you just tried to add the 65536th reference.  Please change the ref type
to a larger int type, or use the default ref type (UInt32).
unsafe_pool_push!(::PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}, ::String) at /home/claireh/.julia/v0.6/PooledArrays/src/PooledArrays.jl:329
getpoolidx(::PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}, ::String) at /home/claireh/.julia/v0.6/PooledArrays/src/PooledArrays.jl:320
setindex! at /home/claireh/.julia/v0.6/PooledArrays/src/PooledArrays.jl:353 [inlined]
macro expansion at ./multidimensional.jl:558 [inlined]
macro expansion at ./cartesian.jl:64 [inlined]
macro expansion at ./multidimensional.jl:556 [inlined]
_unsafe_setindex!(::IndexCartesian, ::PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}, ::Array{String,1}, ::UnitRange{Int64}) at ./multidimensional.jl:549
macro expansion at ./multidimensional.jl:541 [inlined]
_setindex! at ./multidimensional.jl:537 [inlined]
setindex!(::PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}, ::Array{String,1}, ::UnitRange{Int64}) at ./abstractarray.jl:968
typed_vcat(::Type{String}, ::PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}, ::Array{String,1}) at ./abstractarray.jl:1089
macro expansion at /home/claireh/.julia/v0.6/NamedTuples/src/NamedTuples.jl:286 [inlined]
_map(::Base.#vcat, ::NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}, ::NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}) at /home/claireh/.julia/v0.6/NamedTuples/src/NamedTuples.jl:273
merge(::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}}}, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}}}) at /home/claireh/.julia/v0.6/IndexedTables/src/join.jl:812
_merge(::JuliaDB.##76#77, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}}}, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}}}) at /home/claireh/.julia/v0.6/JuliaDB/src/table.jl:256
_merge(::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}}}, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}}}) at /home/claireh/.julia/v0.6/JuliaDB/src/table.jl:265
do_task(::Dagger.Context, ::Dagger.OSProc, ::Int64, ::Function, ::Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}}},MemPool.DRef}}, ::Bool, ::Bool, ::Bool) at /home/claireh/.julia/v0.6/Dagger/src/compute.jl:319
(::Base.Distributed.##135#136{Dagger.#do_task,Tuple{Dagger.Context,Dagger.OSProc,Int64,JuliaDB.#_merge,Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}}},MemPool.DRef}},Bool,Bool,Bool},Array{Any,1}})() at ./distributed/remotecall.jl:314
run_work_thunk(::Base.Distributed.##135#136{Dagger.#do_task,Tuple{Dagger.Context,Dagger.OSProc,Int64,JuliaDB.#_merge,Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}}},MemPool.DRef}},Bool,Bool,Bool},Array{Any,1}}, ::Bool) at ./distributed/process_messages.jl:56
#remotecall_fetch#140(::Array{Any,1}, ::Function, ::Function, ::Base.Distributed.LocalProcess, ::Dagger.Context, ::Vararg{Any,N} where N) at ./distributed/remotecall.jl:339
remotecall_fetch(::Function, ::Base.Distributed.LocalProcess, ::Dagger.Context, ::Vararg{Any,N} where N) at ./distributed/remotecall.jl:339
#remotecall_fetch#144(::Array{Any,1}, ::Function, ::Function, ::Int64, ::Dagger.Context, ::Vararg{Any,N} where N) at ./distributed/remotecall.jl:367
macro expansion at /home/claireh/.julia/v0.6/Dagger/src/compute.jl:332 [inlined]
(::Dagger.##69#70{Dagger.Context,Dagger.OSProc,Int64,JuliaDB.#_merge,Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,String,String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},Array{String,1},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}}}}},MemPool.DRef}},Channel{Any},Bool,Bool,Bool})() at ./event.jl:73
claireh93 commented 6 years ago

@piever I tried your suggestion on a smaller test dataset that produces the same error but I get some problems with setcol:

table2 = setcol(table, :species, PooledArray(column(table, :species), UInt32))
ERROR: MethodError: Cannot `convert` an object of type Dagger.Chunk{String,MemPool.DRef} to an object of type String
This may have arisen from a call to the constructor String(...),
since type constructors fall back to convert methods.
Stacktrace:
 [1] copy!(::IndexLinear, ::Array{String,1}, ::IndexLinear, ::Array{Dagger.Chunk{String,MemPool.DRef},1}) at ./abstractarray.jl:656
 [2] convert(::Type{Array{String,1}}, ::Array{Dagger.Chunk{String,MemPool.DRef},1}) at ./array.jl:373
 [3] Type at /Users/claireh/.julia/v0.6/PooledArrays/src/PooledArrays.jl:90 [inlined]
 [4] PooledArrays.PooledArray(::Dagger.DArray{String,1,JuliaDB.##59#62}, ::Type{UInt32}) at /Users/claireh/.julia/v0.6/PooledArrays/src/PooledArrays.jl:108

and

typeof(column(table, :species))
Dagger.DArray{String,1,JuliaDB.##59#62}
piever commented 6 years ago

Fair enough, table is still of distributed type, even if with one worker whereas my workaround works only for the non-distributed type. Could your try:

table1 = collect(table)
table2 = setcol(table1, :species, PooledArray(column(table1, :species), UInt32))
result = groupby(length, table2, :species)
claireh93 commented 6 years ago

Ah collecting the table on line 1 seems to give me the same Pooled Array error (i.e. ERROR: You're using a PooledArray with ref type UInt8, which can only hold 255 values, and you just tried to add the 256th reference. Please change the ref type to a larger int type, or use the default ref type (UInt32).)?

shashi commented 6 years ago

I think this is because there is a missing vcat method for PooledArray and Array... The fallback implementation from base is causing the pool to "overflow". I think this should return an Array.

shashi commented 6 years ago

@claireh93 I have added the right methods in the PooledArrays package -- if you run Pkg.checkout("PooledArrays") and run your query the problem should hopefully go away. If you can test it, I will tag a release of that package.

Thanks!

claireh93 commented 6 years ago

Thanks @shashi ! I had a go on my smaller test data and it now seems to give me a different error:

ERROR: MethodError: similar(::PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}, ::Type{DataValues.DataValue{String}}, ::Tuple{Int64}) is ambiguous. Candidates:
  similar(x::AbstractArray, ::Type{DataValues.DataValue{T}}, dims::Tuple{Vararg{Int64,N}} where N) where T in DataValues at /Users/claireh/.julia/v0.6/DataValues/src/array/primitives.jl:13
  similar(pa::PooledArrays.PooledArray{T,R,N,RA} where RA where N, S::Type, dims::Tuple{Vararg{Int64,N}} where N) where {T, R} in PooledArrays at /Users/claireh/.julia/v0.6/PooledArrays/src/PooledArrays.jl:148
Possible fix, define
  similar(::PooledArrays.PooledArray{T,R,N,RA} where RA where N, ::Type{DataValues.DataValue{T}}, ::Tuple{Vararg{Int64,N}} where N)
typed_vcat(::Type{DataValues.DataValue{String}}, ::PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}, ::DataValues.DataValueArray{String,1}) at ./abstractarray.jl:1084
macro expansion at /Users/claireh/.julia/v0.6/NamedTuples/src/NamedTuples.jl:286 [inlined]
_map(::Base.#vcat, ::NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}, ::NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}) at /Users/claireh/.julia/v0.6/NamedTuples/src/NamedTuples.jl:273
merge(::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Union{}},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}}, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},DataValues.DataValue{String},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}}) at /Users/claireh/.julia/v0.6/IndexedTables/src/join.jl:812
_merge(::JuliaDB.##76#77, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Union{}},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}}, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},DataValues.DataValue{String},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}}) at /Users/claireh/.julia/v0.6/JuliaDB/src/table.jl:256
_merge(::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Union{}},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}}, ::IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},DataValues.DataValue{String},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}}) at /Users/claireh/.julia/v0.6/JuliaDB/src/table.jl:265
do_task(::Dagger.Context, ::Dagger.OSProc, ::Int64, ::Function, ::Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Union{}},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},DataValues.DataValue{String},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef}}, ::Bool, ::Bool, ::Bool) at /Users/claireh/.julia/v0.6/Dagger/src/compute.jl:319
(::Base.Distributed.##135#136{Dagger.#do_task,Tuple{Dagger.Context,Dagger.OSProc,Int64,JuliaDB.#_merge,Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Union{}},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},DataValues.DataValue{String},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef}},Bool,Bool,Bool},Array{Any,1}})() at ./distributed/remotecall.jl:314
run_work_thunk(::Base.Distributed.##135#136{Dagger.#do_task,Tuple{Dagger.Context,Dagger.OSProc,Int64,JuliaDB.#_merge,Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Union{}},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},DataValues.DataValue{String},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef}},Bool,Bool,Bool},Array{Any,1}}, ::Bool) at ./distributed/process_messages.jl:56
#remotecall_fetch#140(::Array{Any,1}, ::Function, ::Function, ::Base.Distributed.LocalProcess, ::Dagger.Context, ::Vararg{Any,N} where N) at ./distributed/remotecall.jl:339
remotecall_fetch(::Function, ::Base.Distributed.LocalProcess, ::Dagger.Context, ::Vararg{Any,N} where N) at ./distributed/remotecall.jl:339
#remotecall_fetch#144(::Array{Any,1}, ::Function, ::Function, ::Int64, ::Dagger.Context, ::Vararg{Any,N} where N) at ./distributed/remotecall.jl:367
macro expansion at /Users/claireh/.julia/v0.6/Dagger/src/compute.jl:332 [inlined]
(::Dagger.##69#70{Dagger.Context,Dagger.OSProc,Int64,JuliaDB.#_merge,Tuple{Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Union{}},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{Union{}},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Union{},1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Union{},1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef},Dagger.Chunk{IndexedTables.NextTable{IndexedTables.Columns{NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{String,String,String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},String,String,String,String,Float64,Float64,DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},DataValues.DataValue{Float64},String,DataValues.DataValue{Int64},DataValues.DataValue{Int64},Int64,String,DataValues.DataValue{Int64},String,String,String,String,String,String,String,String,String,DataValues.DataValue{String},DataValues.DataValue{String},String,String,String},NamedTuples._NT_species_phylum_class_order_family_genus_scientificname_gbifid_datasetkey_occurrenceid_kingdom_infraspecificepithet_taxonrank_countrycode_locality_publishingorgkey_decimallatitude_decimallongitude_coordinateuncertaintyinmeters_coordinateprecision_elevation_elevationaccuracy_depth_depthaccuracy_eventdate_day_month_year_taxonkey_specieskey_basisofrecord_institutioncode_collectioncode_catalognumber_recordnumber_identifiedby_license_rightsholder_recordedby_typestatus_establishmentmeans_lastinterpreted_mediatype_issue{PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{Float64,1},Array{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},DataValues.DataValueArray{Float64,1},Array{String,1},DataValues.DataValueArray{Int64,1},DataValues.DataValueArray{Int64,1},Array{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},DataValues.DataValueArray{Int64,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},PooledArrays.PooledArray{String,UInt16,1,Array{UInt16,1}},Array{String,1},Array{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},Array{String,1},DataValues.DataValueArray{String,1},DataValues.DataValueArray{String,1},Array{String,1},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}},PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}}}},MemPool.DRef}},Channel{Any},Bool,Bool,Bool})() at ./event.jl:73
shashi commented 6 years ago

It's surprising that you have a DataValue{String} field in your data. Is this table the result of a join?

claireh93 commented 6 years ago

No the table is just a result of several csv files loaded and saved through Dagger - and it is strange that it says I have a DataValue{String} because there isn't one in the table anywhere!

Distributed Table with 48862802 rows in 8 chunks:
Columns:
#   colname                        type
────────────────────────────────────────────────────────────────
1   phylum                         String
2   class                          String
3   order                          String
4   family                         String
5   genus                          String
6   species                        String
7   scientificname                 String
8   gbifid                         String
9   datasetkey                     String
10  occurrenceid                   String
11  kingdom                        String
12  infraspecificepithet           String
13  taxonrank                      String
14  countrycode                    String
15  locality                       String
16  publishingorgkey               String
17  decimallatitude                Float64
18  decimallongitude               Float64
19  coordinateuncertaintyinmeters  DataValues.DataValue{Float64}
20  coordinateprecision            DataValues.DataValue{Float64}
21  elevation                      DataValues.DataValue{Float64}
22  elevationaccuracy              DataValues.DataValue{Float64}
23  depth                          DataValues.DataValue{Float64}
24  depthaccuracy                  DataValues.DataValue{Float64}
25  eventdate                      String
26  day                            DataValues.DataValue{Int64}
27  month                          DataValues.DataValue{Int64}
28  year                           Int64
29  taxonkey                       String
30  specieskey                     DataValues.DataValue{Int64}
31  basisofrecord                  String
32  institutioncode                String
33  collectioncode                 String
34  catalognumber                  String
35  recordnumber                   String
36  identifiedby                   String
37  license                        String
38  rightsholder                   String
39  recordedby                     String
40  typestatus                     String
41  establishmentmeans             String
42  lastinterpreted                String
43  mediatype                      String
44  issue                          String
claireh93 commented 6 years ago

Hi @shashi , I wondered whether the error might be caused by missing values in my :species String column and so I tried filtering out these, but I still come up with the same error. Similarly for if I try it on columns where I am sure the data is complete. I'm not sure if they are cross-compatible but I could post up the dagger chunks if that would help? Many thanks.

richardreeve commented 6 years ago

@shashi Any further thoughts on what might be going on here? Is one of the columns being converted from String to DataValue{String} unintentionally? If so is there anything that can be done to fix it? If not, is there any further debugging @claireh93 can do to help identify what's going wrong?

shashi commented 6 years ago

I figured out how it's possible to end up with DataValue{String}, and we need special handling for the specific case of when it's also a DataValueArray{String, <:PooledArray}. I'll fix this in the next couple of days. Sorry for the hold up, appreciate your patience!

richardreeve commented 6 years ago

@shashi bump.

shashi commented 6 years ago
julia> x=PooledArray(["x"])
1-element PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}:
 "x"

julia> y=DataValueArray(["x"])
1-element DataValues.DataValueArray{String,1}:
 "x"

julia> vcat(x,y)
ERROR: MethodError: similar(::PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}, ::Type{DataValues.DataValue{String}}, ::Tuple{Int64}) is ambiguous. Candidates:
  similar(x::AbstractArray, ::Type{DataValues.DataValue{T}}, dims::Tuple{Vararg{Int64,N}} where N) where T in DataValues at /home/shashi/.julia/v0.6/DataValues/src/array/primitives.jl:13
  similar(pa::PooledArrays.PooledArray{T,R,N,RA} where RA where N, S::Type, dims::Tuple{Vararg{Int64,N}} where N) where {T, R} in PooledArrays at /home/shashi/.julia/v0.6/PooledArrays/src/PooledArrays.jl:148
Possible fix, define
  similar(::PooledArrays.PooledArray{T,R,N,RA} where RA where N, ::Type{DataValues.DataValue{T}}, ::Tuple{Vararg{Int64,N}} where N)
Stacktrace:
 [1] typed_vcat(::Type{DataValues.DataValue{String}}, ::PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}, ::DataValues.DataValueArray{String,1}) at ./abstractarray.jl:1084
 [2] vcat(::PooledArrays.PooledArray{String,UInt8,1,Array{UInt8,1}}, ::DataValues.DataValueArray{String,1}) at ./abstractarray.jl:1076
 [3] macro expansion at /home/shashi/.julia/v0.6/Revise/src/Revise.jl:775 [inlined]
 [4] (::Revise.##17#18{Base.REPL.REPLBackend})() at ./event.jl:73

@davidanthoff do you have any thoughts on how to handle this?

shashi commented 6 years ago

Do let me know if the other branch fixes this issue.

shashi commented 6 years ago

An unrelated tip is try to use groupreduce where possible. Since groupby requires all data for the group at the same place at the same time, it will trigger a "reshuffle" of all the data, however groupreduce will apply a pairwise function that is assumed to be commutative, like + in parallel and then combine much smaller results. If you want to do stats such as Mean and Std, use OnlineStats instead of a reduction function.

claireh93 commented 6 years ago

Thanks, groupreduce is useful and does seem to work- we will certainly use it! However, we also have quite a few cases where we will need groupby for our data.

shashi commented 6 years ago

You can optimize groupby by rechunking the table by the grouped columns first. This will bring rows for the same group to the same process.

claireh93 commented 6 years ago

Sorry for the delay @shashi! I'm just bringing this on here as #175 is now closed. I have tried loading in the csv files again and unfortunately I still get the same deserialisation error.