public class MutatorClientBuilder extends Object
MutatorClient
instances.Modifier and Type | Field and Description |
---|---|
LockFailureListener |
lockFailureListener |
Constructor and Description |
---|
MutatorClientBuilder() |
Modifier and Type | Method and Description |
---|---|
MutatorClientBuilder |
addSinkTable(String databaseName,
String tableName)
Adds a mutation event destination (an ACID table) to be managed by this client, which is either unpartitioned or
will is not to have partitions created automatically.
|
MutatorClientBuilder |
addSinkTable(String databaseName,
String tableName,
boolean createPartitions)
Adds a partitioned mutation event destination (an ACID table) to be managed by this client, where new partitions
will be created as needed.
|
MutatorClientBuilder |
addSourceTable(String databaseName,
String tableName)
Adds a mutation event destination (an ACID table) to be managed by this client, which is either unpartitioned or
will is not to have partitions created automatically.
|
MutatorClientBuilder |
authenticatedUser(org.apache.hadoop.security.UserGroupInformation authenticatedUser) |
MutatorClient |
build()
Builds the client.
|
MutatorClientBuilder |
configuration(HiveConf conf) |
MutatorClientBuilder |
lockFailureListener(LockFailureListener lockFailureListener)
Set a listener to handle
Lock failure events - highly recommended. |
MutatorClientBuilder |
metaStoreUri(String metaStoreUri) |
public LockFailureListener lockFailureListener
public MutatorClientBuilder configuration(HiveConf conf)
public MutatorClientBuilder authenticatedUser(org.apache.hadoop.security.UserGroupInformation authenticatedUser)
public MutatorClientBuilder metaStoreUri(String metaStoreUri)
public MutatorClientBuilder lockFailureListener(LockFailureListener lockFailureListener)
Lock
failure events - highly recommended.public MutatorClientBuilder addSourceTable(String databaseName, String tableName)
public MutatorClientBuilder addSinkTable(String databaseName, String tableName)
public MutatorClientBuilder addSinkTable(String databaseName, String tableName, boolean createPartitions)
public MutatorClient build() throws ClientException, MetaException
ClientException
MetaException
Copyright © 2016 The Apache Software Foundation. All rights reserved.