@Test public void testParquetExecution() throws Exception { String ddl = "CREATE FOREIGN TABLE Table1 (\n" + " firstname string ,\n" + " id long ,\n" + " lastname string ,\n" + " CONSTRAINT PK0 PRIMARY KEY(id)\n" + ") OPTIONS (\"teiid_parquet:LOCATION\" 'people1.parquet');"; VirtualFileConnection connection = new JavaVirtualFileConnection(UnitTestUtil.getTestDataPath()); ArrayList<?> results = helpExecute(ddl, connection, "select * from Table1"); Assert.assertEquals("[[Aditya, 1, Sharma], [Animesh, 2, Sharma], [Shradha, 3, Khapra]]", results.toString()); }
public ParquetExecution(Select query, ExecutionContext executionContext, RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable) throws TranslatorException { super(executionContext, metadata, connection, immutable); visit(query); }
ParquetExecution extends BaseParquetExecution implements ResultSetExecution { public ParquetExecution(Select query, ExecutionContext executionContext, RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable) throws TranslatorException { super(executionContext, metadata, connection, immutable); visit(query); } }
ParquetExecution extends BaseParquetExecution implements ResultSetExecution { public ParquetExecution(Select query, ExecutionContext executionContext, RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable) throws TranslatorException { super(executionContext, metadata, connection, immutable); visit(query); } ParquetExecution(Select query, ExecutionContext executionContext,
                            RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable); }
ParquetExecution extends BaseParquetExecution implements ResultSetExecution { public ParquetExecution(Select query, ExecutionContext executionContext, RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable) throws TranslatorException { super(executionContext, metadata, connection, immutable); visit(query); } ParquetExecution(Select query, ExecutionContext executionContext,
                            RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable); @Override List<?> next(); }
ParquetExecution extends BaseParquetExecution implements ResultSetExecution { public ParquetExecution(Select query, ExecutionContext executionContext, RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable) throws TranslatorException { super(executionContext, metadata, connection, immutable); visit(query); } ParquetExecution(Select query, ExecutionContext executionContext,
                            RuntimeMetadata metadata, VirtualFileConnection connection, boolean immutable); @Override List<?> next();  }