@Internal public class TableSourceValidation extends Object
TableSource
types.Modifier and Type | Method and Description |
---|---|
static boolean |
hasProctimeAttribute(TableSource<?> tableSource)
Checks if the given
TableSource defines a proctime attribute. |
static boolean |
hasRowtimeAttribute(TableSource<?> tableSource)
Checks if the given
TableSource defines a rowtime attribute. |
static void |
validateTableSource(TableSource<?> tableSource,
TableSchema schema)
Validates a TableSource.
|
public static void validateTableSource(TableSource<?> tableSource, TableSchema schema)
tableSource
- The TableSource
for which the time attributes are checked.public static boolean hasRowtimeAttribute(TableSource<?> tableSource)
TableSource
defines a rowtime attribute.tableSource
- The table source to check.public static boolean hasProctimeAttribute(TableSource<?> tableSource)
TableSource
defines a proctime attribute.tableSource
- The table source to check.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.