Dear Wiki user,

You have subscribed to a wiki page or wiki category on "Pig Wiki" for change 
notification.

The following page has been changed by OlgaN:
http://wiki.apache.org/pig/PigStreamingFunctionalSpec

------------------------------------------------------------------------------
  Given the definition above, the stream command will look as follows:
  
  {{{
- <stream command>::= <alias> = stream <alias> through <streaming spec> 
[<schema spec>]
+ <stream command>::= <alias>{,<alias>} = stream <alias>{,<alais>} through 
<streaming spec> [<schema spec>]
  <streaming spec>::= <alias> | <UDF spec> | <command>
  <schema spec>:: standard pig schema spec like as (x,yz)
  }}}
  
  Within stream operator, If streaming specification is enclosed in backticks, 
it is assumed to be a streaming command specified inline. Otherwise, the string 
is looked up in the alias hash and if found assumed to be an alias. Otherwise, 
an error is reported.
+ 
+ Note that left hand side of the streaming command allows multiple aliases. 
This is needed for the case of streaming creating multiple outputs and will not 
be supported in the initial implementation. Also note that both define and 
stream operators refer to UDF specs. This is to accomodate streaming UDFs and 
will not be supported in the initial release.
  
  {{{
  A = load 'data';

Reply via email to