谢谢你们的回答。它帮助我找到路。
最后，我所使用的jsonloader将出现问题。我不知道确切的原因，但是有一个带有空字符串的bug是很正常的。
我终于把代码改成了https://github.com/kevinweil/elephant-bird.
现在代码如下所示：

register 'elephant-bird-core-3.0.0.jar'
    register 'elephant-bird-pig-3.0.0.jar'
    register 'google-collections-1.0.jar'
    register 'json-simple-1.1.jar'

    json_lines = LOAD '/twitterecho/tweets/stream/v1/json/2012_10_10/08' USING com.twitter.elephantbird.pig.load.JsonLoader();

    geo_tweets = FOREACH json_lines GENERATE (CHARARRAY) $0#'id' AS id, (CHARARRAY) $0#'geoLocation' AS geoLocation;

    tweets_grp = GROUP geo_tweets BY id;
    unique_tweets = FOREACH tweets_grp {
          first_tweet = LIMIT inpt 1;
          GENERATE FLATTEN(first_tweet);
    };

    only_not_nulls = FILTER geo_tweets BY geoLocation is not null;
    store only_not_nulls into '/twitter_data/results/geo_tweets';

干杯

我也遇到过类似的问题，类似的事情对我很有用：

geoinfo_no_nulls = FILTER geoinfo BY geoLocation != '';

假设您希望地理位置是以经纬度为关键字的Map，则可以将数据作为Map加载，并按如下方式检查空值：

A = LOAD 'data' AS (f1:map[]);
B = FILTER A BY f1#longitude is not null and f1#latitude is not null;

不过，这只是一种变通办法。

试试这个： geoinfo_no_nulls = FILTER geoinfo BY (geomap#'geoLocation' is not null); 从错误中可以看出，它将类型识别为Map。您需要指定Map的特定键。如果这不起作用，您通常无法将该数据作为Map正确获取。请照弗雷德说的做。