diff options
| author | Lester Solbakken <lesters@yahoo-inc.com> | 2017-03-17 12:29:41 +0100 |
|---|---|---|
| committer | Lester Solbakken <lesters@yahoo-inc.com> | 2017-03-17 12:29:41 +0100 |
| commit | ef775d57f273a69f0de2cd52518cbd9260e55eac (patch) | |
| tree | 5b89780e05f24c70b0158968fda5225822df9933 /vespa-hadoop/src/test/pig/feed_operations_with_json_loader.pig | |
| parent | b09d7deb64e5a723c5a052dd2b1db225f632405f (diff) | |
Renamce hadoop -> vespa-hadoop
Diffstat (limited to 'vespa-hadoop/src/test/pig/feed_operations_with_json_loader.pig')
| -rw-r--r-- | vespa-hadoop/src/test/pig/feed_operations_with_json_loader.pig | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/vespa-hadoop/src/test/pig/feed_operations_with_json_loader.pig b/vespa-hadoop/src/test/pig/feed_operations_with_json_loader.pig new file mode 100644 index 00000000000..6d31201e4eb --- /dev/null +++ b/vespa-hadoop/src/test/pig/feed_operations_with_json_loader.pig @@ -0,0 +1,13 @@ +-- REGISTER vespa-hadoop.jar -- Not needed in tests + +-- Define short name for VespaJsonLoader +DEFINE VespaJsonLoader com.yahoo.vespa.hadoop.pig.VespaSimpleJsonLoader(); + +-- Define short name for VespaStorage +DEFINE VespaStorage com.yahoo.vespa.hadoop.pig.VespaStorage(); + +-- Load data - one column for json data +metrics = LOAD 'src/test/resources/operations_data.json' USING VespaJsonLoader() AS (data:chararray); + +-- Store into Vespa +STORE metrics INTO '$ENDPOINT' USING VespaStorage();
\ No newline at end of file |