mirror of
https://github.com/apache/arrow.git
synced 2026-10-29 00:56:31 +08:00
Renamed 'kerb' parameter to 'kerb_ticket'
This commit is contained in:
1 parent
f1d63de578
commit
c2a4e649c2
4 files changed
+10
-10
No files matched your search
@@ -296,8 +296,8 @@ class HdfsClient::HdfsClientImpl {
|
||||
if (!config->user.empty()) {
|
||||
hdfsBuilderSetUserName(builder, config->user.c_str());
|
||||
}
|
||||
if (!config->kerb.empty()) {
|
||||
hdfsBuilderSetKerbTicketCachePath(builder, config->kerb.c_str());
|
||||
if (!config->kerb_ticket.empty()) {
|
||||
hdfsBuilderSetKerbTicketCachePath(builder, config->kerb_ticket.c_str());
|
||||
}
|
||||
fs_ = hdfsBuilderConnect(builder);
|
||||
|
||||
@@ -305,7 +305,7 @@ class HdfsClient::HdfsClientImpl {
|
||||
namenode_host_ = config->host;
|
||||
port_ = config->port;
|
||||
user_ = config->user;
|
||||
kerb_ = config->kerb;
|
||||
kerb_ticket_ = config->kerb_ticket;
|
||||
|
||||
return Status::OK();
|
||||
}
|
||||
@@ -438,7 +438,7 @@ class HdfsClient::HdfsClientImpl {
|
||||
std::string namenode_host_;
|
||||
std::string user_;
|
||||
int port_;
|
||||
std::string kerb_;
|
||||
std::string kerb_ticket_;
|
||||
|
||||
hdfsFS fs_;
|
||||
};
|
||||
|
||||
@@ -60,7 +60,7 @@ struct HdfsConnectionConfig {
|
||||
std::string host;
|
||||
int port;
|
||||
std::string user;
|
||||
std::string kerb;
|
||||
std::string kerb_ticket;
|
||||
};
|
||||
|
||||
class ARROW_EXPORT HdfsClient : public FileSystemClient {
|
||||
|
||||
@@ -93,7 +93,7 @@ cdef extern from "arrow/io/hdfs.h" namespace "arrow::io" nogil:
|
||||
c_string host
|
||||
int port
|
||||
c_string user
|
||||
c_string kerb
|
||||
c_string kerb_ticket
|
||||
|
||||
cdef cppclass HdfsPathInfo:
|
||||
ObjectType kind;
|
||||
|
||||
@@ -313,7 +313,7 @@ cdef class HdfsClient:
|
||||
raise IOError('HDFS client is closed')
|
||||
|
||||
@classmethod
|
||||
def connect(cls, host="default", port=0, user=None, kerb=None):
|
||||
def connect(cls, host="default", port=0, user=None, kerb_ticket=None):
|
||||
"""
|
||||
Connect to an HDFS cluster. All parameters are optional and should
|
||||
only be set if the defaults need to be overridden.
|
||||
@@ -327,7 +327,7 @@ cdef class HdfsClient:
|
||||
host : NameNode. Set to "default" for fs.defaultFS from core-site.xml.
|
||||
port : NameNode's port. Set to 0 for default or logical (HA) nodes.
|
||||
user : Username when connecting to HDFS; None implies login user.
|
||||
kerb : Path to Kerberos ticket cache.
|
||||
kerb_ticket : Path to Kerberos ticket cache.
|
||||
|
||||
Notes
|
||||
-----
|
||||
@@ -347,8 +347,8 @@ cdef class HdfsClient:
|
||||
conf.port = port
|
||||
if user is not None:
|
||||
conf.user = tobytes(user)
|
||||
if kerb is not None:
|
||||
conf.kerb = tobytes(kerb)
|
||||
if kerb_ticket is not None:
|
||||
conf.kerb_ticket = tobytes(kerb_ticket)
|
||||
|
||||
with nogil:
|
||||
check_status(CHdfsClient.Connect(&conf, &out.client))
|
||||
|
||||
Reference in new issue
Block a user