Skip to content

Commit 835e656

Browse files
committed
Merge branch 'feat/scala_mode' into spark_35
2 parents 9ea7ed8 + 7ba3a6e commit 835e656

1 file changed

Lines changed: 22 additions & 0 deletions

File tree

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package com.atgenomix.seqslab.piper.plugin.api.executor;
2+
3+
import com.atgenomix.seqslab.piper.tags.DeveloperApi;
4+
import com.atgenomix.seqslab.piper.tags.FeatureAfterCall;
5+
import com.atgenomix.seqslab.piper.tags.FeatureBeforeCall;
6+
import org.apache.spark.sql.Dataset;
7+
import org.apache.spark.sql.Row;
8+
import org.apache.spark.sql.api.java.UDF1;
9+
10+
/**
11+
* A mix-in interface for {@link Executor}. Executors can implement this interface to support DataFrame preprocessing
12+
* for Scala command execution.
13+
*
14+
* Executors implementing this mix-in interface is a user-defined function (UDF) that takes a DataFrame as an input
15+
* parameter and returns a new DataFrame.
16+
* This feature is invoked before and after applying Executor's call function.
17+
*/
18+
@DeveloperApi
19+
@FeatureBeforeCall
20+
@FeatureAfterCall
21+
public interface SupportsScalaLocalization extends Executor, UDF1<Dataset<Row>, Dataset<Row>> {
22+
}

0 commit comments

Comments
 (0)