MCPcopy Create free account
hub / github.com/apache/pig / load

Method load

src/org/apache/pig/impl/io/PigFile.java:57–66  ·  view source on GitHub ↗
(LoadFunc lfunc, PigContext pigContext)

Source from the content-addressed store, hash-verified

55 }
56
57 public DataBag load(LoadFunc lfunc, PigContext pigContext) throws IOException {
58 DataBag content = BagFactory.getInstance().newDefaultBag();
59 ReadToEndLoader loader = new ReadToEndLoader(lfunc,
60 ConfigurationUtil.toConfiguration(pigContext.getProperties()), file, 0);
61 Tuple f = null;
62 while ((f = loader.getNext()) != null) {
63 content.add(f);
64 }
65 return content;
66 }
67
68
69 public void store(DataBag data, FuncSpec storeFuncSpec, PigContext pigContext) throws IOException {

Callers 7

runMethod · 0.45
log4jConfAsPropertiesMethod · 0.45
selectExecTypeMethod · 0.45
getTezVersionMethod · 0.45
pigudf.rbFile · 0.45

Calls 6

getInstanceMethod · 0.95
toConfigurationMethod · 0.95
getNextMethod · 0.95
addMethod · 0.95
newDefaultBagMethod · 0.45
getPropertiesMethod · 0.45

Tested by

no test coverage detected