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()