org.apache.drill.exec.store.easy.text.compliant

Class BaseCsvTest

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.ClusterTest

org.apache.drill.exec.store.easy.text.compliant.BaseCsvTest

Direct Known Subclasses:

TestCsvIgnoreHeaders, TestCsvTableProperties, TestCsvWithHeaders, TestCsvWithoutHeaders, TestCsvWithSchema, TestLogReaderIssue, TestPartitionRace, TextCsvWithoutHeadersWithSchema

public class BaseCsvTest
extends ClusterTest

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.test.DrillTest

DrillTest.MemWatcher

Field Summary

Fields

Modifier and Type	Field and Description
protected int	BIG_COL_SIZE
protected static String	EMPTY_FILE
protected static String	FILE_N_NAME
protected static String	NESTED_DIR
protected static String	NESTED_FILE
protected static String	PART_DIR
protected static String	ROOT_FILE
protected static boolean	SCHEMA_BATCH_ENABLED The scan operator can return an empty schema batch as the first batch.
protected static String[]	secondFile
protected static File	testDir
protected static String[]	validHeaders

Fields inherited from class org.apache.drill.test.ClusterTest

client, cluster, dirTestWatcher

Fields inherited from class org.apache.drill.test.DrillTest

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
BaseCsvTest()

Method Summary

Modifier and Type	Method and Description
protected String	buildBigColFile(boolean withHeader)
protected static void	buildFile(File file, String[] data)
protected static void	buildFile(String fileName, String[] data)
protected static void	buildNestedTable()
protected static String	buildTable(String tableName, String[]... fileContents)
protected void	enableMultiScan()
protected void	enableSchema(boolean enable)
protected void	enableSchemaSupport()
protected void	resetMultiScan()
protected void	resetSchema()
protected void	resetSchemaSupport()
protected static void	setup(boolean skipFirstLine, boolean extractHeader)
protected static void	setup(boolean skipFirstLine, boolean extractHeader, int maxParallelization)

Methods inherited from class org.apache.drill.test.ClusterTest

getFile, queryBuilder, run, runAndLog, runAndPrint, runAndPrint, shutdown, startCluster, testBuilder

Methods inherited from class org.apache.drill.test.DrillTest

escapeJsonString, finishDrillTest, initDrillTest

Methods inherited from class java.lang.Object

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

Field Detail

BIG_COL_SIZE

protected final int BIG_COL_SIZE

See Also:

Constant Field Values

PART_DIR

protected static final String PART_DIR

See Also:

Constant Field Values

NESTED_DIR

protected static final String NESTED_DIR

See Also:

Constant Field Values

ROOT_FILE

protected static final String ROOT_FILE

See Also:

Constant Field Values

NESTED_FILE

protected static final String NESTED_FILE

See Also:

Constant Field Values

EMPTY_FILE

protected static final String EMPTY_FILE

See Also:

Constant Field Values

SCHEMA_BATCH_ENABLED

protected static boolean SCHEMA_BATCH_ENABLED

The scan operator can return an empty schema batch as the first batch. But, this broke multiple operators that do not handle this case. So, it is turned off for now. Tests that verified the empty batch use this flag to disable that checking.

validHeaders

protected static String[] validHeaders

secondFile

protected static String[] secondFile

testDir

protected static File testDir

FILE_N_NAME

protected static final String FILE_N_NAME

See Also:

Constant Field Values

Constructor Detail

BaseCsvTest

public BaseCsvTest()

Method Detail

setup

protected static void setup(boolean skipFirstLine,
                            boolean extractHeader)
                     throws Exception

Throws:

Exception

setup

protected static void setup(boolean skipFirstLine,
                            boolean extractHeader,
                            int maxParallelization)
                     throws Exception

Throws:

Exception

buildNestedTable

protected static void buildNestedTable()
                                throws IOException

Throws:

IOException

enableMultiScan

protected void enableMultiScan()

resetMultiScan

protected void resetMultiScan()

enableSchema

protected void enableSchema(boolean enable)

resetSchema

protected void resetSchema()

buildFile

protected static void buildFile(String fileName,
                                String[] data)
                         throws IOException

Throws:

IOException

buildFile

protected static void buildFile(File file,
                                String[] data)
                         throws IOException

Throws:

IOException

buildBigColFile

protected String buildBigColFile(boolean withHeader)
                          throws IOException

Throws:

IOException

buildTable

protected static String buildTable(String tableName,
                                   String[]... fileContents)
                            throws IOException

Throws:

IOException

enableSchemaSupport

protected void enableSchemaSupport()

resetSchemaSupport

protected void resetSchemaSupport()