org.apache.drill.exec.physical.impl.scan.v3.schema

Class TestScanSchemaTracker

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.exec.physical.impl.scan.v3.schema.TestScanSchemaTracker

public class TestScanSchemaTracker
extends BaseTest

Test the scan operator schema tracker which computes the final output schema from a variety of sources.

Constructor Summary

Constructors

Constructor and Description
TestScanSchemaTracker()

Method Summary

Modifier and Type	Method and Description
void	testBasics() Basic test: select a set of columns (a, b, c) when the data source has an early schema of (a, b).
void	testEmptyProject()
void	testEmptyProjectWithProvidedSchema()
void	testProvidedSchema() The provided schema is a bit like a defined schema, but it is more of an advisory.
void	testProvidedSchemaWithWildcard()
void	testStrictProvidedSchemaWithWildcard()
void	testWildcard() Wildcard projection, schema change allowed.
void	testWildcardWithExplicitWithProvided() Test for a query of the form: {code SELECT * FROM t ORDER BY a} in which we get a projection list of the form If we are given a provided schema of {@code (a, b, c)}, the "natural" expansion will be @{code (b, c, a)}, but we add a hack to get what the user expects: @{code (a, b, c)}.
void	testWildcardWithExplicitWithProvidedAndReaderSchema()
void	testWildcardWithExplicitWithReaderSchema() Test for a query of the form: {code SELECT * FROM t ORDER BY a} in which we get a projection list of the form If we are given a reader schema of {@code (a, b, c)}, the "natural" expansion will be @{code (b, c, a)}, but we add a hack to get what the user expects: @{code (a, b, c)}.
void	testWildcardWithoutSchemaChange() Wildcard projection, schema change not allowed; first batch defines the schema and projection for later readers.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestScanSchemaTracker

public TestScanSchemaTracker()

Method Detail

testBasics

public void testBasics()

Basic test: select a set of columns (a, b, c) when the data source has an early schema of (a, b).

testWildcard

public void testWildcard()

Wildcard projection, schema change allowed.

testProvidedSchema

public void testProvidedSchema()

The provided schema is a bit like a defined schema, but it is more of an advisory. The provided schema is completely independent of the project list: the user is responsible for choosing the project list wisely.

testProvidedSchemaWithWildcard

public void testProvidedSchemaWithWildcard()

testWildcardWithExplicitWithProvided

public void testWildcardWithExplicitWithProvided()

Test for a query of the form:
{code SELECT * FROM t ORDER BY a}
in which we get a projection list of the form If we are given a provided schema of {@code (a, b, c)}, the "natural" expansion will be @{code (b, c, a)}, but we add a hack to get what the user expects: @{code (a, b, c)}. The "natural" expansion occurs because the projection list says "all all columns to the wildcard position except those mentioned elsewhere". We essentially redefine it as "add or move all columns in provided schema order."

testStrictProvidedSchemaWithWildcard

public void testStrictProvidedSchemaWithWildcard()

testWildcardWithoutSchemaChange

public void testWildcardWithoutSchemaChange()

Wildcard projection, schema change not allowed; first batch defines the schema and projection for later readers.

testEmptyProject

public void testEmptyProject()

testEmptyProjectWithProvidedSchema

public void testEmptyProjectWithProvidedSchema()

testWildcardWithExplicitWithReaderSchema

public void testWildcardWithExplicitWithReaderSchema()

Test for a query of the form:
{code SELECT * FROM t ORDER BY a}
in which we get a projection list of the form If we are given a reader schema of {@code (a, b, c)}, the "natural" expansion will be @{code (b, c, a)}, but we add a hack to get what the user expects: @{code (a, b, c)}. The "natural" expansion occurs because the projection list says "all all columns to the wildcard position except those mentioned elsewhere". We essentially redefine it as "add or move all columns in provided schema order."

testWildcardWithExplicitWithProvidedAndReaderSchema

public void testWildcardWithExplicitWithProvidedAndReaderSchema()