@InterfaceAudience.Public @InterfaceStability.Evolving public interface IndexableLoadFunc
LoadFunc.getNext()called multiple times to retrieve data and perform the join
|Modifier and Type||Method and Description|
A method called by the Pig runtime to give an opportunity for implementations to perform cleanup actions like closing the underlying input stream.
This method is called by Pig run time to allow the IndexableLoadFunc to perform any initialization actions
This method is called by the Pig runtime to indicate to the LoadFunc to position its underlying input stream near the keys supplied as the argument.
void initialize(org.apache.hadoop.conf.Configuration conf) throws java.io.IOException
conf- The job configuration object
void seekNear(Tuple keys) throws java.io.IOException
keys- Tuple with join keys (which are a prefix of the sort keys of the input data). For example if the data is sorted on columns in position 2,4,5 any of the following Tuples are valid as an argument value: (fieldAt(2)) (fieldAt(2), fieldAt(4)) (fieldAt(2), fieldAt(4), fieldAt(5)) The following are some invalid cases: (fieldAt(4)) (fieldAt(2), fieldAt(5)) (fieldAt(4), fieldAt(5))
java.io.IOException- When the loadFunc is unable to position to the required point in its input stream
void close() throws java.io.IOException
java.io.IOException- if the loadfunc is unable to perform its close actions.
Copyright © 2007-2012 The Apache Software Foundation