Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.connectors.hive.read |
Modifier and Type | Method and Description |
---|---|
static ConsumeOrder |
ConsumeOrder.getConsumeOrder(String consumeOrderStr)
Get
ConsumeOrder from consume order string. |
static ConsumeOrder |
ConsumeOrder.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ConsumeOrder[] |
ConsumeOrder.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
HiveContinuousMonitoringFunction(HiveShim hiveShim,
org.apache.hadoop.mapred.JobConf conf,
ObjectPath tablePath,
CatalogTable catalogTable,
int readerParallelism,
ConsumeOrder consumeOrder,
String consumeOffset,
String extractorKind,
String extractorClass,
String extractorPattern,
long interval) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.