net.sf.farrago.query
Class FarragoTransformDef

java.lang.Object
  extended by net.sf.farrago.query.FarragoTransformDef

public class FarragoTransformDef
extends Object

Defines a FarragoTransform, the java peer of a fennel::JavaTransformExecStream. A FarragoTransformDef is constructed by a FarragoRelImplementor and then handed off to a FarragoExecutableJavaStmt, which instantiates the FarragoTransform.

Author:
Marc Berkowitz

Field Summary
private  String className
           
private  FarragoTransform.InputBinding[] inputBindings
           
private  Class objectCode
           
private  RelNode relNode
           
private  ClassDeclaration sourceCode
           
private  String streamName
           
private static Logger tracer
           
 
Constructor Summary
FarragoTransformDef(RelNode relNode, ClassDeclaration sourceCode)
           
 
Method Summary
private  void bindInputs(FarragoRuntimeContext conn)
           
(package private)  void compile(FarragoPreparingStmt stmt, String pkgName)
           
(package private)  void disconnectFromImplementor()
           
 String getClassName()
           
 String getStreamName()
           
 void init(FarragoSessionRuntimeContext fsrc)
           
(package private)  void setStreamName(String s)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

tracer

private static final Logger tracer

relNode

private RelNode relNode

sourceCode

private ClassDeclaration sourceCode

objectCode

private Class objectCode

className

private String className

streamName

private String streamName

inputBindings

private FarragoTransform.InputBinding[] inputBindings
Constructor Detail

FarragoTransformDef

FarragoTransformDef(RelNode relNode,
                    ClassDeclaration sourceCode)
Method Detail

toString

public String toString()
Overrides:
toString in class Object

setStreamName

void setStreamName(String s)

getClassName

public String getClassName()

getStreamName

public String getStreamName()

disconnectFromImplementor

void disconnectFromImplementor()

compile

void compile(FarragoPreparingStmt stmt,
             String pkgName)

bindInputs

private void bindInputs(FarragoRuntimeContext conn)

init

public void init(FarragoSessionRuntimeContext fsrc)
          throws Error
Throws:
Error