Package org.apache.beam.runners.spark.structuredstreaming.translation

Interface EvaluationContext.NamedDataset<T>

Enclosing class:
EvaluationContext
public static interface EvaluationContext.NamedDataset<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.spark.sql.Dataset<WindowedValue<T>>
    dataset()
     
    String
    name()