Skip to content

Commit 2dc5864

Browse files
leonardBangleonardBang
committed
[lake] Unify lake related package name to lake
1 parent 756fff4 commit 2dc5864

File tree

45 files changed

+133
-133
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

45 files changed

+133
-133
lines changed

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/batch/ArrowRecordBatch.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/batch/ArrowRecordBatch.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.batch;
17+
package com.alibaba.fluss.lake.batch;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
2020

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/batch/RecordBatch.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/batch/RecordBatch.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.batch;
17+
package com.alibaba.fluss.lake.batch;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
2020

‎fluss-common/src/main/java/com/alibaba/fluss/lake/committer/CommitterInitContext.java‎

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
/*
2+
* Copyright (c) 2025 Alibaba Group Holding Ltd.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
package com.alibaba.fluss.lake.committer;
18+
19+
import com.alibaba.fluss.annotation.PublicEvolving;
20+
import com.alibaba.fluss.metadata.TablePath;
21+
22+
/**
23+
* The CommitterInitContext interface provides the context needed to create a LakeCommitter. It
24+
* includes methods to obtain the table path.
25+
*
26+
* @since 0.7
27+
*/
28+
@PublicEvolving
29+
public interface CommitterInitContext {
30+
31+
/**
32+
* Returns the table path.
33+
*
34+
* @return the table path
35+
*/
36+
TablePath tablePath();
37+
}

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/committer/LakeCommitter.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/committer/LakeCommitter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.committer;
17+
package com.alibaba.fluss.lake.committer;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
2020

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/lakestorage/LakeCatalog.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/lakestorage/LakeCatalog.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,20 @@
11
/*
2-
* Copyright (c) 2025 Alibaba Group Holding Ltd.
2+
* Copyright (c) 2025 Alibaba Group Holding Ltd.
33
*
4-
* Licensed under the Apache License, Version 2.0 (the "License");
5-
* you may not use this file except in compliance with the License.
6-
* You may obtain a copy of the License at
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
77
*
8-
* http://www.apache.org/licenses/LICENSE-2.0
8+
* http://www.apache.org/licenses/LICENSE-2.0
99
*
10-
* Unless required by applicable law or agreed to in writing, software
11-
* distributed under the License is distributed on an "AS IS" BASIS,
12-
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13-
* See the License for the specific language governing permissions and
14-
* limitations under the License.
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.lakestorage;
17+
package com.alibaba.fluss.lake.lakestorage;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
2020
import com.alibaba.fluss.exception.TableAlreadyExistException;

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/lakestorage/LakeStorage.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/lakestorage/LakeStorage.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,10 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.lakestorage;
17+
package com.alibaba.fluss.lake.lakestorage;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
20-
import com.alibaba.fluss.lakehouse.writer.LakeTieringFactory;
20+
import com.alibaba.fluss.lake.writer.LakeTieringFactory;
2121

2222
/**
2323
* The LakeStorage interface defines how to implement lakehouse storage system such as Paimon and

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/lakestorage/LakeStoragePlugin.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/lakestorage/LakeStoragePlugin.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.lakestorage;
17+
package com.alibaba.fluss.lake.lakestorage;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
2020
import com.alibaba.fluss.config.Configuration;

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/lakestorage/LakeStoragePluginSetUp.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/lakestorage/LakeStoragePluginSetUp.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,20 @@
11
/*
2-
* Copyright (c) 2025 Alibaba Group Holding Ltd.
2+
* Copyright (c) 2025 Alibaba Group Holding Ltd.
33
*
4-
* Licensed under the Apache License, Version 2.0 (the "License");
5-
* you may not use this file except in compliance with the License.
6-
* You may obtain a copy of the License at
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
77
*
8-
* http://www.apache.org/licenses/LICENSE-2.0
8+
* http://www.apache.org/licenses/LICENSE-2.0
99
*
10-
* Unless required by applicable law or agreed to in writing, software
11-
* distributed under the License is distributed on an "AS IS" BASIS,
12-
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13-
* See the License for the specific language governing permissions and
14-
* limitations under the License.
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.lakestorage;
17+
package com.alibaba.fluss.lake.lakestorage;
1818

1919
import com.alibaba.fluss.config.ConfigOptions;
2020
import com.alibaba.fluss.config.Configuration;

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/serializer/SimpleVersionedSerializer.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/serializer/SimpleVersionedSerializer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.serializer;
17+
package com.alibaba.fluss.lake.serializer;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
2020

fluss-common/src/main/java/com/alibaba/fluss/lakehouse/writer/LakeTieringFactory.java renamed to fluss-common/src/main/java/com/alibaba/fluss/lake/writer/LakeTieringFactory.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,12 +14,12 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.alibaba.fluss.lakehouse.writer;
17+
package com.alibaba.fluss.lake.writer;
1818

1919
import com.alibaba.fluss.annotation.PublicEvolving;
20-
import com.alibaba.fluss.lakehouse.committer.CommitterInitContext;
21-
import com.alibaba.fluss.lakehouse.committer.LakeCommitter;
22-
import com.alibaba.fluss.lakehouse.serializer.SimpleVersionedSerializer;
20+
import com.alibaba.fluss.lake.committer.CommitterInitContext;
21+
import com.alibaba.fluss.lake.committer.LakeCommitter;
22+
import com.alibaba.fluss.lake.serializer.SimpleVersionedSerializer;
2323

2424
import java.io.IOException;
2525
import java.io.Serializable;

0 commit comments

Comments
 (0)