Interface | Description |
---|---|
PeriodicWatermarkAssignerProvider |
Provider of an
AssignerWithPeriodicWatermarks instance as a runtime implementation for
generating watermarks in ScanTableSource . |
PunctuatedWatermarkAssignerProvider |
Provider of an
AssignerWithPunctuatedWatermarks instance as a runtime implementation for
generating watermarks in ScanTableSource . |
SupportsComputedColumnPushDown |
Enables to push down computed columns into a
ScanTableSource . |
SupportsComputedColumnPushDown.ComputedColumnConverter |
Generates and adds computed columns to
RowData if necessary. |
SupportsFilterPushDown |
Enables to push down filters into a
ScanTableSource . |
SupportsLimitPushDown |
Enables to push down a limit (the expected maximum number of produced records) into a
ScanTableSource . |
SupportsPartitionPushDown |
Enables to pass available partitions to the planner and push down partitions into a
ScanTableSource . |
SupportsProjectionPushDown |
Enables to push down a (possibly nested) projection into a
ScanTableSource . |
SupportsWatermarkPushDown |
Enables to push down watermarks into a
ScanTableSource . |
SupportsWatermarkPushDown.WatermarkProvider |
Provides actual runtime implementation for generating watermarks.
|
Class | Description |
---|---|
SupportsFilterPushDown.Result |
Result of a filter push down.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.