[MINOR] Move java file to java directory

[ConeyLiu]

What changes were proposed in this pull request?

move

org.apache.spark.sql.execution.streaming.BaseStreamingSource
org.apache.spark.sql.execution.streaming.BaseStreamingSink

to java directory

How was this patch tested?

Existing UT.

[ConeyLiu]

Hi @srowen, can you help to review. Thanks a lot.

[srowen]

I agree with moving the code, but why change the package?

[srowen]

Offset.java can be moved too?

[dongjoon-hyun]

+1 for @srowen 's comment. We should keep the package name.

[dongjoon-hyun]

ok to test

[SparkQA]

Test build #103982 has finished for PR 24222 at commit 5ae78b4.

• This patch passes all tests.
• This patch merges cleanly.
• This patch adds no public classes.

[ConeyLiu]

thanks @srowen@dongjoon-hyun for the review. I am referring to @cloud-fan 's point of view.
shall we move these new interfaces to org.apache.spark.sql.sources.v2.reader/write.streaming package?

Offset.java can be moved too?

Will move it later.

[cloud-fan]

These 2 interfaces are internal and I don't think we can move them to a public package now.

[ConeyLiu]

thanks @cloud-fan, just move those files to java directory.
Hi @srowen, Offset.java already under java directory.

[SparkQA]

Test build #104038 has finished for PR 24222 at commit d893909.

• This patch fails due to an unknown error code, -9.
• This patch merges cleanly.
• This patch adds no public classes.

[srowen]

I'm looking at sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/Offset.java -- seems like that should move too?

[ConeyLiu]

thanks @srowen for point out it. I have moved it too.

[attilapiros]

LGTM

I have not found any other '*.java" file under scala directories which can be moved.
I used the following search:

$ find . -name "scala" -exec find \{} -name "*.java" \; | grep -v package-info
./mllib/src/main/scala/org/apache/spark/mllib/JavaPackage.java
./sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/BaseStreamingSink.java
./sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/BaseStreamingSource.java
./sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/Offset.java

JavaPackage.java must be kept in its current place as:

/**
* A dummy class as a workaround to show the package doc of <code>spark.mllib</code> in generated
* Java API docs.
* @see <a href="http://bugs.java.com/bugdatabase/view_bug.do?bug_id=4492654" target="_blank">
* JDK-4492654</a>
*/

[srowen]

LG pending tests

[SparkQA]

Test build #104047 has finished for PR 24222 at commit 0b69d45.

• This patch passes all tests.
• This patch merges cleanly.
• This patch adds no public classes.

[srowen]

Merged to master

[ConeyLiu]

thanks everyone.