Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.table.filesystem |
Modifier and Type | Class and Description |
---|---|
class |
HiveRowDataPartitionComputer
A
RowDataPartitionComputer that converts Flink objects to Hive objects before computing
the partition value strings. |
Constructor and Description |
---|
ProjectionBulkFactory(BulkWriter.Factory<RowData> factory,
RowDataPartitionComputer computer) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.