Package | Description |
---|---|
org.apache.flink.hcatalog | |
org.apache.flink.hcatalog.java |
Modifier and Type | Method and Description |
---|---|
HCatInputFormatBase<T> |
HCatInputFormatBase.asFlinkTuples()
Specifies that the InputFormat returns Flink tuples instead of
HCatRecord . |
HCatInputFormatBase<T> |
HCatInputFormatBase.getFields(String... fields)
Specifies the fields which are returned by the InputFormat and their order.
|
HCatInputFormatBase<T> |
HCatInputFormatBase.withFilter(String filter)
Specifies a SQL-like filter condition on the table's partition columns.
|
Modifier and Type | Class and Description |
---|---|
class |
HCatInputFormat<T>
A InputFormat to read from HCatalog tables.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.