net.sf.farrago.query
Class FarragoTransformDef

java.lang.Object
  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