Refactor code to more functional style (#27)

trinitylake-io · Jan 24, 2025 · 720f9d4 · 720f9d4
1 parent a8ef90f
commit 720f9d4
Show file tree

Hide file tree

Showing 27 changed files with 915 additions and 556 deletions.
diff --git a/core/src/main/java/io/trinitylake/BasicLakehouse.java b/core/src/main/java/io/trinitylake/BasicLakehouse.java
diff --git a/core/src/main/java/io/trinitylake/BasicLakehouseVersion.java b/core/src/main/java/io/trinitylake/BasicLakehouseVersion.java
diff --git a/...va/io/trinitylake/TransactionContext.java → .../io/trinitylake/CommittedTransaction.java b/...va/io/trinitylake/TransactionContext.java → .../io/trinitylake/CommittedTransaction.java
@@ -13,17 +13,13 @@
  */
 package io.trinitylake;
 
-import java.util.Map;
+import io.trinitylake.tree.TreeNode;
 import org.immutables.value.Value;
 
 @Value.Immutable
-public interface TransactionContext {
+public interface CommittedTransaction {
 
   String transactionId();
 
-  LakehouseVersion version();
-
-  long startedAtMillis();
-
-  Map<String, String> options();
+  TreeNode committedRoot();
 }
diff --git a/...main/java/io/trinitylake/tree/Action.java → ...n/java/io/trinitylake/IsolationLevel.java b/...main/java/io/trinitylake/tree/Action.java → ...n/java/io/trinitylake/IsolationLevel.java
@@ -11,6 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.trinitylake.tree;
+package io.trinitylake;
 
-public interface Action {}
+public enum IsolationLevel {
+  SERIALIZABLE,
+  SNAPSHOT
+}
diff --git a/core/src/main/java/io/trinitylake/LakehouseVersion.java b/core/src/main/java/io/trinitylake/LakehouseVersion.java