Skip to content

Commit

Permalink
handled todos, re-added missing final in transaction
Browse files Browse the repository at this point in the history
  • Loading branch information
datomo committed Apr 19, 2024
1 parent 78057b5 commit 50dda39
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1068,8 +1068,6 @@ private PreparedResult<PolyValue> implement( AlgRoot root, AlgDataType parameter
}

final AlgDataType jdbcType = QueryProcessorHelpers.makeStruct( root.alg.getCluster().getTypeFactory(), root.validatedRowType );
//TODO DL: get metadata instead of null
List<List<String>> fieldOrigins = Collections.nCopies( jdbcType.getFieldCount(), null );

final Prefer prefer = Prefer.ARRAY;
final Convention resultConvention =
Expand Down Expand Up @@ -1115,7 +1113,7 @@ private PreparedResult<PolyValue> implement( AlgRoot root, AlgDataType parameter
return new PreparedResultImpl<>(
resultType,
parameterRowType,
fieldOrigins,
Collections.nCopies( jdbcType.getFieldCount(), null ), // we do not have the origin of the fields so we provide null for all
root.collation.getFieldCollations().isEmpty()
? ImmutableList.of()
: ImmutableList.of( root.collation ),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,6 @@ public void close() {
dataContext.getParameterValues().clear();
}
fileInputHandles.forEach( FileInputHandle::close );
// dataContext = null; todo dl check how we want to handle this long term
}


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ public class TransactionImpl implements Transaction, Comparable<Object> {
private final PolyXid xid;

@Getter
private AtomicBoolean cancelFlag = new AtomicBoolean();
private final AtomicBoolean cancelFlag = new AtomicBoolean();

@Getter
private final LogicalUser user;
Expand Down

0 comments on commit 50dda39

Please sign in to comment.