org.apache.flink.table.codesplit

Class ReturnValueRewriter

java.lang.Object

org.apache.flink.table.codesplit.ReturnValueRewriter

All Implemented Interfaces:

CodeRewriter

@Internal
public class ReturnValueRewriter
extends Object
implements CodeRewriter

Rewrite functions with return values by splitting them into two functions and storing the return values into member variables.

Before

 public class Example {
     public int myFun(int a) {
         a += 1;
         return a;
     }
 }
 

<After

 public class Example {
     int myFunReturnValue$0;

     public int myFun(int a) {
         myFunImpl(a);
         return myFunReturnValue$0;
     }

     void myFunImpl(int a) {
         a += 1;
         {
             myFunReturnValue$0 = a;
             return;
         }
     }
 }
 

Constructor Summary

Constructors

Constructor and Description
ReturnValueRewriter(String code, int maxMethodLength)

Method Summary

Modifier and Type	Method and Description
String	rewrite()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReturnValueRewriter

public ReturnValueRewriter(String code,
                           int maxMethodLength)

Method Detail

rewrite

public String rewrite()

Specified by:

rewrite in interface CodeRewriter