Flow flow = context.getFlow();
flow.getSink().getSinkFields();
PlannerPlatformBroker platformBroker = new PlannerPlatformBroker();
LingualContext lingualContext = new LingualContext( this, flow, platformBroker );
OptiqPrepareImpl prepare = new OptiqPrepareImpl();
prepare.prepareSql( lingualContext, getSql(), null, Object[].class, -1 );
Pipe current = platformBroker.getTail();
String name;
if( getTailName() != null )
name = getTailName();