Package org.apache.calcite.adapter.pig
Class PigTable
- java.lang.Object
-
- org.apache.calcite.schema.impl.AbstractTable
-
- org.apache.calcite.adapter.pig.PigTable
-
- All Implemented Interfaces:
Table
,TranslatableTable
,Wrapper
public class PigTable extends AbstractTable implements TranslatableTable
Represents a Pig relation that is created by Pig LatinLOAD
statement.Only the default load function is supported at this point (PigStorage()).
Only VARCHAR (CHARARRAY in Pig) type supported at this point.
- See Also:
PigTableFactory
-
-
Field Summary
Fields Modifier and Type Field Description private java.lang.String[]
fieldNames
private java.lang.String
filePath
-
Constructor Summary
Constructors Constructor Description PigTable(java.lang.String filePath, java.lang.String[] fieldNames)
Creates a PigTable.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
getFilePath()
RelDataType
getRowType(RelDataTypeFactory typeFactory)
Returns this table's row type.RelNode
toRel(RelOptTable.ToRelContext context, RelOptTable relOptTable)
Converts this table into arelational expression
.-
Methods inherited from class org.apache.calcite.schema.impl.AbstractTable
getJdbcTableType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg, unwrap
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.calcite.schema.Table
getJdbcTableType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg
-
-
-
-
Method Detail
-
getRowType
public RelDataType getRowType(RelDataTypeFactory typeFactory)
Description copied from interface:Table
Returns this table's row type.This is a struct type whose fields describe the names and types of the columns in this table.
The implementer must use the type factory provided. This ensures that the type is converted into a canonical form; other equal types in the same query will use the same object.
- Specified by:
getRowType
in interfaceTable
- Parameters:
typeFactory
- Type factory with which to create the type- Returns:
- Row type
-
getFilePath
public java.lang.String getFilePath()
-
toRel
public RelNode toRel(RelOptTable.ToRelContext context, RelOptTable relOptTable)
Description copied from interface:TranslatableTable
Converts this table into arelational expression
.- Specified by:
toRel
in interfaceTranslatableTable
-
-