Skip to content

Commit

Permalink
minor clean up and additional tests
Browse files Browse the repository at this point in the history
  • Loading branch information
cwensel committed Sep 20, 2023
1 parent 3f4d419 commit 04d98d0
Show file tree
Hide file tree
Showing 6 changed files with 15 additions and 41 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -8,34 +8,16 @@

package io.clusterless.tessellate.parser.ast;

import java.util.Objects;

public class FieldName implements FieldRef {
String name;

public FieldName(CharSequence name) {
this.name = name.toString();
}

@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
FieldName fieldName = (FieldName) o;
return Objects.equals(name, fieldName.name);
}

@Override
public int hashCode() {
return Objects.hash(name);
}

@Override
public String toString() {
final StringBuilder sb = new StringBuilder("FieldName{");
sb.append("name='").append(name).append('\'');
sb.append('}');
return sb.toString();
return name;
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,6 @@ public Comparable<?> asComparable() {

@Override
public String toString() {
final StringBuilder sb = new StringBuilder("FieldOrdinal{");
sb.append("ordinal=").append(ordinal);
sb.append('}');
return sb.toString();
return ordinal.toString();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,6 @@

package io.clusterless.tessellate.parser.ast;

import java.util.Objects;

public class FieldTypeName {
String name;

Expand All @@ -21,19 +19,6 @@ public String name() {
return name;
}

@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
FieldTypeName fieldName = (FieldTypeName) o;
return Objects.equals(name, fieldName.name);
}

@Override
public int hashCode() {
return Objects.hash(name);
}

@Override
public String toString() {
return name;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,13 @@

package io.clusterless.tessellate.parser;

import io.clusterless.tessellate.parser.ast.Intrinsic;
import io.clusterless.tessellate.parser.ast.Operation;
import io.clusterless.tessellate.parser.ast.*;
import org.junit.jupiter.api.Test;

import java.util.List;
import java.util.Objects;
import java.util.Optional;

import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertNotNull;

Expand Down Expand Up @@ -50,6 +53,10 @@ void parse() {

@Test
void transforms() {
Field field = new Field(new FieldName("time_ymd"), Optional.of(new FieldType(new FieldTypeName("DateTime"), Optional.of(new FieldTypeParam("yyyyMMdd", Optional.empty())))));
List<Field> results = ((UnaryOperation) StatementParser.parse("time +> time_ymd|DateTime|yyyyMMdd")).results();
assertThat(results).hasSize(1).map(Objects::toString).contains(field.toString());

assertNotNull(StatementParser.parse("one"));
assertNotNull(StatementParser.parse("one|string"));
assertNotNull(StatementParser.parse("two->@two"));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@
import io.clusterless.tessellate.options.PipelineOptions;
import io.clusterless.tessellate.options.PipelineOptionsMerge;
import io.clusterless.tessellate.parser.ast.Assignment;
import io.clusterless.tessellate.parser.ast.UnaryOperation;
import io.clusterless.tessellate.util.JSONUtil;
import org.junit.jupiter.api.Test;

Expand Down Expand Up @@ -42,6 +43,7 @@ void usingOptions(@GivenTextResource("/config/pipeline-mvel.json") String pipeli
assertEquals(output, merged.sink().output());

assertEquals("1689820455", ((Assignment) merged.transform().statements().get(5)).literal());
assertEquals("_seven", ((UnaryOperation) merged.transform().statements().get(6)).results().get(0).fieldRef().asComparable());
}

@Test
Expand Down
3 changes: 2 additions & 1 deletion tessellate-main/src/test/resources/config/pipeline-mvel.json
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@
"three+>@three|DateTime|yyyyMMdd",
"four->",
"five=>_five",
"@{1689820455}=>six|DateTime|yyyyMMdd"
"@{1689820455}=>six|DateTime|yyyyMMdd",
"seven +> _seven|DateTime|yyyyMMdd"
]
}

0 comments on commit 04d98d0

Please sign in to comment.