datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionPreservingExecutionPlanner.java [212:227]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private void determineInputSchemas() throws IOException
  {
    if (_latestInputByPath.size() > 0)
    {
      _log.info("Determining input schemas");
      for (Entry<String,String> entry : _latestInputByPath.entrySet())
      {
        String root = entry.getKey();
        String input = entry.getValue();
        _log.info("Loading schema for " + input);
        Schema schema = PathUtils.getSchemaFromPath(getFileSystem(),new Path(input));
        _inputSchemas.add(schema);
        _inputSchemasByPath.put(root, schema);
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



datafu-hourglass/src/main/java/datafu/hourglass/jobs/PartitionCollapsingExecutionPlanner.java [138:153]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void determineInputSchemas() throws IOException
    {
      if (_latestInputByPath.size() > 0)
      {
        _log.info("Determining input schemas");
        for (Entry<String,String> entry : _latestInputByPath.entrySet())
        {
          String root = entry.getKey();
          String input = entry.getValue();
          _log.info("Loading schema for " + input);
          Schema schema = PathUtils.getSchemaFromPath(getFileSystem(),new Path(input));
          _inputSchemas.add(schema);
          _inputSchemasByPath.put(root, schema);
        }
      }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -