code: public P get(final Map<String, Object> query, final PipelineContext context) {
          final A item = source.get(acquiredType, query, context);
  
          if(item == null) {
              return null;
          }
  
          for(final SinkHandler<A, ?> sink : preTransform) {
              sink.put(item, context);
          }
  
          final P converted = transform.transform(item, context);
  
          for(final SinkHandler<P, ?> sink : postTransform) {
              sink.put(converted, context);
          }
  
          return converted;
      }
docs: Gets data from the underlying {@link com.merakianalytics.datapipelines.sources.DataSource}, provides it to the appropriate
  {@link com.merakianalytics.datapipelines.SinkHandler}s, converts it and returns it
  
  @param query
  a query specifying the details of what data should fulfill this request
  @param context
  information about the context of the request such as what {@link com.merakianalytics.datapipelines.DataPipeline} called this method
  @return the requested data