mirror of
https://github.com/xpipe-io/xpipe.git
synced 2026-04-24 08:31:39 -04:00
Various small fixes
This commit is contained in:
@@ -17,6 +17,22 @@ import java.util.Map;
|
||||
*/
|
||||
public interface DataSource {
|
||||
|
||||
/**
|
||||
* Creates a new supplier data source that will be interpreted as the generated data source.
|
||||
* In case this program should be a data source generator, this method has to be called at
|
||||
* least once to register that it actually generates a data source.
|
||||
*
|
||||
* All content that is written to this data source until the generator program terminates is
|
||||
* will be available later on when the data source is used as a supplier later on.
|
||||
*
|
||||
* In case this method is called multiple times, the same data source is returned.
|
||||
*
|
||||
* @return the generator data source
|
||||
*/
|
||||
static DataSource supplySource() {
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Wrapper for {@link #get(DataSourceId)}.
|
||||
*
|
||||
|
||||
@@ -9,6 +9,13 @@ import java.util.stream.Stream;
|
||||
|
||||
public interface DataTable extends Iterable<TupleNode>, DataSource {
|
||||
|
||||
/**
|
||||
* @see DataSource#supplySource()
|
||||
*/
|
||||
static DataTable supplySource() {
|
||||
return null;
|
||||
}
|
||||
|
||||
Stream<TupleNode> stream();
|
||||
|
||||
int getRowCount();
|
||||
|
||||
Reference in New Issue
Block a user