public class toTable extends java.lang.Object implements java.util.stream.Collector<Tuple,TupleList,Table>
| Constructor and Description |
|---|
toTable(Table t)
create table accumulator/collector with schema of given table
|
toTable(TableSchema ts)
create table accumulator for given schema
|
| Modifier and Type | Method and Description |
|---|---|
java.util.function.BiConsumer<TupleList,Tuple> |
accumulator() |
java.util.Set<java.util.stream.Collector.Characteristics> |
characteristics() |
java.util.function.BinaryOperator<TupleList> |
combiner() |
java.util.function.Function<TupleList,Table> |
finisher() |
java.util.function.Supplier<TupleList> |
supplier() |
public toTable(TableSchema ts)
ts - -- table schemapublic toTable(Table t)
t - -- table whose schema is to be usedpublic java.util.Set<java.util.stream.Collector.Characteristics> characteristics()
public java.util.function.BinaryOperator<TupleList> combiner()