Looking up of the zip code and preparing for the windowing operation
The NycTaxiZipFareExtractor operator is the operator that is immediate downstream of the NycTaxiCsvParser explained above. It looks at the pickup latitude-longitude coordinate, looks up the zip code given the latitude-longitude coordinate, and prepares a TimestampedTuple for the KeyedWindowedOperatorImpl operator downstream. The output tuple is of the TimestampedTuple<KeyValPair<String, Double>> type, with the key being the zip code, and the value being the total payment amount.
Here's the definition of the input port of the NycTaxiZipFareExtractor operator:
public final transient DefaultInputPort<Map<String, String>> input = new DefaultInputPort<Map<String, String>>()
{
@Override
public void process(Map<String, String> tuple)
{
try {
String zip =
NycLocationUtils.getZip(Double.valueOf(tuple.get("pickup_lat")),
Double.valueOf(tuple.get("pickup_lon...
