[jira] Updated: (PIG-1141) Make streaming work with the new load-store interfaces

2010-03-24 Thread Alan Gates (JIRA)

 [ 
https://issues.apache.org/jira/browse/PIG-1141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Alan Gates updated PIG-1141:


Fix Version/s: 0.7.0

 Make streaming work with the new load-store interfaces 
 ---

 Key: PIG-1141
 URL: https://issues.apache.org/jira/browse/PIG-1141
 Project: Pig
  Issue Type: Sub-task
Reporter: Richard Ding
Assignee: Richard Ding
 Fix For: 0.7.0

 Attachments: PIG-1141.patch, PIG-1141.patch, PIG-1141.patch




-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.



[jira] Updated: (PIG-1141) Make streaming work with the new load-store interfaces

2009-12-21 Thread Richard Ding (JIRA)

 [ 
https://issues.apache.org/jira/browse/PIG-1141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Richard Ding updated PIG-1141:
--

Attachment: PIG-1141.patch

This patch made changes following Alan's comments.

 Make streaming work with the new load-store interfaces 
 ---

 Key: PIG-1141
 URL: https://issues.apache.org/jira/browse/PIG-1141
 Project: Pig
  Issue Type: Sub-task
Reporter: Richard Ding
Assignee: Richard Ding
 Attachments: PIG-1141.patch, PIG-1141.patch, PIG-1141.patch




-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.



[jira] Updated: (PIG-1141) Make streaming work with the new load-store interfaces

2009-12-17 Thread Richard Ding (JIRA)

 [ 
https://issues.apache.org/jira/browse/PIG-1141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Richard Ding updated PIG-1141:
--

Attachment: PIG-1141.patch

This patch also removes BinaryStorage and StreamOptimizer from the source (in 
the branch).

Here is the result of locally run 'commit-patch':

{code}
[exec] -1 overall.  
 [exec] 
 [exec] +1 @author.  The patch does not contain any @author tags.
 [exec] 
 [exec] +1 tests included.  The patch appears to include 32 new or 
modified tests.
 [exec] 
 [exec] +1 javadoc.  The javadoc tool did not generate any warning 
messages.
 [exec] 
 [exec] +1 javac.  The applied patch does not increase the total number 
of javac compiler warnings.
 [exec] 
 [exec] +1 findbugs.  The patch does not introduce any new Findbugs 
warnings.
 [exec] 
 [exec] -1 release audit.  The applied patch generated 433 release 
audit warnings (more than the trunk's current 430 warnings).
{code}

The release audit warnings are all 'html' related.

 Make streaming work with the new load-store interfaces 
 ---

 Key: PIG-1141
 URL: https://issues.apache.org/jira/browse/PIG-1141
 Project: Pig
  Issue Type: Sub-task
Reporter: Richard Ding
Assignee: Richard Ding
 Attachments: PIG-1141.patch, PIG-1141.patch




-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.



[jira] Updated: (PIG-1141) Make streaming work with the new load-store interfaces

2009-12-16 Thread Richard Ding (JIRA)

 [ 
https://issues.apache.org/jira/browse/PIG-1141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Richard Ding updated PIG-1141:
--

Attachment: PIG-1141.patch

This patch implemented the proposed changes to streaming with the following 
modification:

* PigToStream interface:

{code}
package org.apache.pig.impl.streaming;

public interface PigToStream {

/**
 * Given a tuple, produce an array of bytes to be passed to the streaming
 * executable.
 */
public byte[] serialize(Tuple t) throws IOException;

}
{code}

* StreamToPig interface:

{code}
package org.apache.pig.impl.streaming;

public interface StreamToPig {
/**
 *  Given a byte array from a streaming executable, produce a tuple.
 */
public Tuple deserialize(byte[] bytes) throws IOException;

/**
 * This will be called on the front end during planning and not on the back 
 * end during execution.
 * 
 * @return the {...@link LoadCaster} associated with this object. 
 * @throws IOException if there is an exception during LoadCaster 
 */
public LoadCaster getLoadCaster() throws IOException;

}

{code}

* The class that provides the default implementation of these interfaces: 

{code}

org.apache.pig.impl.streaming.PigStreaming

{code} 


 Make streaming work with the new load-store interfaces 
 ---

 Key: PIG-1141
 URL: https://issues.apache.org/jira/browse/PIG-1141
 Project: Pig
  Issue Type: Sub-task
Reporter: Richard Ding
Assignee: Richard Ding
 Attachments: PIG-1141.patch




-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.