mraad

package com.esri;

import cascading.flow.Flow;
import cascading.flow.FlowConnector;
import cascading.flow.hadoop.HadoopFlowConnector;
import cascading.operation.aggregator.Count;
import cascading.pipe.Each;
import cascading.pipe.Every;
import cascading.pipe.GroupBy;
import cascading.pipe.Pipe;

mraad

import arcpy


class Toolbox(object):
    def __init__(self):
        self.label = "TSV Toolbox"
        self.alias = "TSV Toolbox"
        self.tools = [TSVTool]

mraad

$(document).ready(function () {
    'use strict';
    var mapServerInfo;
    document.getElementById('buttonLocate').addEventListener('click', function (e) {
        e.preventDefault();
        var level = $('#inputLevel').val(),
            row = $('#inputRow').val(),
            col = $('#inputCol').val();
        console.log(level, row, col);
        /*

mraad

@Override
protected void map(
        final LongWritable key,
        final Text value,
        final Context context) throws IOException, InterruptedException
{
    final String[] tokens = value.toString().split("\t");
    if (tokens.length != 4)
    {
        return;

mraad

@Override
protected void reduce(
        final Text key,
        final Iterable<DoubleWritable> values,
        final Context context) throws IOException, InterruptedException
{
    double sum = 0.0;
    for (final DoubleWritable doubleWritable : values)
    {
        sum += doubleWritable.get();

mraad

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:hdp="http://www.springframework.org/schema/hadoop"
       xsi:schemaLocation="
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/hadoop http://www.springframework.org/schema/hadoop/spring-hadoop.xsd">

    <hdp:configuration id="hadoopConfiguration">
        fs.defaultFS=hdfs://10.12.51.70:8020

mraad

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:hdp="http://www.springframework.org/schema/hadoop"
       xsi:schemaLocation="
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/hadoop http://www.springframework.org/schema/hadoop/spring-hadoop.xsd">

    <hdp:configuration id="hadoopConfiguration">
        fs.defaultFS=hdfs://10.12.51.70:8020

mraad

    <hdp:job id="mr-job"
             jar-by-class="com.esri.density.Main"
             input-path="/user/mraad_admin/infousa"
             output-path="/user/mraad_admin/raster"
             mapper="com.esri.density.CellFilterMapper"
             combiner="com.esri.density.CellReducer"
             reducer="com.esri.density.CellReducer"/>

mraad

public final class AppDistance
{
    public static void main(String[] args)
    {
        final boolean local = args.length == 0;

        final LogicalGraph graph = LogicalGraphFactory.newLogicalGraph("AppDistance");

        final TextRecord schema = SchemaBuilder.define(
                SchemaBuilder.DOUBLE("LON"),

mraad

public class App
{
    public static void main(String[] args) throws IOException
    {
        if (args.length != 4)
        {
            System.err.println("Usage: " + App.class + " workflow.dr workflow.properties num-parallelism local|dr://dr-host:1099");
            return;
        }