mirror/xpipe
1
0
Fork 0
mirror of https://github.com/xpipe-io/xpipe.git synced 2026-04-24 08:31:39 -04:00
Code Issues Packages Projects Releases Wiki Activity

Rework data structure nodes, other rework

Browse Source
This commit is contained in:
Christopher Schnick
2022-09-04 04:11:01 +02:00
parent c7606f9f8e
commit 4d168b66c0
38 changed files with 408 additions and 762 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
api/src/main/java/io/xpipe/api/impl/DataTableImpl.java
View File

@@ -11,8 +11,10 @@ import io.xpipe.core.data.node.TupleNode;
import io.xpipe.core.data.typed.TypedAbstractReader;
import io.xpipe.core.data.typed.TypedDataStreamParser;
import io.xpipe.core.data.typed.TypedDataStructureNodeReader;
import io.xpipe.core.data.typed.TypedReusableDataStructureNodeReader;
import io.xpipe.core.source.*;
import io.xpipe.core.source.DataSourceId;
import io.xpipe.core.source.DataSourceInfo;
import io.xpipe.core.source.DataSourceReference;
import io.xpipe.core.source.DataSourceType;
import java.io.InputStream;
import java.util.*;
@@ -63,7 +65,7 @@ public class DataTableImpl extends DataSourceImpl implements DataTable {
.ref(DataSourceReference.id(getId())).maxRows(maxRows).build();
con.performInputExchange(req, (QueryTableDataExchange.Response res, InputStream in) -> {
var r = new TypedDataStreamParser(info.getDataType());
r.parseStructures(in, TypedDataStructureNodeReader.immutable(info.getDataType()), nodes::add);
r.parseStructures(in, TypedDataStructureNodeReader.of(info.getDataType()), nodes::add);
});
});
return ArrayNode.of(nodes);
@@ -78,7 +80,7 @@ public class DataTableImpl extends DataSourceImpl implements DataTable {
private final TypedAbstractReader nodeReader;
{
nodeReader = TypedReusableDataStructureNodeReader.create(info.getDataType());
nodeReader = TypedDataStructureNodeReader.of(info.getDataType());
parser = new TypedDataStreamParser(info.getDataType());
connection = XPipeConnection.open();