Package | Description |
---|---|
org.apache.flink.connectors.hive |
Modifier and Type | Method and Description |
---|---|
HiveSourceBuilder |
HiveSourceBuilder.setDynamicFilterPartitionKeys(List<String> dynamicFilterPartitionKeys) |
HiveSourceBuilder |
HiveSourceBuilder.setLimit(Long limit)
Sets the maximum number of records this source should return.
|
HiveSourceBuilder |
HiveSourceBuilder.setPartitions(List<HiveTablePartition> partitions)
Sets the partitions to read in batch mode.
|
HiveSourceBuilder |
HiveSourceBuilder.setProjectedFields(int[] projectedFields)
Sets the indices of projected fields.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.