org.apache.calcite.test

Class StreamTest.InfiniteOrdersStreamTableFactory

java.lang.Object

org.apache.calcite.test.StreamTest.InfiniteOrdersStreamTableFactory

All Implemented Interfaces:

org.apache.calcite.schema.TableFactory<org.apache.calcite.schema.Table>

Enclosing class:

StreamTest

public static class StreamTest.InfiniteOrdersStreamTableFactory
extends java.lang.Object
implements org.apache.calcite.schema.TableFactory<org.apache.calcite.schema.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
org.apache.calcite.schema.Table	create(org.apache.calcite.schema.SchemaPlus schema, java.lang.String name, java.util.Map<java.lang.String,java.lang.Object> operand, org.apache.calcite.rel.type.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 org.apache.calcite.schema.Table create(org.apache.calcite.schema.SchemaPlus schema,
                                              java.lang.String name,
                                              java.util.Map<java.lang.String,java.lang.Object> operand,
                                              org.apache.calcite.rel.type.RelDataType rowType)

Specified by:

create in interface org.apache.calcite.schema.TableFactory<org.apache.calcite.schema.Table>