Hi, we've created simple utility project for testing pig scripts.
We the core we do:
def pigServer = new PigServer(ExecType.LOCAL)
pigServer.setBatchOn()
try
{
pigServer.registerScript(new
FileInputStream(scriptFile.absolutePath), params, null)
pigServer.dumpSchema("routeElementPairs")
for (ExecJob job : pigServer.executeBatch())
{
while (!job.hasCompleted())
{
TimeUnit.SECONDS.sleep(1)
}
if (job.status != ExecJob.JOB_STATUS.COMPLETED)
{
return PigExecutionResult.failed()
}
}
}
The problem is that server ignores RESCRIBE statement.
We see that PigServer instance have a method:
pigServer.dumpSchema("alias")
so It can dump schema. Is there any possibility to force PigServer in Local
mode dump shema?
