Class PigRelFactories.PigFilterFactory

java.lang.Object
org.apache.calcite.adapter.pig.PigRelFactories.PigFilterFactory
All Implemented Interfaces:
RelFactories.FilterFactory
Enclosing class:
PigRelFactories

public static class PigRelFactories.PigFilterFactory extends Object implements RelFactories.FilterFactory
Implementation of RelFactories.FilterFactory that returns a PigFilter.
  • Field Details

  • Constructor Details

    • PigFilterFactory

      public PigFilterFactory()
  • Method Details

    • createFilter

      public RelNode createFilter(RelNode input, RexNode condition, Set<CorrelationId> variablesSet)
      Description copied from interface: RelFactories.FilterFactory
      Creates a filter.

      Some implementations of Filter do not support correlation variables, and for these, this method will throw if variablesSet is not empty.

      Specified by:
      createFilter in interface RelFactories.FilterFactory
      Parameters:
      input - Input relational expression
      condition - Filter condition; only rows for which this condition evaluates to TRUE will be emitted
      variablesSet - Correlating variables that are set when reading a row from the input, and which may be referenced from inside the condition