org.apache.calcite.test

Class StreamTest.InfiniteOrdersStreamTableFactory

java.lang.Object

org.apache.calcite.test.StreamTest.InfiniteOrdersStreamTableFactory

All Implemented Interfaces:

TableFactory<Table>

Enclosing class:

StreamTest

public static class StreamTest.InfiniteOrdersStreamTableFactory
extends Object
implements TableFactory<Table>

Mock table that returns a stream of orders from a fixed array.

Constructor Summary

Constructors

Constructor and Description
InfiniteOrdersStreamTableFactory()

Method Summary

Modifier and Type	Method and Description
Table	create(SchemaPlus schema, String name, Map<String,Object> operand, RelDataType rowType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InfiniteOrdersStreamTableFactory

public InfiniteOrdersStreamTableFactory()

Method Detail

create

public Table create(SchemaPlus schema,
                    String name,
                    Map<String,Object> operand,
                    RelDataType rowType)

Specified by:

create in interface TableFactory<Table>