Package | Description |
---|---|
org.apache.storm.hive.bolt.mapper | |
org.apache.storm.hive.common |
Modifier and Type | Class and Description |
---|---|
class |
DelimitedRecordHiveMapper |
class |
JsonRecordHiveMapper |
Modifier and Type | Field and Description |
---|---|
protected HiveMapper |
HiveOptions.mapper |
Modifier and Type | Method and Description |
---|---|
HiveMapper |
HiveOptions.getMapper() |
Modifier and Type | Method and Description |
---|---|
org.apache.hive.hcatalog.streaming.RecordWriter |
HiveWriter.getRecordWriter(HiveMapper mapper,
boolean tokenAuthEnabled) |
Constructor and Description |
---|
HiveOptions(String metaStoreUri,
String databaseName,
String tableName,
HiveMapper mapper) |
HiveWriter(org.apache.hive.hcatalog.streaming.HiveEndPoint endPoint,
int txnsPerBatch,
boolean autoCreatePartitions,
long callTimeout,
ExecutorService callTimeoutPool,
HiveMapper mapper,
org.apache.hadoop.security.UserGroupInformation ugi,
boolean tokenAuthEnabled) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.