Skip to content

Commit

Permalink
Merge pull request #1261 from David-C-L/deltalake-scripting-updates
Browse files Browse the repository at this point in the history
Delta Lake/Scripting changes: run mvn spotless
  • Loading branch information
ghislainfourny authored Sep 23, 2024
2 parents 7ee88c3 + 4fc8cc6 commit 3520ad7
Show file tree
Hide file tree
Showing 4 changed files with 24 additions and 23 deletions.
1 change: 0 additions & 1 deletion src/main/java/org/rumbledb/api/Rumble.java
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
import org.rumbledb.context.DynamicContext;
import org.rumbledb.expressions.module.MainModule;
import org.rumbledb.runtime.RuntimeIterator;
import org.rumbledb.runtime.update.PendingUpdateList;
import sparksoniq.spark.SparkSessionManager;

import java.io.IOException;
Expand Down
1 change: 0 additions & 1 deletion src/main/java/org/rumbledb/cli/JsoniqQueryExecutor.java
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,6 @@
import org.rumbledb.optimizations.Profiler;
import org.rumbledb.runtime.functions.input.FileSystemUtil;

import org.rumbledb.runtime.update.PendingUpdateList;
import sparksoniq.spark.SparkSessionManager;
import java.io.IOException;
import java.net.URI;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,10 @@ public ExpressionClassification visitCommaExpression(
// Region Typing

@Override
public ExpressionClassification visitTreatExpression(TreatExpression expression, ExpressionClassification argument) {
public ExpressionClassification visitTreatExpression(
TreatExpression expression,
ExpressionClassification argument
) {
ExpressionClassification result = this.visit(expression.getMainExpression(), argument);
expression.setExpressionClassification(result);
return result;
Expand Down
40 changes: 20 additions & 20 deletions src/test/java/iq/RuntimeTests.java
Original file line number Diff line number Diff line change
Expand Up @@ -62,28 +62,28 @@ public RuntimeTests(File testFile) {
public RumbleRuntimeConfiguration getConfiguration() {
return new RumbleRuntimeConfiguration(
new String[] {
"--print-iterator-tree",
"yes",
"--variable:externalUnparsedString",
"unparsed string",
"--apply-updates",
"yes" }
"--print-iterator-tree",
"yes",
"--variable:externalUnparsedString",
"unparsed string",
"--apply-updates",
"yes" }
).setExternalVariableValue(
Name.createVariableInNoNamespace("externalStringItem"),
Collections.singletonList(ItemFactory.getInstance().createStringItem("this is a string"))
Name.createVariableInNoNamespace("externalStringItem"),
Collections.singletonList(ItemFactory.getInstance().createStringItem("this is a string"))
)
.setExternalVariableValue(
Name.createVariableInNoNamespace("externalIntegerItems"),
Arrays.asList(
new Item[] {
ItemFactory.getInstance().createIntItem(1),
ItemFactory.getInstance().createIntItem(2),
ItemFactory.getInstance().createIntItem(3),
ItemFactory.getInstance().createIntItem(4),
ItemFactory.getInstance().createIntItem(5),
}
)
.setExternalVariableValue(
Name.createVariableInNoNamespace("externalIntegerItems"),
Arrays.asList(
new Item[] {
ItemFactory.getInstance().createIntItem(1),
ItemFactory.getInstance().createIntItem(2),
ItemFactory.getInstance().createIntItem(3),
ItemFactory.getInstance().createIntItem(4),
ItemFactory.getInstance().createIntItem(5),
}
)
);
);
}

public static void readFileList(File dir) {
Expand Down

0 comments on commit 3520ad7

Please sign in to comment.