Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions sql/core/src/main/java/org/apache/spark/sql/SaveMode.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,14 @@
*/
package org.apache.spark.sql;

import org.apache.spark.annotation.InterfaceStability;

/**
* SaveMode is used to specify the expected behavior of saving a DataFrame to a data source.
*
* @since 1.3.0
*/
@InterfaceStability.Stable
public enum SaveMode {
/**
* Append mode means that when saving a DataFrame to a data source, if data/table already exists,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I can't find FunctionRegistration anymore, so deleting this.

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1


/**
* A Spark SQL UDF that has 1 arguments.
*/
@InterfaceStability.Stable
public interface UDF1<T1, R> extends Serializable {
public R call(T1 t1) throws Exception;
R call(T1 t1) throws Exception;
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

methods in interface in Java are by default public.

}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 10 arguments.
*/
@InterfaceStability.Stable
public interface UDF10<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 11 arguments.
*/
@InterfaceStability.Stable
public interface UDF11<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 12 arguments.
*/
@InterfaceStability.Stable
public interface UDF12<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 13 arguments.
*/
@InterfaceStability.Stable
public interface UDF13<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 14 arguments.
*/
@InterfaceStability.Stable
public interface UDF14<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 15 arguments.
*/
@InterfaceStability.Stable
public interface UDF15<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 16 arguments.
*/
@InterfaceStability.Stable
public interface UDF16<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 17 arguments.
*/
@InterfaceStability.Stable
public interface UDF17<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 18 arguments.
*/
@InterfaceStability.Stable
public interface UDF18<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 19 arguments.
*/
@InterfaceStability.Stable
public interface UDF19<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 2 arguments.
*/
@InterfaceStability.Stable
public interface UDF2<T1, T2, R> extends Serializable {
public R call(T1 t1, T2 t2) throws Exception;
R call(T1 t1, T2 t2) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 20 arguments.
*/
@InterfaceStability.Stable
public interface UDF20<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19, T20 t20) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19, T20 t20) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 21 arguments.
*/
@InterfaceStability.Stable
public interface UDF21<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19, T20 t20, T21 t21) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19, T20 t20, T21 t21) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 22 arguments.
*/
@InterfaceStability.Stable
public interface UDF22<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19, T20 t20, T21 t21, T22 t22) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9, T10 t10, T11 t11, T12 t12, T13 t13, T14 t14, T15 t15, T16 t16, T17 t17, T18 t18, T19 t19, T20 t20, T21 t21, T22 t22) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 3 arguments.
*/
@InterfaceStability.Stable
public interface UDF3<T1, T2, T3, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3) throws Exception;
R call(T1 t1, T2 t2, T3 t3) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 4 arguments.
*/
@InterfaceStability.Stable
public interface UDF4<T1, T2, T3, T4, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 5 arguments.
*/
@InterfaceStability.Stable
public interface UDF5<T1, T2, T3, T4, T5, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 6 arguments.
*/
@InterfaceStability.Stable
public interface UDF6<T1, T2, T3, T4, T5, T6, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 7 arguments.
*/
@InterfaceStability.Stable
public interface UDF7<T1, T2, T3, T4, T5, T6, T7, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7) throws Exception;
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,12 @@

import java.io.Serializable;

// **************************************************
// THIS FILE IS AUTOGENERATED BY CODE IN
// org.apache.spark.sql.api.java.FunctionRegistration
// **************************************************
import org.apache.spark.annotation.InterfaceStability;

/**
* A Spark SQL UDF that has 8 arguments.
*/
@InterfaceStability.Stable
public interface UDF8<T1, T2, T3, T4, T5, T6, T7, T8, R> extends Serializable {
public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8) throws Exception;
R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8) throws Exception;
}
Loading